package endpoint
import "k8s.io/kubernetes/pkg/controller/endpoint"
Package endpoint provides EndpointController implementation to manage and sync service endpoints.
Index ¶
- Constants
- type EndpointController
- func NewEndpointController(podInformer coreinformers.PodInformer, serviceInformer coreinformers.ServiceInformer, endpointsInformer coreinformers.EndpointsInformer, client clientset.Interface, endpointUpdatesBatchPeriod time.Duration) *EndpointController
- func (e *EndpointController) Run(workers int, stopCh <-chan struct{})
Constants ¶
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" )
Types ¶
type EndpointController ¶
type EndpointController struct {
// contains filtered or unexported fields
}
EndpointController manages selector-based service endpoints.
func NewEndpointController ¶
func NewEndpointController(podInformer coreinformers.PodInformer, serviceInformer coreinformers.ServiceInformer, endpointsInformer coreinformers.EndpointsInformer, client clientset.Interface, endpointUpdatesBatchPeriod time.Duration) *EndpointController
NewEndpointController returns a new *EndpointController.
func (*EndpointController) Run ¶
func (e *EndpointController) Run(workers int, stopCh <-chan struct{})
Run will not return until stopCh is closed. workers determines how many endpoints will be handled in parallel.
Source Files ¶
doc.go endpoints_controller.go
Directories ¶
Path | Synopsis |
---|---|
pkg/controller/endpoint/config | |
pkg/controller/endpoint/config/v1alpha1 |
- Version
- v1.19.0-beta.1
- Published
- Jun 4, 2020
- Platform
- js/wasm
- Imports
- 33 packages
- Last checked
- 1 minute ago –
Tools for package owners.