Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
Controller is network endpoint group controller. It determines whether NEG for a service port is needed, then signals NegSyncerManager to sync it.
func NewController ¶
func NewController( kubeClient kubernetes.Interface, svcNegClient svcnegclient.Interface, kubeSystemUID types.UID, ingressInformer cache.SharedIndexInformer, serviceInformer cache.SharedIndexInformer, podInformer cache.SharedIndexInformer, nodeInformer cache.SharedIndexInformer, endpointSliceInformer cache.SharedIndexInformer, svcNegInformer cache.SharedIndexInformer, networkInformer cache.SharedIndexInformer, gkeNetworkParamSetInformer cache.SharedIndexInformer, hasSynced func() bool, l4Namer namer2.L4ResourcesNamer, defaultBackendService utils.ServicePort, cloud negtypes.NetworkEndpointGroupCloud, zoneGetter *zonegetter.ZoneGetter, namer negtypes.NetworkEndpointGroupNamer, resyncPeriod time.Duration, gcPeriod time.Duration, numGCWorkers int, enableReadinessReflector bool, runL4Controller bool, enableNonGcpMode bool, enableDualStackNEG bool, enableAsm bool, asmServiceNEGSkipNamespaces []string, lpConfig labels.PodLabelPropagationConfig, enableMultiNetworking bool, enableIngressRegionalExternal bool, stopCh <-chan struct{}, logger klog.Logger, ) *Controller
NewController returns a network endpoint group controller.
func (*Controller) IsHealthy ¶ added in v1.2.2
func (c *Controller) IsHealthy() error
func (*Controller) Run ¶
func (c *Controller) Run()
type NegSyncerType ¶ added in v1.5.0
type NegSyncerType string
NegSyncerType represents the neg syncer type
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.