- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for WithClusterID (0.15 sec)
-
pilot/pkg/bootstrap/servicecontroller.go
serviceControllers := s.ServiceController() s.serviceEntryController = serviceentry.NewController( s.configController, s.XDSServer, s.environment.Watcher, serviceentry.WithClusterID(s.clusterID), ) serviceControllers.AddRegistry(s.serviceEntryController) registered := sets.New[provider.ID]() for _, r := range args.RegistryOptions.Registries { serviceRegistry := provider.ID(r)
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/serviceregistry/kube/controller/multicluster.go
kubeController.workloadEntryController = serviceentry.NewWorkloadEntryController( configStore, options.XDSUpdater, m.opts.MeshWatcher, serviceentry.WithClusterID(cluster.ID), serviceentry.WithNetworkIDCb(kubeRegistry.Network)) // Services can select WorkloadEntry from the same cluster. We only duplicate the Service to configure kube-dns.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 12.7K bytes - Viewed (0) -
pilot/pkg/networking/core/fake.go
} serviceDiscovery := aggregate.NewController(aggregate.Options{}) se := serviceentry.NewController( configController, xdsUpdater, env.Watcher, serviceentry.WithClusterID(opts.ClusterID)) // TODO allow passing in registry, for k8s, mem reigstry serviceDiscovery.AddRegistry(se) msd := memregistry.NewServiceDiscovery(opts.Services...) msd.XdsUpdater = xdsUpdater
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 11.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller.go
workloadEntryController bool meshWatcher mesh.Watcher model.NoopAmbientIndexes model.NetworkGatewaysHandler } type Option func(*Controller) func WithClusterID(clusterID cluster.ID) Option { return func(o *Controller) { o.clusterID = clusterID } } func WithNetworkIDCb(cb func(endpointIP string, labels labels.Instance) network.ID) Option {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 36.8K bytes - Viewed (0)