package endpoint
import "k8s.io/kubernetes/pkg/controller/endpoint"
Package endpoint provides EndpointController implementation to manage and sync service endpoints.
Index ¶
- Constants
- type Controller
- func NewEndpointController(podInformer coreinformers.PodInformer, serviceInformer coreinformers.ServiceInformer, endpointsInformer coreinformers.EndpointsInformer, client clientset.Interface, endpointUpdatesBatchPeriod time.Duration) *Controller
- func (e *Controller) Run(ctx context.Context, workers int)
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 Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
Controller manages selector-based service endpoints.
func NewEndpointController ¶
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 ¶
func (e *Controller) Run(ctx context.Context, workers int)
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.23.17
- Published
- Feb 22, 2023
- Platform
- js/wasm
- Imports
- 31 packages
- Last checked
- 43 seconds ago –
Tools for package owners.