cluster

Documentation

Overview

Package cluster implements EKS cluster tester.

Index

• Constants
• type Config
• type Tester
  • func New(cfg Config) Tester

Constants

const (
	ClusterCreateTimeout = time.Hour
	ClusterDeleteTimeout = time.Hour
)

const TemplateCluster = `` /* 1608-byte string literal not displayed */

TemplateCluster is the CloudFormation template for EKS cluster.

const TemplateClusterRole = `` /* 6849-byte string literal not displayed */

TemplateClusterRole is the CloudFormation template for EKS cluster role.

ref. https://amazon-eks.s3.us-west-2.amazonaws.com/cloudformation/2019-09-17/amazon-eks-service-role.yaml

e.g.

Error creating load balancer (will retry): failed to ensure load balancer for service eks-*/hello-world-service: Error creating load balancer: "AccessDenied: User: arn:aws:sts::404174646922:assumed-role/eks-*-cluster-role/* is not authorized to perform: ec2:DescribeAccountAttributes\n\tstatus code: 403"

TODO: scope down (e.g. ec2:DescribeAccountAttributes, ec2:DescribeInternetGateways) mng, fargate, etc. may use other roles

const TemplateVPCPublicPrivate = `` /* 13008-byte string literal not displayed */

TemplateVPCPublicPrivate is the CloudFormation template for EKS VPC.

ref. https://amazon-eks.s3.us-west-2.amazonaws.com/cloudformation/2020-03-23/amazon-eks-vpc-private-subnets.yaml

e.g. An error occurred (InvalidParameterException) when calling the CreateFargateProfile operation: Subnet subnet-123 provided in Fargate Profile is not a private subnet

Types

type Config

type Config struct {
	Logger    *zap.Logger
	LogWriter io.Writer
	Stopc     chan struct{}
	EKSConfig *eksconfig.Config
	S3API     s3iface.S3API
	IAMAPI    iamiface.IAMAPI
	KMSAPI    kmsiface.KMSAPI
	CFNAPI    cloudformationiface.CloudFormationAPI
	EC2API    ec2iface.EC2API
	EKSAPI    eksiface.EKSAPI
	ELBV2API  elbv2iface.ELBV2API
}

Config defines version upgrade configuration.

type Tester

type Tester interface {
	// Name returns the name of the tester.
	Name() string
	// Create creates EKS cluster, and waits for completion.
	Create() error
	Client() k8s_client.EKS
	// CheckHealth checks EKS cluster health.
	CheckHealth() error
	// Delete deletes all EKS cluster resources.
	Delete() error
}

func New

func New(cfg Config) Tester

New creates a new Job tester.