manager

Documentation

Index

• Constants
• func Run(passError func(error), tasks ...task)
• type Stack
• type StackCollection
  • func NewStackCollection(provider api.ClusterProvider, spec *api.ClusterConfig) *StackCollection
  • func (c *StackCollection) CreateCluster(errs chan error) error
  • func (s *StackCollection) CreateClusterWithInitialNodeGroup() []error
  • func (c *StackCollection) CreateInitialNodeGroup(errs chan error) error
  • func (c *StackCollection) CreateNodeGroup(seq int, errs chan error) error
  • func (c *StackCollection) CreateStack(name string, stack builder.ResourceSet, parameters map[string]string, ...) error
  • func (c *StackCollection) DeleteCluster() error
  • func (c *StackCollection) DeleteNodeGroup() error
  • func (c *StackCollection) DeleteStack(name string) (*Stack, error)
  • func (c *StackCollection) DeprecatedDeleteStackControlPlane() error
  • func (c *StackCollection) DeprecatedDeleteStackDefaultNodeGroup() error
  • func (c *StackCollection) DeprecatedDeleteStackServiceRole() error
  • func (c *StackCollection) DeprecatedDeleteStackVPC() error
  • func (c *StackCollection) DescribeStackEvents(i *Stack) ([]*cloudformation.StackEvent, error)
  • func (c *StackCollection) DescribeStacks(name string) ([]*Stack, error)
  • func (c *StackCollection) ListReadyStacks(nameRegex string) ([]*Stack, error)
  • func (c *StackCollection) ListStacks(nameRegex string, statusFilters ...string) ([]*Stack, error)
  • func (c *StackCollection) WaitDeleteNodeGroup() error
  • func (c *StackCollection) WaitDeleteStack(name string) error

Constants

const (
	ClusterNameTag = "eksctl.cluster.k8s.io/v1alpha1/cluster-name"
	NodeGroupTagID = "eksctl.cluster.k8s.io/v1alpha1/nodegroup-id"
)

Functions

func Run

func Run(passError func(error), tasks ...task)

Run a set of tests in parallel and wait for them to complete; passError should take any errors and do what it needs to in a given context, e.g. during serial CLI-driven execution one can keep errors in a slice, while in a daemon channel maybe more suitable

Types

type Stack

type Stack = cloudformation.Stack

type StackCollection

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

func NewStackCollection

func NewStackCollection(provider api.ClusterProvider, spec *api.ClusterConfig) *StackCollection

NewStackCollection create a stack manager for a single cluster

func (*StackCollection) CreateCluster

func (c *StackCollection) CreateCluster(errs chan error) error

func (*StackCollection) CreateClusterWithInitialNodeGroup

func (s *StackCollection) CreateClusterWithInitialNodeGroup() []error

CreateClusterWithInitialNodeGroup runs two tasks to create the stacks for use with CLI; any errors will be returned as a slice on completion of one of the two tasks

func (*StackCollection) CreateInitialNodeGroup

func (c *StackCollection) CreateInitialNodeGroup(errs chan error) error

func (*StackCollection) CreateNodeGroup

func (c *StackCollection) CreateNodeGroup(seq int, errs chan error) error

func (*StackCollection) CreateStack

func (c *StackCollection) CreateStack(name string, stack builder.ResourceSet, parameters map[string]string, errs chan error) error

CreateStack with given name, stack builder instance and parameters; any errors will be written to errs channel, when nil is written, assume completion, do not expect more then one error value on the channel, it's closed immediately after it is written two

func (*StackCollection) DeleteCluster

func (c *StackCollection) DeleteCluster() error

func (*StackCollection) DeleteNodeGroup

func (c *StackCollection) DeleteNodeGroup() error

func (*StackCollection) DeleteStack

func (c *StackCollection) DeleteStack(name string) (*Stack, error)

DeleteStack kills a stack by name without waiting for DELETED status

func (*StackCollection) DeprecatedDeleteStackControlPlane

func (c *StackCollection) DeprecatedDeleteStackControlPlane() error

func (*StackCollection) DeprecatedDeleteStackDefaultNodeGroup

func (c *StackCollection) DeprecatedDeleteStackDefaultNodeGroup() error

func (*StackCollection) DeprecatedDeleteStackServiceRole

func (c *StackCollection) DeprecatedDeleteStackServiceRole() error

func (*StackCollection) DeprecatedDeleteStackVPC

func (c *StackCollection) DeprecatedDeleteStackVPC() error

func (*StackCollection) DescribeStackEvents

func (c *StackCollection) DescribeStackEvents(i *Stack) ([]*cloudformation.StackEvent, error)

func (*StackCollection) DescribeStacks

func (c *StackCollection) DescribeStacks(name string) ([]*Stack, error)

func (*StackCollection) ListReadyStacks

func (c *StackCollection) ListReadyStacks(nameRegex string) ([]*Stack, error)

ListReadyStacks gets all of CloudFormation stacks with READY status

func (*StackCollection) ListStacks

func (c *StackCollection) ListStacks(nameRegex string, statusFilters ...string) ([]*Stack, error)

ListStacks gets all of CloudFormation stacks

func (*StackCollection) WaitDeleteNodeGroup

func (c *StackCollection) WaitDeleteNodeGroup() error

func (*StackCollection) WaitDeleteStack

func (c *StackCollection) WaitDeleteStack(name string) error

WaitDeleteStack kills a stack by name and waits for DELETED status