- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 44 for ClusterID (0.15 sec)
-
pilot/pkg/serviceregistry/kube/controller/autoserviceexportcontroller.go
mcsSupported bool } // autoServiceExportOptions provide options for creating a autoServiceExportController. type autoServiceExportOptions struct { Client kube.Client ClusterID cluster.ID DomainSuffix string ClusterLocal model.ClusterLocalProvider } // newAutoServiceExportController creates a new autoServiceExportController.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 5.7K bytes - Viewed (0) -
pilot/pkg/networking/core/route/route_cache.go
) // Cache includes the variables that can influence a Route Configuration. // Implements XdsCacheEntry interface. type Cache struct { RouteName string ProxyVersion string // proxy cluster ID ClusterID string // proxy dns domain DNSDomain string // DNSCapture indicates whether the workload has enabled dns capture DNSCapture bool
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 5.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/multicluster_test.go
stop := test.NewStop(t) s := server.New() mcc := initController(clientset, testSecretNameSpace, stop) mc := NewMulticluster("pilot-abc-123", clientset.Kube(), testSecretNameSpace, Options{ ClusterID: "cluster-1", DomainSuffix: DomainSuffix, MeshWatcher: mesh.NewFixedWatcher(&meshconfig.MeshConfig{}), MeshServiceController: mockserviceController,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 16:44:32 UTC 2024 - 6.7K bytes - Viewed (0) -
pilot/pkg/xds/ecds.go
// Generate the pull secrets first, which will be used when populating the extension config. if e.secretController != nil { var err error secretController, err := e.secretController.ForCluster(proxy.Metadata.ClusterID) if err != nil { log.Warnf("proxy %s is from an unknown cluster, cannot retrieve certificates for Wasm image pull: %v", proxy.ID, err) return nil, model.DefaultXdsLogDetails, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 16 18:25:42 UTC 2024 - 7.2K bytes - Viewed (0) -
pilot/cmd/pilot-discovery/app/cmd.go
"DNS domain suffix") c.PersistentFlags().StringVar((*string)(&serverArgs.RegistryOptions.KubeOptions.ClusterID), "clusterID", features.ClusterName, "The ID of the cluster that this Istiod instance resides") c.PersistentFlags().StringToStringVar(&serverArgs.RegistryOptions.KubeOptions.ClusterAliases, "clusterAliases", map[string]string{},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 16:44:32 UTC 2024 - 8.5K bytes - Viewed (0) -
pilot/cmd/pilot-agent/options/security.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 4.7K bytes - Viewed (0) -
pkg/test/framework/components/istio/ca.go
Csr: string(csrPEM), ValidityDuration: int64((time.Hour * 24 * 7).Seconds()), } rctx := metadata.NewOutgoingContext(context.Background(), metadata.Pairs("Authorization", "Bearer "+token, "ClusterID", constants.DefaultClusterName)) resp, err := client.CreateCertificate(rctx, req) if err != nil { return Cert{}, fmt.Errorf("send CSR: %v", err) } certChain := []byte{} for _, c := range resp.CertChain {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 4.5K bytes - Viewed (0) -
pilot/pkg/xds/nds_test.go
nameTable: nil, }, } for _, tt := range cases { t.Run(tt.name, func(t *testing.T) { if tt.proxy.Metadata == nil { tt.proxy.Metadata = &model.NodeMetadata{} } tt.proxy.Metadata.ClusterID = constants.DefaultClusterName s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{}) gen := s.Discovery.Generators[v3.NameTableType] tt.request.Start = time.Now()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 4.6K bytes - Viewed (0) -
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)