- Sort Score
- Result 10 results
- Languages All
Results 41 - 46 of 46 for ClusterID (0.2 sec)
-
pilot/pkg/serviceregistry/kube/controller/autoserviceexportcontroller_test.go
}, }, } env := model.Environment{Watcher: mesh.NewFixedWatcher(&m)} env.Init() sc := newAutoServiceExportController(autoServiceExportOptions{ Client: client, ClusterID: "", DomainSuffix: env.DomainSuffix, ClusterLocal: env.ClusterLocal(), }) stop := test.NewStop(t) client.RunAndWait(stop) go sc.Run(stop) t.Run("exportable", func(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 06 16:02:24 UTC 2023 - 4.9K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_cache.go
service, dr, ) } return clusterCache{ clusterName: clusterName, proxyVersion: cb.proxyVersion, locality: cb.locality, proxyClusterID: cb.clusterID, proxySidecar: cb.sidecarProxy(), proxyView: cb.proxyView, hbone: cb.sendHbone, http2: port.Protocol.IsHTTP2(), downstreamAuto: cb.sidecarProxy() && port.Protocol.IsUnsupported(),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 6.1K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/context.go
if len(instances) > 0 { foundInternal.Insert(fmt.Sprintf("%s:%d", g, port)) foundInternalIP.InsertAll(svc.GetAddresses(&model.Proxy{Metadata: &model.NodeMetadata{ClusterID: gc.cluster}})...) if svc.Attributes.ClusterExternalAddresses.Len() > 0 { // Fetch external IPs from all clusters svc.Attributes.ClusterExternalAddresses.ForEach(func(c cluster.ID, externalIPs []string) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 18:33:02 UTC 2024 - 6.2K bytes - Viewed (0) -
pkg/dns/server/name_table.go
} // TODO(stevenctl): headless across-networks https://github.com/istio/istio/issues/38327 sameNetwork := cfg.Node.InNetwork(instance.Network) sameCluster := cfg.Node.InCluster(instance.Locality.ClusterID) // For all k8s headless services, populate the dns table with the endpoint IPs as k8s does. // And for each individual pod, populate the dns table with the endpoint IP with a manufactured host name.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Feb 27 07:19:38 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy_delta_test.go
t.Fatalf("Expected to get listener response but got %v", res) } } func TestDeltaECDSWasmConversion(t *testing.T) { node := model.NodeMetadata{ Namespace: "default", InstanceIPs: []string{"1.1.1.1"}, ClusterID: constants.DefaultClusterName, } proxy := setupXdsProxy(t) // Reset wasm cache to a fake ACK cache. proxy.wasmCache.Cleanup() proxy.wasmCache = &fakeAckCache{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 04:48:02 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/config/analysis/README.md
c.Report(gvk.VirtualService, msg) } } } ``` If you are writing a multi-cluster analyzer, you can obtain the cluster name from the resource metadata: ```go clusterID := r.Origin.ClusterName() ``` ### 2. Add the Analyzer to All()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 08:32:06 UTC 2024 - 9.4K bytes - Viewed (0)