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

package endpointslicemirroring

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


Package Files

endpointset.go endpointslice_tracker.go endpointslicemirroring_controller.go events.go reconciler.go reconciler_helpers.go utils.go


const (
    // FailedToListEndpointSlices indicates the controller has failed to list
    // EndpointSlices.
    FailedToListEndpointSlices = "FailedToListEndpointSlices"
    // FailedToUpdateEndpointSlices indicates the controller has failed to
    // update EndpointSlices.
    FailedToUpdateEndpointSlices = "FailedToUpdateEndpointSlices"
    // InvalidIPAddress indicates that an IP address found in an Endpoints
    // resource is invalid.
    InvalidIPAddress = "InvalidIPAddress"
    // TooManyAddressesToMirror indicates that some addresses were not mirrored
    // due to an EndpointSubset containing more addresses to mirror than
    // MaxEndpointsPerSubset allows.
    TooManyAddressesToMirror = "TooManyAddressesToMirror"

type Controller Uses

type Controller struct {
    // contains filtered or unexported fields

Controller manages selector-based service endpoint slices

func NewController Uses

func NewController(endpointsInformer coreinformers.EndpointsInformer,
    endpointSliceInformer discoveryinformers.EndpointSliceInformer,
    serviceInformer coreinformers.ServiceInformer,
    maxEndpointsPerSubset int32,
    client clientset.Interface,
    endpointUpdatesBatchPeriod time.Duration,
) *Controller

NewController creates and initializes a new Controller

func (*Controller) Run Uses

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

Run will not return until stopCh is closed.



Package endpointslicemirroring imports 35 packages (graph) and is imported by 2 packages. Updated 2020-09-25. Refresh now. Tools for package owners.