backends

Nov 1, 2018

Changes in this version

type Backends

+ func NewPool(cloud *gce.GCECloud, namer *utils.Namer, resyncWithCloud bool) *Backends

+ func (b *Backends) Create(sp utils.ServicePort, hcLink string) (*composite.BackendService, error)

+ func (b *Backends) GetLocalSnapshot() []string

+ func (b *Backends) Health(name string) string

+ func (b *Backends) Update(be *composite.BackendService) error

+ type GroupKey struct

+ Name string

+ Zone string

+ type Linker interface

+ Link func(sp utils.ServicePort, groups []GroupKey) error

+ func NewInstanceGroupLinker(instancePool instances.NodePool, backendPool Pool, namer *utils.Namer) Linker

+ func NewNEGLinker(backendPool Pool, negGetter NEGGetter, namer *utils.Namer) Linker

+ type Pool interface

+ Create func(sp utils.ServicePort, hcLink string) (*composite.BackendService, error)

+ Delete func(name string) error

+ Get func(name string, version meta.Version) (*composite.BackendService, error)

+ GetLocalSnapshot func() []string

+ Health func(name string) string

+ Update func(be *composite.BackendService) error

+ type Syncer interface

+ GC func(svcPorts []utils.ServicePort) error

+ Init func(p ProbeProvider)

+ Shutdown func() error

+ Status func(name string) string

+ Sync func(svcPorts []utils.ServicePort) error

+ func NewBackendSyncer(backendPool Pool, healthChecker healthchecks.HealthChecker, namer *utils.Namer, ...) Syncer

Apr 11, 2018

Changes in this version

+ type BackendService struct

+ Alpha *computealpha.BackendService

+ Ga *compute.BackendService

+ func (be *BackendService) GetDescription() string

+ func (be *BackendService) GetHealthCheckLink() string

+ func (be *BackendService) GetProtocol() string

type BackendServices

+ CreateAlphaGlobalBackendService func(bg *computealpha.BackendService) error

type FakeBackendServices

+ func (f *FakeBackendServices) CreateAlphaGlobalBackendService(be *computealpha.BackendService) error

Mar 16, 2018

Changes in this version

+ type BackendPool interface

+ Delete func(port int64) error

+ Ensure func(ports []ServicePort, igs []*compute.InstanceGroup) error

+ GC func(ports []ServicePort) error

+ Get func(port int64) (*compute.BackendService, error)

+ Init func(p ProbeProvider)

+ Link func(port ServicePort, zones []string) error

+ List func() ([]interface{}, error)

+ Shutdown func() error

+ Status func(name string) string

+ type BackendServices interface

+ CreateGlobalBackendService func(bg *compute.BackendService) error

+ DeleteGlobalBackendService func(name string) error

+ GetAlphaGlobalBackendService func(name string) (*computealpha.BackendService, error)

+ GetGlobalBackendService func(name string) (*compute.BackendService, error)

+ GetGlobalBackendServiceHealth func(name, instanceGroupLink string) (*compute.BackendServiceGroupHealth, error)

+ ListGlobalBackendServices func() ([]*compute.BackendService, error)

+ UpdateAlphaGlobalBackendService func(bg *computealpha.BackendService) error

+ UpdateGlobalBackendService func(bg *compute.BackendService) error

+ type Backends struct

+ func NewBackendPool(cloud BackendServices, negGetter NEGGetter, ...) *Backends

+ func (b *Backends) Delete(port int64) (err error)

+ func (b *Backends) Ensure(svcPorts []ServicePort, igs []*compute.InstanceGroup) error

+ func (b *Backends) GC(svcNodePorts []ServicePort) error

+ func (b *Backends) Get(port int64) (*compute.BackendService, error)

+ func (b *Backends) Init(pp ProbeProvider)

+ func (b *Backends) Link(port ServicePort, zones []string) error

+ func (b *Backends) List() ([]interface{}, error)

+ func (b *Backends) Shutdown() error

+ func (b *Backends) Status(name string) string

+ type BalancingMode string

+ const Connections

+ const Rate

+ const Utilization

+ type FakeBackendServices struct

+ func NewFakeBackendServices(ef func(op int, be *compute.BackendService) error) *FakeBackendServices

+ func (f *FakeBackendServices) CreateGlobalBackendService(be *compute.BackendService) error

+ func (f *FakeBackendServices) DeleteGlobalBackendService(name string) error

+ func (f *FakeBackendServices) GetAlphaGlobalBackendService(name string) (*computealpha.BackendService, error)

+ func (f *FakeBackendServices) GetGlobalBackendService(name string) (*compute.BackendService, error)

+ func (f *FakeBackendServices) GetGlobalBackendServiceHealth(name, instanceGroupLink string) (*compute.BackendServiceGroupHealth, error)

+ func (f *FakeBackendServices) ListGlobalBackendServices() ([]*compute.BackendService, error)

+ func (f *FakeBackendServices) UpdateAlphaGlobalBackendService(be *computealpha.BackendService) error

+ func (f *FakeBackendServices) UpdateGlobalBackendService(be *compute.BackendService) error

+ type FakeProbeProvider struct

+ func NewFakeProbeProvider(probes map[ServicePort]*api_v1.Probe) *FakeProbeProvider

+ func (pp *FakeProbeProvider) GetProbe(port ServicePort) (*api_v1.Probe, error)

+ type NEGGetter interface

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

+ type ProbeProvider interface

+ GetProbe func(sp ServicePort) (*api_v1.Probe, error)

+ type ServicePort struct

+ NEGEnabled bool

+ NodePort int64

+ Protocol annotations.AppProtocol

+ SvcName types.NamespacedName

+ SvcPort intstr.IntOrString

+ SvcTargetPort string

+ func (sp ServicePort) Description() string