fargate

Documentation

Overview

Package fargate implements tester for Fargate.

Index

• Constants
• func IsProfileDeleted(err error) bool
• func Poll(ctx context.Context, stopc chan struct{}, lg *zap.Logger, ...) <-chan FargateProfileStatus
• type Config
• type FargateProfileStatus
• type Tester
  • func New(cfg Config) (Tester, error)

Constants

const FargateProfileStatusDELETEDORNOTEXIST = "DELETED/NOT-EXIST"

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

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

CREATING
ACTIVE
DELETING
CREATE_FAILED
DELETE_FAILED

const TemplateRole = `` /* 1055-byte string literal not displayed */

TemplateRole is the CloudFormation template for EKS Fargate role.

Functions

func IsProfileDeleted

func IsProfileDeleted(err error) bool

IsProfileDeleted returns true if error from EKS API indicates that the EKS fargate profile has already been deleted.

func Poll

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

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

Types

type Config

type Config struct {
	Logger    *zap.Logger
	Stopc     chan struct{}
	Sig       chan os.Signal
	EKSConfig *eksconfig.Config
	K8SClient k8sClientSetGetter
	CFNAPI    cloudformationiface.CloudFormationAPI
	EKSAPI    eksiface.EKSAPI
	IAMAPI    iamiface.IAMAPI
}

Config defines "Secrets" configuration. ref. https://aws.amazon.com/blogs/opensource/introducing-fine-grained-iam-roles-service-accounts/

type FargateProfileStatus

type FargateProfileStatus struct {
	FargateProfile *eks.FargateProfile
	Error          error
}

FargateProfileStatus represents the CloudFormation status.

type Tester

type Tester interface {
	// Create creates Fargate pods.
	Create() error
	// Delete deletes Fargate pods.
	Delete() error
}

Tester defines Fargate tester.

func New

func New(cfg Config) (Tester, error)

New creates a new Job tester.