neg

Documentation

Index

• type Controller
  • func NewController(kubeClient kubernetes.Interface, svcNegClient svcnegclient.Interface, ...) *Controller
  • func (c *Controller) IsHealthy() error
  • func (c *Controller) Run()
• 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,
	eventRecorderClient kubernetes.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

func (c *Controller) IsHealthy() error

func (*Controller) Run

func (c *Controller) Run()

type NegSyncerType

type NegSyncerType string

NegSyncerType represents the neg syncer type