neg

package
v0.9.8-alpha.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 12, 2018 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source
const (
	TestZone1     = "zone1"
	TestZone2     = "zone2"
	TestInstance1 = "instance1"
	TestInstance2 = "instance2"
	TestInstance3 = "instance3"
	TestInstance4 = "instance4"
)
View Source
const (
	MAX_NETWORK_ENDPOINTS_PER_BATCH = 500
)

Variables

View Source
var NotFoundError = fmt.Errorf("Not Found")

Functions

func NewFakeNetworkEndpointGroupCloud

func NewFakeNetworkEndpointGroupCloud(subnetwork, network string) networkEndpointGroupCloud

func NewFakeZoneGetter

func NewFakeZoneGetter() *fakeZoneGetter

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,
	cloud networkEndpointGroupCloud,
	ctx *context.ControllerContext,
	zoneGetter zoneGetter,
	namer networkEndpointGroupNamer,
	resyncPeriod time.Duration,
) (*Controller, error)

NewController returns a network endpoint group controller.

func (*Controller) Run

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

type ErrorList

type ErrorList struct {
	// contains filtered or unexported fields
}

func (*ErrorList) Add

func (e *ErrorList) Add(err error)

func (*ErrorList) List

func (e *ErrorList) List() []error

type FakeNetworkEndpointGroupCloud

type FakeNetworkEndpointGroupCloud struct {
	NetworkEndpointGroups map[string][]*computealpha.NetworkEndpointGroup
	NetworkEndpoints      map[string][]*computealpha.NetworkEndpoint
	Subnetwork            string
	Network               string
	// contains filtered or unexported fields
}

func (*FakeNetworkEndpointGroupCloud) AggregatedListNetworkEndpointGroup

func (cloud *FakeNetworkEndpointGroupCloud) AggregatedListNetworkEndpointGroup() (map[string][]*computealpha.NetworkEndpointGroup, error)

func (*FakeNetworkEndpointGroupCloud) AttachNetworkEndpoints

func (cloud *FakeNetworkEndpointGroupCloud) AttachNetworkEndpoints(name, zone string, endpoints []*computealpha.NetworkEndpoint) error

func (*FakeNetworkEndpointGroupCloud) CreateNetworkEndpointGroup

func (cloud *FakeNetworkEndpointGroupCloud) CreateNetworkEndpointGroup(neg *computealpha.NetworkEndpointGroup, zone string) error

func (*FakeNetworkEndpointGroupCloud) DeleteNetworkEndpointGroup

func (cloud *FakeNetworkEndpointGroupCloud) DeleteNetworkEndpointGroup(name string, zone string) error

func (*FakeNetworkEndpointGroupCloud) DetachNetworkEndpoints

func (cloud *FakeNetworkEndpointGroupCloud) DetachNetworkEndpoints(name, zone string, endpoints []*computealpha.NetworkEndpoint) error

func (*FakeNetworkEndpointGroupCloud) GetNetworkEndpointGroup

func (cloud *FakeNetworkEndpointGroupCloud) GetNetworkEndpointGroup(name string, zone string) (*computealpha.NetworkEndpointGroup, error)

func (*FakeNetworkEndpointGroupCloud) ListNetworkEndpointGroup

func (cloud *FakeNetworkEndpointGroupCloud) ListNetworkEndpointGroup(zone string) ([]*computealpha.NetworkEndpointGroup, error)

func (*FakeNetworkEndpointGroupCloud) ListNetworkEndpoints

func (cloud *FakeNetworkEndpointGroupCloud) ListNetworkEndpoints(name, zone string, showHealthStatus bool) ([]*computealpha.NetworkEndpointWithHealthStatus, error)

func (*FakeNetworkEndpointGroupCloud) NetworkURL

func (cloud *FakeNetworkEndpointGroupCloud) NetworkURL() string

func (*FakeNetworkEndpointGroupCloud) SubnetworkURL

func (cloud *FakeNetworkEndpointGroupCloud) SubnetworkURL() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL