neg

Documentation

Index

• func GetNegStatus(zones []string, portToNegs types.PortNameMap) types.NegStatus
• func NEGServicePorts(ann *annotations.NegAnnotation, knownPorts types.PortNameMap) (types.PortNameMap, error)
• func NewAdapter(g *gce.GCECloud) negtypes.NetworkEndpointGroupCloud
• type Controller
  • func NewController(cloud negtypes.NetworkEndpointGroupCloud, ctx *context.ControllerContext, ...) *Controller
  • func (c *Controller) IsHealthy() error
  • func (c *Controller) Run(stopCh <-chan struct{})

Functions

func GetNegStatus

func GetNegStatus(zones []string, portToNegs types.PortNameMap) types.NegStatus

GetNegStatus generates a NegStatus denoting the current NEGs associated with the given ports. NetworkEndpointGroups is a mapping between ServicePort and NEG name Zones is a list of zones where the NEGs exist.

func NEGServicePorts

func NEGServicePorts(ann *annotations.NegAnnotation, knownPorts types.PortNameMap) (types.PortNameMap, error)

NEGServicePorts returns the parsed ServicePorts from the annotation. knownPorts represents the known Port:TargetPort attributes of servicePorts that already exist on the service. This function returns an error if any of the parsed ServicePorts from the annotation is not in knownPorts.

func NewAdapter

func NewAdapter(g *gce.GCECloud) negtypes.NetworkEndpointGroupCloud

NewAdapter takes a GCECloud and returns a NetworkEndpointGroupCloud.

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(
	cloud negtypes.NetworkEndpointGroupCloud,
	ctx *context.ControllerContext,
	zoneGetter negtypes.ZoneGetter,
	namer negtypes.NetworkEndpointGroupNamer,
	resyncPeriod time.Duration,
	gcPeriod time.Duration) *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{})