package endpointslicemirroring
import "k8s.io/kubernetes/pkg/controller/endpointslicemirroring"
Index ¶
- Constants
- type Controller
- func NewController(endpointsInformer coreinformers.EndpointsInformer, endpointSliceInformer discoveryinformers.EndpointSliceInformer, serviceInformer coreinformers.ServiceInformer, maxEndpointsPerSubset int32, client clientset.Interface, endpointUpdatesBatchPeriod time.Duration, ) *Controller
- func (c *Controller) Run(workers int, stopCh <-chan struct{})
- type StaleInformerCache
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" )
Types ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
Controller manages selector-based service endpoint slices
func NewController ¶
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 ¶
func (c *Controller) Run(workers int, stopCh <-chan struct{})
Run will not return until stopCh is closed.
type StaleInformerCache ¶
type StaleInformerCache struct {
// contains filtered or unexported fields
}
StaleInformerCache errors indicate that the informer cache includes out of date resources.
func (*StaleInformerCache) Error ¶
func (e *StaleInformerCache) Error() string
Source Files ¶
endpointset.go endpointslice_tracker.go endpointslicemirroring_controller.go errors.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.19.12-rc.0
- Published
- May 12, 2021
- Platform
- js/wasm
- Imports
- 35 packages
- Last checked
- 5 seconds ago –
Tools for package owners.