nodegroup

Documentation

Index

• type CreateOpts
• type Manager
  • func New(cfg *api.ClusterConfig, ctl *eks.ClusterProvider, ...) *Manager
  • func (m *Manager) Create(options CreateOpts, nodegroupFilter filter.NodeGroupFilter) error
  • func (m *Manager) Delete(nodeGroups []*api.NodeGroup, managedNodeGroups []*api.ManagedNodeGroup, ...) error
  • func (m *Manager) Drain(nodeGroups []eks.KubeNodeGroup, plan bool, maxGracePeriod time.Duration, ...) error
  • func (m *Manager) Get(name string) (*manager.NodeGroupSummary, error)
  • func (m *Manager) GetAll() ([]*manager.NodeGroupSummary, error)
  • func (m *Manager) Scale(ng *api.NodeGroup) error
  • func (m *Manager) Upgrade(options managed.UpgradeOptions) error
• type WaitFunc

Types

type CreateOpts

type CreateOpts struct {
	UpdateAuthConfigMap       bool
	InstallNeuronDevicePlugin bool
	InstallNvidiaDevicePlugin bool
	DryRun                    bool
	ConfigFileProvided        bool
}

Options controls specific steps of node group creation

type Manager

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

func New

func New(cfg *api.ClusterConfig, ctl *eks.ClusterProvider, clientSet *kubernetes.Clientset) *Manager

func (*Manager) Create

func (m *Manager) Create(options CreateOpts, nodegroupFilter filter.NodeGroupFilter) error

func (*Manager) Delete

func (m *Manager) Delete(nodeGroups []*api.NodeGroup, managedNodeGroups []*api.ManagedNodeGroup, wait, plan bool) error

func (*Manager) Drain

func (m *Manager) Drain(nodeGroups []eks.KubeNodeGroup, plan bool, maxGracePeriod time.Duration, disableEviction bool) error

func (*Manager) Get

func (m *Manager) Get(name string) (*manager.NodeGroupSummary, error)

func (*Manager) GetAll

func (m *Manager) GetAll() ([]*manager.NodeGroupSummary, error)

func (*Manager) Scale

func (m *Manager) Scale(ng *api.NodeGroup) error

func (*Manager) Upgrade

func (m *Manager) Upgrade(options managed.UpgradeOptions) error

type WaitFunc

type WaitFunc func(name, msg string, acceptors []request.WaiterAcceptor, newRequest func() *request.Request, waitTimeout time.Duration, troubleshoot func(string) error) error