kubernetes: k8s.io/kubernetes/pkg/controller/endpoint Index | Files | Directories

package endpoint

import "k8s.io/kubernetes/pkg/controller/endpoint"

Package endpoint provides EndpointController implementation to manage and sync service endpoints.


Package Files

doc.go endpoints_controller.go


const (

    // TolerateUnreadyEndpointsAnnotation is an annotation on the Service denoting if the endpoints
    // controller should go ahead and create endpoints for unready pods. This annotation is
    // currently only used by StatefulSets, where we need the pod to be DNS
    // resolvable during initialization and termination. In this situation we
    // create a headless Service just for the StatefulSet, and clients shouldn't
    // be using this Service for anything so unready endpoints don't matter.
    // Endpoints of these Services retain their DNS records and continue
    // receiving traffic for the Service from the moment the kubelet starts all
    // containers in the pod and marks it "Running", till the kubelet stops all
    // containers and deletes the pod from the apiserver.
    // This field is deprecated. v1.Service.PublishNotReadyAddresses will replace it
    // subsequent releases.  It will be removed no sooner than 1.13.
    TolerateUnreadyEndpointsAnnotation = "service.alpha.kubernetes.io/tolerate-unready-endpoints"

type Controller Uses

type Controller struct {
    // contains filtered or unexported fields

Controller manages selector-based service endpoints.

func NewEndpointController Uses

func NewEndpointController(podInformer coreinformers.PodInformer, serviceInformer coreinformers.ServiceInformer,
    endpointsInformer coreinformers.EndpointsInformer, client clientset.Interface, endpointUpdatesBatchPeriod time.Duration) *Controller

NewEndpointController returns a new *Controller.

func (*Controller) Run Uses

func (e *Controller) Run(workers int, stopCh <-chan struct{})

Run will not return until stopCh is closed. workers determines how many endpoints will be handled in parallel.



Package endpoint imports 32 packages (graph) and is imported by 360 packages. Updated 2020-11-12. Refresh now. Tools for package owners.