Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 399 for MeshConfig (0.17 sec)

  1. pilot/cmd/pilot-agent/config/config.go

    		}
    		fileMeshContents = string(contents)
    	}
    	meshConfig, err := getMeshConfig(fileMeshContents, annotations[annotation.ProxyConfig.Name], proxyConfigEnv)
    	if err != nil {
    		return nil, err
    	}
    	proxyConfig := mesh.DefaultProxyConfig()
    	if meshConfig.DefaultConfig != nil {
    		proxyConfig = meshConfig.DefaultConfig
    	}
    
    	// Concurrency wasn't explicitly set
    	if proxyConfig.Concurrency == nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 20:06:41 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  2. pilot/pkg/model/conversion_test.go

    			in:   `{"enableTracing": true}`,
    			want: &meshconfig.MeshConfig{EnableTracing: true},
    		},
    		{
    			in:   `{"enableTracing": true, "unknownField": "unknownValue"}`,
    			want: &meshconfig.MeshConfig{EnableTracing: true},
    		},
    	}
    	for i, c := range cases {
    		t.Run(fmt.Sprintf("[%v]", i), func(tt *testing.T) {
    			var got meshconfig.MeshConfig
    			err := protomarshal.ApplyJSON(c.in, &got)
    			if err != nil {
    				if !c.wantErr {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 02 20:50:14 UTC 2023
    - 5.1K bytes
    - Viewed (0)
  3. operator/pkg/apis/istio/v1alpha1/validation/validation.go

    		{"Values.global.proxy.holdApplicationUntilProxyStarts", "meshConfig.defaultConfig.holdApplicationUntilProxyStarts", false},
    		{"Values.pilot.ingress", "meshConfig.ingressService, meshConfig.ingressControllerMode, and meshConfig.ingressClass", nil},
    		{"Values.global.mtls.enabled", "the PeerAuthentication resource", nil},
    		{"Values.global.mtls.auto", "meshConfig.enableAutoMtls", nil},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 16 20:02:28 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  4. pkg/config/analysis/analyzers/telemetry/util.go

    	}
    	sort.Strings(names)
    	return names
    }
    
    func fetchMeshConfig(c analysis.Context) *v1alpha1.MeshConfig {
    	var meshConfig *v1alpha1.MeshConfig
    	c.ForEach(gvk.MeshConfig, func(r *resource.Instance) bool {
    		meshConfig = r.Message.(*v1alpha1.MeshConfig)
    		return r.Metadata.FullName.Name != util.MeshConfigName
    	})
    
    	return meshConfig
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun May 05 03:44:57 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  5. pilot/pkg/networking/core/tracing.go

    	case *meshconfig.MeshConfig_ExtensionProvider_EnvoyExtAuthzHttp,
    		*meshconfig.MeshConfig_ExtensionProvider_EnvoyExtAuthzGrpc,
    		*meshconfig.MeshConfig_ExtensionProvider_EnvoyHttpAls,
    		*meshconfig.MeshConfig_ExtensionProvider_EnvoyTcpAls,
    		*meshconfig.MeshConfig_ExtensionProvider_EnvoyOtelAls,
    		*meshconfig.MeshConfig_ExtensionProvider_EnvoyFileAccessLog,
    		*meshconfig.MeshConfig_ExtensionProvider_Prometheus:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 16 17:05:28 UTC 2024
    - 24.2K bytes
    - Viewed (0)
  6. pkg/config/analysis/analyzers/authz/authorizationpolicies.go

    // It takes the MeshConfig names istio, if not the last instance found.
    func meshWidePolicy(ns string, c analysis.Context) bool {
    	mConf := fetchMeshConfig(c)
    	return mConf != nil && ns == mConf.GetRootNamespace()
    }
    
    func fetchMeshConfig(c analysis.Context) *v1alpha1.MeshConfig {
    	if meshConfig != nil {
    		return meshConfig
    	}
    
    	c.ForEach(gvk.MeshConfig, func(r *resource.Instance) bool {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Sep 11 20:57:29 UTC 2023
    - 6K bytes
    - Viewed (0)
  7. pkg/config/mesh/networks_watcher_test.go

    	g := NewWithT(t)
    
    	path := newTempFile(t)
    	defer removeSilent(path)
    
    	n := meshconfig.MeshNetworks{
    		Networks: make(map[string]*meshconfig.Network),
    	}
    	writeMessage(t, path, &n)
    
    	w := newNetworksWatcher(t, path)
    	g.Expect(w.Networks()).To(Equal(&n))
    
    	doneCh := make(chan struct{}, 1)
    
    	var newN *meshconfig.MeshNetworks
    	w.AddNetworksHandler(func() {
    		newN = w.Networks()
    		close(doneCh)
    	})
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Oct 31 14:48:28 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  8. istioctl/pkg/kubeinject/kubeinject.go

    			return nil, nil, err
    		}
    	}
    	return injector, meshConfig, err
    }
    
    // getIOPConfigs gets the configs in IOPs.
    func getIOPConfigs() (string, *meshconfig.MeshConfig, error) {
    	var meshConfig *meshconfig.MeshConfig
    	var valuesConfig string
    	if iopFilename != "" {
    		var iop *iopv1alpha1.IstioOperator
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Mar 29 02:29:02 UTC 2024
    - 21.6K bytes
    - Viewed (0)
  9. pilot/pkg/model/telemetry_test.go

    )
    
    var (
    	jsonTextProvider = &meshconfig.MeshConfig_ExtensionProvider{
    		Name: "envoy-json",
    		Provider: &meshconfig.MeshConfig_ExtensionProvider_EnvoyFileAccessLog{
    			EnvoyFileAccessLog: &meshconfig.MeshConfig_ExtensionProvider_EnvoyFileAccessLogProvider{
    				Path: "/dev/stdout",
    				LogFormat: &meshconfig.MeshConfig_ExtensionProvider_EnvoyFileAccessLogProvider_LogFormat{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:30 UTC 2024
    - 39.6K bytes
    - Viewed (0)
  10. pilot/pkg/config/kube/ingress/conversion_test.go

    		ingressClass  *knetworking.IngressClass
    		ingressMode   meshconfig.MeshConfig_IngressControllerMode
    		shouldProcess bool
    	}{
    		// Annotation
    		{ingressMode: meshconfig.MeshConfig_DEFAULT, annotation: "nginx", shouldProcess: false},
    		{ingressMode: meshconfig.MeshConfig_STRICT, annotation: "nginx", shouldProcess: false},
    		{ingressMode: meshconfig.MeshConfig_OFF, annotation: istio, shouldProcess: false},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 19 18:20:34 UTC 2023
    - 14.9K bytes
    - Viewed (0)
Back to top