- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 40 for DefaultMeshConfig (0.35 sec)
-
pilot/pkg/serviceregistry/kube/controller/ambient/meshconfig.go
if options.Revision != "" && options.Revision != "default" { cmName = cmName + "-" + options.Revision } return krt.NewSingleton[MeshConfig]( func(ctx krt.HandlerContext) *MeshConfig { meshCfg := mesh.DefaultMeshConfig() cms := []*v1.ConfigMap{} if features.SharedMeshConfig != "" { cms = AppendNonNil(cms, krt.FetchOne(ctx, ConfigMaps,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 09 19:55:53 UTC 2024 - 2.2K bytes - Viewed (0) -
pilot/pkg/xds/lds_test.go
s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{ ConfigString: mustReadfolder(t, "tests/testdata/networking/sidecar-ns-scope"), MeshConfig: func() *meshconfig.MeshConfig { m := mesh.DefaultMeshConfig() m.RootNamespace = "istio-config" return m }(), }) adsc := s.Connect(&model.Proxy{ConfigNamespace: "ns1", IPAddresses: []string{"100.1.1.2"}}, nil, watchAll)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 13.1K bytes - Viewed (0) -
operator/pkg/util/merge_iop_test.go
t.Fail() } } func TestOverlayIOPDefaultMeshConfig(t *testing.T) { // Transform default mesh config into map[string]interface{} for inclusion in IstioOperator. m := mesh.DefaultMeshConfig() my, err := protomarshal.ToJSONMap(m) if err != nil { t.Fatal(err) } iop := &v1alpha1.IstioOperator{ Spec: &v1alpha12.IstioOperatorSpec{ MeshConfig: MustStruct(my), }, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 15 20:10:17 UTC 2022 - 3.7K bytes - Viewed (0) -
pilot/pkg/model/sidecar_test.go
name: "default MeshConfig, no Sidecar", meshConfig: mesh.DefaultMeshConfig(), sidecar: nil, outboundTrafficPolicy: &networking.OutboundTrafficPolicy{ Mode: networking.OutboundTrafficPolicy_ALLOW_ANY, }, }, { name: "default MeshConfig, sidecar without OutboundTrafficPolicy", meshConfig: mesh.DefaultMeshConfig(), sidecar: configWithoutOutboundTrafficPolicy,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 07 09:38:49 UTC 2024 - 74.3K bytes - Viewed (0) -
pilot/pkg/bootstrap/mesh.go
} return } } // Config file either didn't exist or failed to load. if s.kubeClient == nil { // Use a default mesh. meshConfig := mesh.DefaultMeshConfig() s.environment.Watcher = mesh.NewFixedWatcher(meshConfig) log.Warnf("Using default mesh - missing file %s and no k8s client", args.MeshConfigFile) return }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 4.5K bytes - Viewed (0) -
pilot/pkg/config/kube/ingress/status_test.go
{ Type: corev1.NodeExternalIP, Address: nodeIP, }, }, }, }, } func fakeMeshHolder(ingressService string) mesh.Watcher { config := mesh.DefaultMeshConfig() config.IngressService = ingressService return mesh.NewFixedWatcher(config) } func makeStatusSyncer(t *testing.T, name string) *StatusSyncer { client := kubelib.NewFakeClient(testObjects...)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 5.8K bytes - Viewed (0) -
tests/integration/telemetry/util.go
func GetTrustDomain(cluster cluster.Cluster, istioNamespace string) string { meshConfigMap, err := cluster.Kube().CoreV1().ConfigMaps(istioNamespace).Get(context.Background(), "istio", metav1.GetOptions{}) defaultTrustDomain := mesh.DefaultMeshConfig().TrustDomain if err != nil { return defaultTrustDomain } configYaml, ok := meshConfigMap.Data["mesh"] if !ok { return defaultTrustDomain }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Oct 13 16:30:22 UTC 2022 - 4.8K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/deploymentcontroller_test.go
ImageType: "distroless", }, }, }); err != nil { t.Fatalf("failed to create ProxyConfigs: %s", err) } proxyConfig := model.GetProxyConfigs(store, mesh.DefaultMeshConfig()) tests := []struct { name string gw k8sbeta.Gateway objects []runtime.Object pcs *model.ProxyConfigs
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 21:43:20 UTC 2024 - 16.5K bytes - Viewed (0) -
pilot/pkg/networking/core/accesslog_test.go
wantFormat: model.EnvoyTextLogFormat, }, } { tc := tc t.Run(tc.name, func(t *testing.T) { accessLogBuilder.reset() // Update MeshConfig m := mesh.DefaultMeshConfig() m.AccessLogFile = "foo" m.AccessLogEncoding = tc.encoding m.AccessLogFormat = tc.format listeners := buildListeners(t, TestOptions{MeshConfig: m}, nil) if len(listeners) != 2 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 19.9K bytes - Viewed (0) -
pilot/cmd/pilot-agent/config/config.go
// untouched fields will remain untouched. This means lists will be replaced, not appended to, for example. func getMeshConfig(fileOverride, annotationOverride, proxyConfigEnv string) (*meshconfig.MeshConfig, error) { mc := mesh.DefaultMeshConfig() if fileOverride != "" { log.Infof("Apply mesh config from file %v", fileOverride) fileMesh, err := mesh.ApplyMeshConfig(fileOverride, mc) if err != nil || fileMesh == 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)