eksfargate

Documentation

Index

• Constants
• func CreateFargateSelectors(selectors []v1alpha1.EKSFargateSelectors) []*eks.FargateProfileSelector
• func CreateFargateTags(tagArray []map[string]string) map[string]*string
• type DiscoveredState
  • func (ds *DiscoveredState) GetProfileStatus() string
  • func (ds *DiscoveredState) IsProvisioned() bool
• type FargateInstanceGroupContext
  • func New(p provisioners.ProvisionerInput) *FargateInstanceGroupContext
  • func (ctx *FargateInstanceGroupContext) BootstrapNodes() error
  • func (ctx *FargateInstanceGroupContext) CloudDiscovery() error
  • func (ctx *FargateInstanceGroupContext) Create() error
  • func (ctx *FargateInstanceGroupContext) Delete() error
  • func (ctx *FargateInstanceGroupContext) GetDiscoveredState() *DiscoveredState
  • func (ctx *FargateInstanceGroupContext) GetInstanceGroup() *v1alpha1.InstanceGroup
  • func (ctx *FargateInstanceGroupContext) GetState() v1alpha1.ReconcileState
  • func (ctx *FargateInstanceGroupContext) IsReady() bool
  • func (ctx *FargateInstanceGroupContext) Locked() bool
  • func (ctx *FargateInstanceGroupContext) SetState(state v1alpha1.ReconcileState)
  • func (ctx *FargateInstanceGroupContext) StateDiscovery()
  • func (ctx *FargateInstanceGroupContext) Update() error
  • func (ctx *FargateInstanceGroupContext) UpgradeNodes() error

Constants

const (
	PendingRolePolicyAttach = "pendingPolicyCreation"
	PendingRoleCreation     = "pendingRoleCreation"
)

const (
	OngoingStateString             = "OngoingState"
	FiniteStateString              = "FiniteState"
	FiniteDeletedString            = "FiniteDeleted"
	UpdateRecoverableErrorString   = "UpdateRecoverableError"
	UnrecoverableErrorString       = "UnrecoverableError"
	UnrecoverableDeleteErrorString = "UnrecoverableDeleteError"
)

const LastAppliedConfigurationKey = "kubectl.kubernetes.io/last-applied-configuration"

const ProvisionerName = "eks-fargate"

Functions

func CreateFargateSelectors

func CreateFargateSelectors(selectors []v1alpha1.EKSFargateSelectors) []*eks.FargateProfileSelector

func CreateFargateTags

func CreateFargateTags(tagArray []map[string]string) map[string]*string

Types

type DiscoveredState

type DiscoveredState struct {
	ProfileStatus string
}

func (*DiscoveredState) GetProfileStatus

func (ds *DiscoveredState) GetProfileStatus() string

func (*DiscoveredState) IsProvisioned

func (ds *DiscoveredState) IsProvisioned() bool

type FargateInstanceGroupContext

type FargateInstanceGroupContext struct {
	InstanceGroup   *v1alpha1.InstanceGroup
	AwsWorker       awsprovider.AwsWorker
	DiscoveredState DiscoveredState
	Log             logr.Logger
}

func New

func New(p provisioners.ProvisionerInput) *FargateInstanceGroupContext

func (*FargateInstanceGroupContext) BootstrapNodes

func (ctx *FargateInstanceGroupContext) BootstrapNodes() error

func (*FargateInstanceGroupContext) CloudDiscovery

func (ctx *FargateInstanceGroupContext) CloudDiscovery() error

func (*FargateInstanceGroupContext) Create

func (ctx *FargateInstanceGroupContext) Create() error

func (*FargateInstanceGroupContext) Delete

func (ctx *FargateInstanceGroupContext) Delete() error

func (*FargateInstanceGroupContext) GetDiscoveredState

func (ctx *FargateInstanceGroupContext) GetDiscoveredState() *DiscoveredState

func (*FargateInstanceGroupContext) GetInstanceGroup

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

func (*FargateInstanceGroupContext) GetState

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

func (*FargateInstanceGroupContext) IsReady

func (ctx *FargateInstanceGroupContext) IsReady() bool

func (*FargateInstanceGroupContext) Locked

func (ctx *FargateInstanceGroupContext) Locked() bool

func (*FargateInstanceGroupContext) SetState

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

func (*FargateInstanceGroupContext) StateDiscovery

func (ctx *FargateInstanceGroupContext) StateDiscovery()

func (*FargateInstanceGroupContext) Update

func (ctx *FargateInstanceGroupContext) Update() error

func (*FargateInstanceGroupContext) UpgradeNodes

func (ctx *FargateInstanceGroupContext) UpgradeNodes() error