- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for AppendWorkloadHandler (0.64 sec)
-
pilot/pkg/serviceregistry/kube/controller/multicluster.go
kubeController.workloadEntryController.AppendWorkloadHandler(kubeRegistry.WorkloadInstanceHandler) // ServiceEntry selects WorkloadEntry from remote cluster kubeController.workloadEntryController.AppendWorkloadHandler(m.serviceEntryController.WorkloadInstanceHandler) if features.EnableEnhancedResourceScoping {
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/serviceregistry/kube/controller/pod_test.go
} func TestHostNetworkPod(t *testing.T) { c, fx := NewFakeControllerWithOptions(t, FakeControllerOptions{}) pods := clienttest.Wrap(t, c.podsClient) events := assert.NewTracker[string](t) c.AppendWorkloadHandler(func(instance *model.WorkloadInstance, event model.Event) { events.Record(fmt.Sprintf("%v/%v", instance.Name, event)) }) initTestEnv(t, c.client.Kube(), fx) createPod := func(ip, name string) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 18:27:40 UTC 2024 - 12.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller.go
c.handlers.AppendServiceHandler(f) } func (c *Controller) AppendWorkloadHandler(f func(*model.WorkloadInstance, model.Event)) { // Currently, it is not used. // Note: take care when you want to enable it, it will register the handlers to all registries // c.handlers.AppendWorkloadHandler(f) } func (c *Controller) AppendServiceHandlerForCluster(id cluster.ID, f model.ServiceHandler) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 13.5K bytes - Viewed (0) -
pilot/test/xds/fake.go
if !ok || k8s.Cluster() != cg.ServiceEntryRegistry.Cluster() { continue } cg.ServiceEntryRegistry.AppendWorkloadHandler(k8s.WorkloadInstanceHandler) k8s.AppendWorkloadHandler(cg.ServiceEntryRegistry.WorkloadInstanceHandler) } s.WorkloadEntryController = autoregistration.NewController(cg.Store(), "test", keepalive.Infinity) var listener net.Listener
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 16:08:52 UTC 2024 - 18.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
func (c *Controller) AppendServiceHandler(f model.ServiceHandler) { c.handlers.AppendServiceHandler(f) } // AppendWorkloadHandler implements a service catalog operation func (c *Controller) AppendWorkloadHandler(f func(*model.WorkloadInstance, model.Event)) { c.handlers.AppendWorkloadHandler(f) } // AppendNamespaceDiscoveryHandlers register handlers on namespace selected/deselected by discovery selectors change.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller.go
func (s *Controller) AppendServiceHandler(_ model.ServiceHandler) {} // AppendWorkloadHandler adds instance event handler. Service Entries does not use these handlers. func (s *Controller) AppendWorkloadHandler(h func(*model.WorkloadInstance, model.Event)) { s.workloadHandlers = append(s.workloadHandlers, h) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 36.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceregistry_test.go
stop := istiotest.NewStop(t) go configController.Run(stop) se := serviceentry.NewController(configController, xdsUpdater, meshWatcher) client.RunAndWait(stop) kc.AppendWorkloadHandler(se.WorkloadInstanceHandler) se.AppendWorkloadHandler(kc.WorkloadInstanceHandler) go kc.Run(stop) go se.Run(stop) return configController, client.Kube(), xdsUpdater }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 51.2K bytes - Viewed (0)