neg

package

v1.1.1 Latest Latest Go to latest Published: Apr 16, 2018 License: Apache-2.0 Imports: 25 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/christianalexander/ingress-gce

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func NewFakeNetworkEndpointGroupCloud(subnetwork, network string) networkEndpointGroupCloud
func NewFakeZoneGetter() *fakeZoneGetter
type Controller
- func NewController(kubeClient kubernetes.Interface, cloud networkEndpointGroupCloud, ...) (*Controller, error)
- func (c *Controller) Run(stopCh <-chan struct{})
type ErrorList
- func (e *ErrorList) Add(err error)
- func (e *ErrorList) List() []error
type FakeNetworkEndpointGroupCloud

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

Source Files ¶

View all Source files

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