- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for AppendWorkloadHandler (0.35 sec)
-
pilot/pkg/model/controller.go
// AppendServiceHandler notifies about changes to the service catalog. AppendServiceHandler(f ServiceHandler) // AppendWorkloadHandler notifies about changes to workloads. This differs from InstanceHandler, // which deals with service instances (the result of a merge of Service and Workload) AppendWorkloadHandler(f func(*WorkloadInstance, Event)) // Run until a signal is received Run(stop <-chan struct{})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 25 06:54:32 UTC 2023 - 4.7K bytes - Viewed (0) -
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/memory/discovery.go
} func (sd *ServiceDiscovery) MCSServices() []model.MCSServiceInfo { return nil } // Memory does not support workload handlers; everything is done in terms of instances func (sd *ServiceDiscovery) AppendWorkloadHandler(func(*model.WorkloadInstance, model.Event)) {} // AppendServiceHandler appends a service handler to the controller func (sd *ServiceDiscovery) AppendServiceHandler(f model.ServiceHandler) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 23:10:01 UTC 2024 - 12.4K 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)