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,
	destinationRuleClient dynamic.NamespaceableResourceInterface,
	kubeSystemUID types.UID,
	ingressInformer cache.SharedIndexInformer,
	serviceInformer cache.SharedIndexInformer,
	podInformer cache.SharedIndexInformer,
	nodeInformer cache.SharedIndexInformer,
	endpointInformer cache.SharedIndexInformer,
	endpointSliceInformer cache.SharedIndexInformer,
	destinationRuleInformer cache.SharedIndexInformer,
	svcNegInformer cache.SharedIndexInformer,
	hasSynced func() bool,
	controllerMetrics *usage.ControllerMetrics,
	l4Namer namer2.L4ResourcesNamer,
	defaultBackendService utils.ServicePort,
	cloud negtypes.NetworkEndpointGroupCloud,
	zoneGetter negtypes.ZoneGetter,
	namer negtypes.NetworkEndpointGroupNamer,
	resyncPeriod time.Duration,
	gcPeriod time.Duration,
	enableReadinessReflector bool,
	runIngress bool,
	runL4Controller bool,
	enableNonGcpMode bool,
	enableAsm bool,
	asmServiceNEGSkipNamespaces []string,
	enableEndpointSlices bool,
	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 the neg syncer type