package endpointslicemirroring
import "k8s.io/kubernetes/pkg/controller/endpointslicemirroring"
Index ¶
- Constants
- type Controller
- func NewController(ctx context.Context, endpointsInformer coreinformers.EndpointsInformer, endpointSliceInformer discoveryinformers.EndpointSliceInformer, serviceInformer coreinformers.ServiceInformer, maxEndpointsPerSubset int32, client clientset.Interface, endpointUpdatesBatchPeriod time.Duration, ) *Controller
- func (c *Controller) Run(ctx context.Context, workers int)
Constants ¶
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" )
const ( // ControllerName is a unique value used with LabelManagedBy to indicated // the component managing an EndpointSlice. ControllerName = "endpointslicemirroring-controller.k8s.io" )
Types ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
Controller manages selector-based service endpoint slices
func NewController ¶
func NewController(ctx context.Context, 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 ¶
func (c *Controller) Run(ctx context.Context, workers int)
Run will not return until stopCh is closed.
Source Files ¶
endpointslicemirroring_controller.go events.go reconciler.go reconciler_helpers.go utils.go
Directories ¶
Path | Synopsis |
---|---|
pkg/controller/endpointslicemirroring/config | |
pkg/controller/endpointslicemirroring/config/v1alpha1 | |
pkg/controller/endpointslicemirroring/metrics |
- Version
- v1.33.0 (latest)
- Published
- Apr 23, 2025
- Platform
- linux/amd64
- Imports
- 34 packages
- Last checked
- 3 hours ago –
Tools for package owners.