wait_v2

Documentation

Overview

Package wait_v2 implements cluster waiter.

Index

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

Functions

func IsDeleted

func IsDeleted(err error) bool

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

func Poll

func Poll(
	ctx context.Context,
	stopc chan struct{},
	lg *zap.Logger,
	logWriter io.Writer,
	eksAPIV2 *aws_eks_v2.Client,
	clusterName string,
	desiredClusterStatus string,
	initialWait time.Duration,
	pollInterval time.Duration,
	opts ...OpOption) <-chan ClusterStatus

Poll periodically fetches the cluster status until the cluster becomes the desired state.

func PollUpdate

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

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

Types

type ClusterStatus

type ClusterStatus struct {
	Cluster *aws_eks_v2_types.Cluster
	Error   error
}

ClusterStatus represents the EKS cluster status.

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 *aws_eks_v2_types.Update
	Error  error
}

UpdateStatus represents the CloudFormation status.