neg

Documentation

Index

• type Controller
  • func NewController(kubeClient kubernetes.Interface, svcNegClient svcnegclient.Interface, ...) *Controller
  • func (c *Controller) IsHealthy() error
  • func (c *Controller) Run(stopCh <-chan struct{})
• type NegSyncerType

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,
	hasSynced func() bool,
	controllerMetrics *usageMetrics.ControllerMetrics,
	l4Namer namer2.L4ResourcesNamer,
	defaultBackendService utils.ServicePort,
	cloud negtypes.NetworkEndpointGroupCloud,
	zoneGetter negtypes.ZoneGetter,
	namer negtypes.NetworkEndpointGroupNamer,
	resyncPeriod time.Duration,
	gcPeriod time.Duration,
	numGCWorkers int,
	enableReadinessReflector bool,
	runIngress bool,
	runL4Controller bool,
	enableNonGcpMode bool,
	enableDualStackNEG bool,
	enableAsm bool,
	asmServiceNEGSkipNamespaces []string,
	lpConfig labels.PodLabelPropagationConfig,
	logger klog.Logger,
) *Controller

NewController returns a network endpoint group controller.

func (*Controller) IsHealthy

func (c *Controller) IsHealthy() error

func (*Controller) Run

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

type NegSyncerType

type NegSyncerType string

NegSyncerType represents the neg syncer type