wait

Documentation

Overview

Package wait implements node waiter.

Index

• Constants
• func IsDeleted(err error) bool
• func Poll(ctx context.Context, stopc chan struct{}, lg *zap.Logger, logWriter io.Writer, ...) <-chan ManagedNodeGroupStatus
• func PollUpdate(ctx context.Context, stopc chan struct{}, lg *zap.Logger, logWriter io.Writer, ...) <-chan UpdateStatus
• type Config
• type ManagedNodeGroupStatus
• type NodeWaiter
  • func New(cfg Config) NodeWaiter
• type Op
• type OpOption
  • func WithQueryFunc(f func()) OpOption
• type UpdateStatus

Constants

const ManagedNodeGroupStatusDELETEDORNOTEXIST = "DELETED/NOT-EXIST"

ManagedNodeGroupStatusDELETEDORNOTEXIST defines the cluster status when the cluster is not found.

ref. https://docs.aws.amazon.com/eks/latest/APIReference/API_Nodegroup.html

CREATING
ACTIVE
DELETING
FAILED
UPDATING

Functions

func IsDeleted

func IsDeleted(err error) bool

IsDeleted returns true if error from EKS API indicates that the EKS managed node group has already been deleted.

func Poll

func Poll(
	ctx context.Context,
	stopc chan struct{},
	lg *zap.Logger,
	logWriter io.Writer,
	eksAPI eksiface.EKSAPI,
	clusterName string,
	mngName string,
	desiredNodeGroupStatus string,
	initialWait time.Duration,
	pollInterval time.Duration,
	opts ...OpOption) <-chan ManagedNodeGroupStatus

Poll periodically fetches the managed node group status until the node group becomes the desired state.

func PollUpdate

func PollUpdate(
	ctx context.Context,
	stopc chan struct{},
	lg *zap.Logger,
	logWriter io.Writer,
	eksAPI eksiface.EKSAPI,
	clusterName string,
	mngName string,
	requestID string,
	desiredUpdateStatus string,
	initialWait time.Duration,
	pollInterval time.Duration,
	opts ...OpOption) <-chan UpdateStatus

PollUpdate periodically fetches the MNG update status until the MNG update becomes the desired state. ref. https://docs.aws.amazon.com/eks/latest/APIReference/API_DescribeUpdate.html

Types

type Config

type Config struct {
	Logger    *zap.Logger
	LogWriter io.Writer
	Stopc     chan struct{}
	EKSConfig *eksconfig.Config
	K8SClient k8s_client.EKS

	EC2APIV2 *aws_ec2_v2.Client
	ASGAPIV2 *aws_asg_v2.Client
	EKSAPI   eksiface.EKSAPI
}

Config defines version upgrade configuration.

type ManagedNodeGroupStatus

type ManagedNodeGroupStatus struct {
	NodeGroupName string
	NodeGroup     *aws_eks.Nodegroup
	Error         error
}

ManagedNodeGroupStatus represents the CloudFormation status.

type NodeWaiter

type NodeWaiter interface {
	// Wait waits until all MNG and Kubernetes nodes are ready.
	Wait(mngName string, retries int) error
}

NodeWaiter defines node waiter operation.

func New

func New(cfg Config) NodeWaiter

New creates a new node waiter.

type Op

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

Op represents a MNG operation.

type OpOption

type OpOption func(*Op)

OpOption configures archiver operations.

func WithQueryFunc

func WithQueryFunc(f func()) OpOption

WithQueryFunc configures query function to be called in retry func.

type UpdateStatus

type UpdateStatus struct {
	Update *eks.Update
	Error  error
}

UpdateStatus represents the CloudFormation status.