- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for onEndpointsDelete (0.12 sec)
-
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go
return } c.queueEndpoints(obj) } // onEndpointsDelete queues a sync for the relevant Endpoints resource. func (c *Controller) onEndpointsDelete(logger klog.Logger, obj interface{}) { endpoints := getEndpointsFromDeleteAction(obj) if endpoints == nil { utilruntime.HandleError(fmt.Errorf("onEndpointsDelete() expected type v1.Endpoints, got %T", obj)) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 23:18:31 UTC 2024 - 20.1K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller.go
}) e.podLister = podInformer.Lister() e.podsSynced = podInformer.Informer().HasSynced endpointsInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ DeleteFunc: e.onEndpointsDelete, }) e.endpointsLister = endpointsInformer.Lister() e.endpointsSynced = endpointsInformer.Informer().HasSynced e.triggerTimeTracker = endpointsliceutil.NewTriggerTimeTracker()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 26.3K bytes - Viewed (0) -
pkg/proxy/config/config.go
utilruntime.HandleError(fmt.Errorf("unexpected object type: %T", obj)) return } } for _, h := range c.eventHandlers { c.logger.V(4).Info("Calling handler.OnEndpointsDelete") h.OnEndpointSliceDelete(endpointSlice) } } // ServiceConfig tracks a set of service configurations. type ServiceConfig struct { listerSynced cache.InformerSynced
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 15.1K bytes - Viewed (0)