eksmanaged

Documentation

Index

• Constants
• type DiscoveredState
  • func (d *DiscoveredState) GetCurrentState() string
  • func (d *DiscoveredState) GetSelfNodeGroup() *eks.Nodegroup
  • func (d *DiscoveredState) IsProvisioned() bool
  • func (d *DiscoveredState) SetCurrentState(state string)
  • func (d *DiscoveredState) SetProvisioned(provisioned bool)
  • func (d *DiscoveredState) SetSelfNodeGroup(ng *eks.Nodegroup)
• type EksManagedDefaultConfiguration
• type EksManagedInstanceGroupContext
  • func New(p provisioners.ProvisionerInput) *EksManagedInstanceGroupContext
  • func (ctx *EksManagedInstanceGroupContext) BootstrapNodes() error
  • func (ctx *EksManagedInstanceGroupContext) CloudDiscovery() error
  • func (ctx *EksManagedInstanceGroupContext) Create() error
  • func (ctx *EksManagedInstanceGroupContext) Delete() error
  • func (ctx *EksManagedInstanceGroupContext) GetDiscoveredState() *DiscoveredState
  • func (ctx *EksManagedInstanceGroupContext) GetInstanceGroup() *v1alpha1.InstanceGroup
  • func (ctx *EksManagedInstanceGroupContext) GetState() v1alpha1.ReconcileState
  • func (ctx *EksManagedInstanceGroupContext) IsReady() bool
  • func (ctx *EksManagedInstanceGroupContext) Locked() bool
  • func (ctx *EksManagedInstanceGroupContext) SetDiscoveredState(state *DiscoveredState)
  • func (ctx *EksManagedInstanceGroupContext) SetState(state v1alpha1.ReconcileState)
  • func (ctx *EksManagedInstanceGroupContext) StateDiscovery()
  • func (ctx *EksManagedInstanceGroupContext) Update() error
  • func (ctx *EksManagedInstanceGroupContext) UpgradeNodes() error

Constants

const (
	OngoingStateString             = "OngoingState"
	FiniteStateString              = "FiniteState"
	UnrecoverableErrorString       = "UnrecoverableError"
	UnrecoverableDeleteErrorString = "UnrecoverableDeleteError"
	ProvisionerName                = "eks-managed"
)

Types

type DiscoveredState

type DiscoveredState struct {
	Provisioned   bool
	SelfNodeGroup *eks.Nodegroup
	CurrentState  string
}

func (*DiscoveredState) GetCurrentState

func (d *DiscoveredState) GetCurrentState() string

func (*DiscoveredState) GetSelfNodeGroup

func (d *DiscoveredState) GetSelfNodeGroup() *eks.Nodegroup

func (*DiscoveredState) IsProvisioned

func (d *DiscoveredState) IsProvisioned() bool

func (*DiscoveredState) SetCurrentState

func (d *DiscoveredState) SetCurrentState(state string)

func (*DiscoveredState) SetProvisioned

func (d *DiscoveredState) SetProvisioned(provisioned bool)

func (*DiscoveredState) SetSelfNodeGroup

func (d *DiscoveredState) SetSelfNodeGroup(ng *eks.Nodegroup)

type EksManagedDefaultConfiguration

type EksManagedDefaultConfiguration struct {
	DefaultSubnets []string `yaml:"defaultSubnets,omitempty"`
	EksClusterName string   `yaml:"defaultClusterName,omitempty"`
}

type EksManagedInstanceGroupContext

type EksManagedInstanceGroupContext struct {
	InstanceGroup    *v1alpha1.InstanceGroup
	KubernetesClient kubeprovider.KubernetesClientSet
	AwsWorker        aws.AwsWorker
	DiscoveredState  *DiscoveredState
	Log              logr.Logger
}

func New

func New(p provisioners.ProvisionerInput) *EksManagedInstanceGroupContext

func (*EksManagedInstanceGroupContext) BootstrapNodes

func (ctx *EksManagedInstanceGroupContext) BootstrapNodes() error

func (*EksManagedInstanceGroupContext) CloudDiscovery

func (ctx *EksManagedInstanceGroupContext) CloudDiscovery() error

func (*EksManagedInstanceGroupContext) Create

func (ctx *EksManagedInstanceGroupContext) Create() error

func (*EksManagedInstanceGroupContext) Delete

func (ctx *EksManagedInstanceGroupContext) Delete() error

func (*EksManagedInstanceGroupContext) GetDiscoveredState

func (ctx *EksManagedInstanceGroupContext) GetDiscoveredState() *DiscoveredState

func (*EksManagedInstanceGroupContext) GetInstanceGroup

func (ctx *EksManagedInstanceGroupContext) GetInstanceGroup() *v1alpha1.InstanceGroup

func (*EksManagedInstanceGroupContext) GetState

func (ctx *EksManagedInstanceGroupContext) GetState() v1alpha1.ReconcileState

func (*EksManagedInstanceGroupContext) IsReady

func (ctx *EksManagedInstanceGroupContext) IsReady() bool

func (*EksManagedInstanceGroupContext) Locked

func (ctx *EksManagedInstanceGroupContext) Locked() bool

func (*EksManagedInstanceGroupContext) SetDiscoveredState

func (ctx *EksManagedInstanceGroupContext) SetDiscoveredState(state *DiscoveredState)

func (*EksManagedInstanceGroupContext) SetState

func (ctx *EksManagedInstanceGroupContext) SetState(state v1alpha1.ReconcileState)

func (*EksManagedInstanceGroupContext) StateDiscovery

func (ctx *EksManagedInstanceGroupContext) StateDiscovery()

func (*EksManagedInstanceGroupContext) Update

func (ctx *EksManagedInstanceGroupContext) Update() error

func (*EksManagedInstanceGroupContext) UpgradeNodes

func (ctx *EksManagedInstanceGroupContext) UpgradeNodes() error