instancegroups

Jun 12, 2024

Changes in this version

type ControllerConfig

+ EnableMultiSubnetCluster bool

+ ZoneGetter *zonegetter.ZoneGetter

May 6, 2024

Changes in this version

type ManagerConfig

+ ZoneGetter *zonegetter.ZoneGetter

Feb 10, 2023

Changes in this version

+ type Controller struct

+ func NewController(config *ControllerConfig) *Controller

+ func (c *Controller) Run()

+ func (c *Controller) Shutdown()

+ type ControllerConfig struct

+ HasSynced func() bool

+ IGManager Manager

+ NodeInformer cache.SharedIndexInformer

+ StopCh chan struct{}

+ type FakeInstanceGroups struct

+ func NewEmptyFakeInstanceGroups() *FakeInstanceGroups

+ func NewFakeInstanceGroups(zonesToIGsToInstances map[string]IGsToInstances, maxIGSize int) *FakeInstanceGroups

+ func (f *FakeInstanceGroups) AddInstancesToInstanceGroup(name, zone string, instanceRefs []*compute.InstanceReference) error

+ func (f *FakeInstanceGroups) CreateInstanceGroup(ig *compute.InstanceGroup, zone string) error

+ func (f *FakeInstanceGroups) DeleteInstanceGroup(name, zone string) error

+ func (f *FakeInstanceGroups) GetInstanceGroup(name, zone string) (*compute.InstanceGroup, error)

+ func (f *FakeInstanceGroups) ListInstanceGroups(zone string) ([]*compute.InstanceGroup, error)

+ func (f *FakeInstanceGroups) ListInstancesInInstanceGroup(name, zone string, state string) ([]*compute.InstanceWithNamedPorts, error)

+ func (f *FakeInstanceGroups) RemoveInstancesFromInstanceGroup(name, zone string, instanceRefs []*compute.InstanceReference) error

+ func (f *FakeInstanceGroups) SetNamedPortsOfInstanceGroup(igName, zone string, namedPorts []*compute.NamedPort) error

+ func (f *FakeInstanceGroups) ToInstanceReferences(zone string, instanceNames []string) (refs []*compute.InstanceReference)

+ type FakeZoneLister struct

+ Zones []string

+ func (z *FakeZoneLister) GetZoneForNode(name string) (string, error)

+ func (z *FakeZoneLister) ListZones(_ utils.NodeConditionPredicate) ([]string, error)

+ type IGsToInstances map[*compute.InstanceGroup]sets.String

+ type Manager interface

+ DeleteInstanceGroup func(name string) error

+ EnsureInstanceGroupsAndPorts func(name string, ports []int64) ([]*compute.InstanceGroup, error)

+ Get func(name, zone string) (*compute.InstanceGroup, error)

+ List func() ([]string, error)

+ Sync func(nodeNames []string) error

+ func NewManager(config *ManagerConfig) Manager

+ type ManagerConfig struct

+ BasePath string

+ Cloud Provider

+ MaxIGSize int

+ Namer namer.BackendNamer

+ Recorders recorderSource

+ ZoneLister ZoneLister

+ type Provider interface

+ AddInstancesToInstanceGroup func(name, zone string, instanceRefs []*compute.InstanceReference) error

+ CreateInstanceGroup func(ig *compute.InstanceGroup, zone string) error

+ DeleteInstanceGroup func(name, zone string) error

+ GetInstanceGroup func(name, zone string) (*compute.InstanceGroup, error)

+ ListInstanceGroups func(zone string) ([]*compute.InstanceGroup, error)

+ ListInstancesInInstanceGroup func(name, zone string, state string) ([]*compute.InstanceWithNamedPorts, error)

+ RemoveInstancesFromInstanceGroup func(name, zone string, instanceRefs []*compute.InstanceReference) error

+ SetNamedPortsOfInstanceGroup func(igName, zone string, namedPorts []*compute.NamedPort) error

+ ToInstanceReferences func(zone string, instanceNames []string) (refs []*compute.InstanceReference)

+ type ZoneLister interface

+ GetZoneForNode func(name string) (string, error)

+ ListZones func(predicate utils.NodeConditionPredicate) ([]string, error)