- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 524 for cluster0 (0.13 sec)
-
pilot/pkg/serviceregistry/aggregate/controller.go
} return out } func nodeClusterID(node *model.Proxy) cluster.ID { if node.Metadata == nil || node.Metadata.ClusterID == "" { return "" } return node.Metadata.ClusterID } // Skip the service registry when there won't be a match // because the proxy is in a different cluster. func skipSearchingRegistryForProxy(nodeClusterID cluster.ID, r serviceregistry.Instance) bool {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 13.5K bytes - Viewed (0) -
pkg/test/framework/components/echo/echotest/filters_test.go
"a.echo1.svc.cluster.local": { "b.echo1.svc.cluster.local_external.echo1.svc.cluster.local_naked.echo1.svc.cluster.local": 2, "external.echo1.svc.cluster.local_naked.echo1.svc.cluster.local_vm.echo1.svc.cluster.local": 2, }, "a.echo2.svc.cluster.local": { "b.echo1.svc.cluster.local_external.echo1.svc.cluster.local_naked.echo1.svc.cluster.local": 2,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 13.1K bytes - Viewed (0) -
pkg/test/framework/test.go
// max clusters doesn't check kube only, the test may be written in a way that doesn't loop over all of Clusters() if t.requiredMaxClusters > 0 && len(t.s.Environment().Clusters()) > t.requiredMaxClusters { t.goTest.Skipf("Skipping %q: number of clusters %d is above required max %d", t.goTest.Name(), len(t.s.Environment().Clusters()), t.requiredMaxClusters) return } if t.minKubernetesMinorVersion > 0 { for _, c := range ctx.Clusters() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 10.3K bytes - Viewed (0) -
pilot/pkg/features/experimental.go
"MeshConfig are excluded.", ).Get() EnableMCSServiceDiscovery = env.Register( "ENABLE_MCS_SERVICE_DISCOVERY", false, "If enabled, istiod will enable Kubernetes Multi-Cluster "+ "Services (MCS) service discovery mode. In this mode, service "+ "endpoints in a cluster will only be discoverable within the "+ "same cluster unless explicitly exported via ServiceExport.").Get()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:02:38 UTC 2024 - 10.2K bytes - Viewed (0) -
pkg/test/framework/components/istio/config.go
// before running tests. DeployEastWestGW bool // DumpKubernetesManifests will cause Kubernetes YAML generated by istioctl install/generate to be dumped to artifacts. DumpKubernetesManifests bool // IstiodlessRemotes makes remote clusters run without istiod, using webhooks/ca from the primary cluster. // TODO we could set this per-cluster if istiod was smarter about patching remotes.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 10 20:33:28 UTC 2024 - 14.8K bytes - Viewed (0) -
pkg/adsc/adsc.go
} a.handleLDS(listeners) case v3.ClusterType: clusters := make([]*cluster.Cluster, 0, len(msg.Resources)) for _, rsc := range msg.Resources { valBytes := rsc.Value cl := &cluster.Cluster{} _ = proto.Unmarshal(valBytes, cl) clusters = append(clusters, cl) } a.handleCDS(clusters) case v3.EndpointType:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 05 22:18:49 UTC 2024 - 35K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/authorizer/webhook/webhook_v1beta1_test.go
wantErr bool }{ { msg: "a single cluster and single user", configTmpl: ` clusters: - cluster: certificate-authority: {{ .CA }} server: https://authz.example.com name: foobar users: - name: a cluster user: client-certificate: {{ .Cert }} client-key: {{ .Key }} `, wantErr: true, }, { msg: "multiple clusters with no context", configTmpl: ` clusters:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 22:41:27 UTC 2024 - 19.9K bytes - Viewed (0) -
pilot/pkg/features/pilot.go
"in the cluster metadata for those endpoints.").Get() LocalClusterSecretWatcher = env.Register("LOCAL_CLUSTER_SECRET_WATCHER", false, "If enabled, the cluster secret watcher will watch the namespace of the external cluster instead of config cluster").Get() InformerWatchNamespace = env.Register("ISTIO_WATCH_NAMESPACE", "",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 13.3K bytes - Viewed (0) -
pilot/pkg/networking/core/networkfilter.go
// because it is set on listener, not on a cluster. tunnelingconfig.Apply(tcpProxy, destinationRule, "") // TODO: Need to handle multiple cluster names for Redis clusterName := clusterSpecifier.WeightedClusters.Clusters[0].Name class := model.OutboundListenerClass(lb.node.Type) tcpFilter := setAccessLogAndBuildTCPFilter(lb.push, lb.node, tcpProxy, class, nil)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 13.7K bytes - Viewed (0) -
pilot/pkg/xds/xds_test.go
serviceCluster string wantClusterLocal map[cluster.ID][]string wantNonClusterLocal map[cluster.ID][]string }{ // set up a k8s service in each cluster, with a pod in each cluster and a workloadentry in cluster-1 "k8s service with pod and workloadentry": { fakeOpts: func() xds.FakeOptions { k8sObjects := map[cluster.ID]string{ "cluster-1": "", "cluster-2": "", } i := 1
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 13.8K bytes - Viewed (0)