- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 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) -
pkg/controller/endpoint/endpoints_controller_test.go
} if req.Method == "DELETE" { go func() { // Delay the deletion of endoints to make endpoint cache out of sync <-blockDelete controller.endpointsStore.Delete(endpoint) controller.onEndpointsDelete(endpoint) }() blockNextAction <- struct{}{} } res.WriteHeader(http.StatusOK) res.Write([]byte(runtime.EncodeOrDie(clientscheme.Codecs.LegacyCodec(v1.SchemeGroupVersion), &v1.Endpoints{}))) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 87.7K bytes - Viewed (0)