- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 145 for ClusterID (0.59 sec)
-
pilot/pkg/serviceregistry/instance.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 07 18:40:05 UTC 2023 - 1.5K bytes - Viewed (0) -
pilot/pkg/bootstrap/servicecontroller.go
}) return nil } // initKubeRegistry creates all the k8s service controllers under this pilot func (s *Server) initKubeRegistry(args *PilotArgs) (err error) { args.RegistryOptions.KubeOptions.ClusterID = s.clusterID args.RegistryOptions.KubeOptions.Revision = args.Revision args.RegistryOptions.KubeOptions.Metrics = s.environment args.RegistryOptions.KubeOptions.XDSUpdater = s.XDSServer
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 3.2K bytes - Viewed (0) -
pilot/pkg/xds/xds_test.go
s := xds.NewFakeDiscoveryServer(t, fakeOpts) for clusterID := range want { p := s.SetupProxy(&model.Proxy{Metadata: &model.NodeMetadata{ClusterID: clusterID}}) eps := xdstest.ExtractLoadAssignments(s.Endpoints(p))[tt.serviceCluster] if want := want[clusterID]; !slices.EqualUnordered(eps, want) { t.Errorf("got %v but want %v for %s", eps, want, clusterID) } } }) } }) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 13.8K bytes - Viewed (0) -
istioctl/pkg/writer/pilot/status.go
} cds, lds, eds, rds, ecds := getSyncStatus(&clientConfig) cp := multixds.CpInfo(dr) fullStatus = append(fullStatus, &xdsWriterStatus{ proxyID: clientConfig.GetNode().GetId(), clusterID: meta.ClusterID.String(), istiodID: cp.ID, istiodVersion: meta.IstioVersion, clusterStatus: cds, listenerStatus: lds, routeStatus: rds,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 15 04:16:55 UTC 2024 - 6.1K bytes - Viewed (0) -
istioctl/pkg/workload/workload_test.go
expectedException: true, expectedOutput: "Error: expecting a WorkloadGroup artifact file or the name and namespace of an existing WorkloadGroup\n", }, { description: "Invalid command args - missing valid input spec", args: strings.Split("entry configure -n bar -o temp --clusterID cid", " "), expectedException: true,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 14.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/fake.go
XDSUpdater: xdsUpdater, Metrics: &model.Environment{}, MeshNetworksWatcher: opts.NetworksWatcher, MeshWatcher: opts.MeshWatcher, ClusterID: opts.ClusterID, MeshServiceController: meshServiceController, ConfigCluster: opts.ConfigCluster, SystemNamespace: opts.SystemNamespace, } c := NewController(opts.Client, options)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/endpoint_builder_test.go
cc := &Controller{ nodes: nodes, meshWatcher: mesh.NewFixedWatcher(mesh.DefaultMeshConfig()), networkManager: &networkManager{ clusterID: c.ctl.cluster, network: c.ctl.network, }, opts: Options{ClusterID: c.ctl.cluster}, } eb := cc.NewEndpointBuilder(&pod) assert.Equal(t, eb.labels, c.expected) }) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 7.8K bytes - Viewed (0) -
pkg/config/analysis/analyzers/multicluster/service.go
c.ForEach(gvk.Service, func(r *resource.Instance) bool { clusterID := r.Origin.ClusterName() if clusterID == "" { return true } if _, ok := services[r.Metadata.FullName]; !ok { services[r.Metadata.FullName] = map[cluster.ID]*resource.Instance{} } services[r.Metadata.FullName][clusterID] = r return true }) for fullname, clusterServices := range services {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 08:32:06 UTC 2024 - 4.3K bytes - Viewed (0) -
istioctl/pkg/workload/workload.go
if !validateFlagIsSetManuallyOrNot(cmd, "clusterID") { // extract the cluster ID from the injector config if it is not set by user clusterName, err := extractClusterIDFromInjectionConfig(kubeClient, ctx.IstioNamespace()) if err != nil { return fmt.Errorf("failed to automatically determine the --clusterID: %v", err) } if clusterName != "" { clusterID = clusterName } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 25.5K bytes - Viewed (0) -
pilot/pkg/bootstrap/discovery.go
"istio.io/istio/pilot/pkg/xds" v3 "istio.io/istio/pilot/pkg/xds/v3" "istio.io/istio/pkg/cluster" ) func InitGenerators( s *xds.DiscoveryServer, cg core.ConfigGenerator, systemNameSpace string, clusterID cluster.ID, internalDebugMux *http.ServeMux, ) { env := s.Env generators := map[string]model.XdsResourceGenerator{} edsGen := &xds.EdsGenerator{Cache: s.Cache, EndpointIndex: env.EndpointIndex}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 16 18:25:42 UTC 2024 - 2.6K bytes - Viewed (0)