Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for onEndpointsDelete (0.14 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top