Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for UpdateMeshConfig (0.17 sec)

  1. pkg/test/framework/components/istio/configmap.go

    	t.Helper()
    	if err := mc.UpdateMeshConfig(ctx, update, cleanupStrategy); err != nil {
    		t.Fatal(err)
    	}
    }
    
    func (mc *meshConfig) PatchMeshConfig(t resource.Context, patch string) error {
    	return mc.UpdateMeshConfig(t, func(mc *meshconfig.MeshConfig) error {
    		return protomarshal.ApplyYAML(patch, mc)
    	}, cleanup.Always)
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  2. pkg/test/framework/components/istio/istio.go

    	ValuesOrFail(test.Failer) OperatorValues
    	// MeshConfig used by the Istio installation.
    	MeshConfig() (*meshconfig.MeshConfig, error)
    	MeshConfigOrFail(test.Failer) *meshconfig.MeshConfig
    	// UpdateMeshConfig used by the Istio installation.
    	UpdateMeshConfig(resource.Context, func(*meshconfig.MeshConfig) error, cleanup.Strategy) error
    	UpdateMeshConfigOrFail(resource.Context, test.Failer, func(*meshconfig.MeshConfig) error, cleanup.Strategy)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Oct 30 17:47:34 UTC 2023
    - 8K bytes
    - Viewed (0)
  3. pkg/test/framework/components/authz/kube.go

    		return err
    	}
    
    	providerNames := sets.New[string]()
    	for _, p := range newMC.GetExtensionProviders() {
    		providerNames.Insert(p.Name)
    	}
    
    	return ist.UpdateMeshConfig(ctx,
    		func(mc *meshconfig.MeshConfig) error {
    			newProviders := []*meshconfig.MeshConfig_ExtensionProvider{}
    			// Merge the extension providers.
    			// If we are overwriting an existing one, keep the new one.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 10 20:33:28 UTC 2024
    - 7K bytes
    - Viewed (0)
  4. pilot/pkg/serviceregistry/kube/controller/controller_test.go

    		DefaultAddress: "10.0.0.1",
    		Ports: model.PortList{
    			&model.Port{
    				Name:     "tcp-port",
    				Port:     8083,
    				Protocol: protocol.TCP,
    			},
    		},
    	}
    
    	updateMeshConfig := func(
    		meshConfig *meshconfig.MeshConfig,
    		expectedSvcList []*model.Service,
    		expectedNumSvcEvents int,
    		testMeshWatcher *mesh.TestWatcher,
    		fx *xdsfake.Updater,
    		controller *FakeController,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 85K bytes
    - Viewed (0)
Back to top