kubernetes/pkg/controller/endpointslice/endpointslice_controller.go

const maxRetries …

const endpointSliceChangeMinSyncDelay …

const defaultSyncBackOff …

const maxSyncBackOff …

const controllerName …

const topologyQueueItemKey …

// NewController creates and initializes a new Controller
func NewController(ctx context.Context, podInformer coreinformers.PodInformer,
	serviceInformer coreinformers.ServiceInformer,
	nodeInformer coreinformers.NodeInformer,
	endpointSliceInformer discoveryinformers.EndpointSliceInformer,
	maxEndpointsPerSlice int32,
	client clientset.Interface,
	endpointUpdatesBatchPeriod time.Duration,
) *Controller { … }

type Controller …

// Run will not return until stopCh is closed.
func (c *Controller) Run(ctx context.Context, workers int) { … }

// serviceQueueWorker runs a worker thread that just dequeues items, processes
// them, and marks them done. You may run as many of these in parallel as you
// wish; the workqueue guarantees that they will not end up processing the same
// service at the same time
func (c *Controller) serviceQueueWorker(logger klog.Logger) { … }

func (c *Controller) processNextServiceWorkItem(logger klog.Logger) bool { … }

func (c *Controller) topologyQueueWorker(logger klog.Logger) { … }

func (c *Controller) processNextTopologyWorkItem(logger klog.Logger) bool { … }

func (c *Controller) handleErr(logger klog.Logger, err error, key string) { … }

func (c *Controller) syncService(logger klog.Logger, key string) error { … }

// onServiceUpdate updates the Service Selector in the cache and queues the Service for processing.
func (c *Controller) onServiceUpdate(obj interface{ … }

// onServiceDelete removes the Service Selector from the cache and queues the Service for processing.
func (c *Controller) onServiceDelete(obj interface{ … }

// onEndpointSliceAdd queues a sync for the relevant Service for a sync if the
// EndpointSlice resource version does not match the expected version in the
// endpointSliceTracker.
func (c *Controller) onEndpointSliceAdd(obj interface{ … }

// onEndpointSliceUpdate queues a sync for the relevant Service for a sync if
// the EndpointSlice resource version does not match the expected version in the
// endpointSliceTracker or the managed-by value of the EndpointSlice has changed
// from or to this controller.
func (c *Controller) onEndpointSliceUpdate(logger klog.Logger, prevObj, obj interface{ … }

// onEndpointSliceDelete queues a sync for the relevant Service for a sync if the
// EndpointSlice resource version does not match the expected version in the
// endpointSliceTracker.
func (c *Controller) onEndpointSliceDelete(obj interface{ … }

// queueServiceForEndpointSlice attempts to queue the corresponding Service for
// the provided EndpointSlice.
func (c *Controller) queueServiceForEndpointSlice(endpointSlice *discovery.EndpointSlice) { … }

func (c *Controller) addPod(obj interface{ … }

func (c *Controller) updatePod(old, cur interface{ … }

// When a pod is deleted, enqueue the services the pod used to be a member of
// obj could be an *v1.Pod, or a DeletionFinalStateUnknown marker item.
func (c *Controller) deletePod(obj interface{ … }

func (c *Controller) addNode() { … }

func (c *Controller) updateNode(old, cur interface{ … }

func (c *Controller) deleteNode() { … }

// checkNodeTopologyDistribution updates Nodes in the topology cache and then
// queues any Services that are past the threshold.
func (c *Controller) checkNodeTopologyDistribution(logger klog.Logger) { … }

// trackSync increments the EndpointSliceSyncs metric with the result of a sync.
func trackSync(err error) { … }

func dropEndpointSlicesPendingDeletion(endpointSlices []*discovery.EndpointSlice) []*discovery.EndpointSlice { … }

// getEndpointSliceFromDeleteAction parses an EndpointSlice from a delete action.
func getEndpointSliceFromDeleteAction(obj interface{ … }

// isNodeReady returns true if a node is ready; false otherwise.
func isNodeReady(node *v1.Node) bool { … }