versionupgrade

Documentation

Overview

Package versionupgrade implements EKS cluster version upgrade tester.

Index

• func New(cfg Config) eks_tester.Tester
• func Poll(ctx context.Context, stopc chan struct{}, lg *zap.Logger, ...) <-chan UpdateStatus
• type Config
• type UpdateStatus

Functions

func New

func New(cfg Config) eks_tester.Tester

New creates a new Job tester.

func Poll

func Poll(
	ctx context.Context,
	stopc chan struct{},
	lg *zap.Logger,
	eksAPI eksiface.EKSAPI,
	clusterName string,
	requestID string,
	desiredUpdateStatus string,
	initialWait time.Duration,
	wait time.Duration,
) <-chan UpdateStatus

Poll 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 Config

type Config struct {
	Logger    *zap.Logger
	Stopc     chan struct{}
	EKSConfig *eksconfig.Config
	K8SClient k8s_client.EKS
	EKSAPI    eksiface.EKSAPI
}

Config defines version upgrade configuration.

type UpdateStatus

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

UpdateStatus represents the CloudFormation status.