eks

Documentation

Overview

Package eks implements EKS cluster operations.

Index

• Constants
• func ClusterDeleted(err error) bool
• func Poll(ctx context.Context, stopc chan struct{}, lg *zap.Logger, ...) <-chan ClusterStatus
• type ClusterStatus
• type Tester
  • func New(cfg *eksconfig.Config) (*Tester, error)
  • func (ts *Tester) Build() error
  • func (ts *Tester) Down() error
  • func (ts *Tester) DownloadClusterLogs(artifactDir, _ string) error
  • func (ts *Tester) DumpClusterLogs() error
  • func (ts *Tester) IsUp() (up bool, err error)
  • func (ts *Tester) Kubeconfig() (string, error)
  • func (ts *Tester) KubernetesClientSet() *kubernetes.Clientset
  • func (ts *Tester) LoadConfig() (eksconfig.Config, error)
  • func (ts *Tester) Provider() string
  • func (ts *Tester) Up() (err error)

Constants

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

TemplateClusterRole is the CloudFormation template for EKS cluster role.

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 TemplateEKSCluster = `` /* 1594-byte string literal not displayed */

TemplateEKSCluster is the CloudFormation template for EKS cluster.

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

TemplateVPCPublicPrivate is the CloudFormation template for EKS VPC.

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

Functions

func ClusterDeleted

func ClusterDeleted(err error) bool

ClusterDeleted 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,
	eksAPI eksiface.EKSAPI,
	clusterName string,
	desiredClusterStatus string,
	initialWait time.Duration,
	wait time.Duration,
) <-chan ClusterStatus

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

Types

type ClusterStatus

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

ClusterStatus represents the CloudFormation status.

type Tester

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

Tester implements "kubetest2" Deployer. ref. https://github.com/kubernetes/test-infra/blob/master/kubetest2/pkg/types/types.go

func New

func New(cfg *eksconfig.Config) (*Tester, error)

New creates a new EKS tester.

func (*Tester) Build

func (ts *Tester) Build() error

Build should build kubernetes and package it in whatever format the deployer consumes

func (*Tester) Down

func (ts *Tester) Down() error

Down cancels the cluster creation and destroy the test cluster if any.

func (*Tester) DownloadClusterLogs

func (ts *Tester) DownloadClusterLogs(artifactDir, _ string) error

DownloadClusterLogs dumps all logs to artifact directory. Let default kubetest log dumper handle all artifact uploads. See https://github.com/kubernetes/test-infra/pull/9811/files#r225776067.

func (*Tester) DumpClusterLogs

func (ts *Tester) DumpClusterLogs() error

DumpClusterLogs should export logs from the cluster. It may be called multiple times. Options for this should come from New(...)

func (*Tester) IsUp

func (ts *Tester) IsUp() (up bool, err error)

IsUp should return true if a test cluster is successfully provisioned

func (*Tester) Kubeconfig

func (ts *Tester) Kubeconfig() (string, error)

Kubeconfig returns a path to a kubeconfig file for the cluster.

func (*Tester) KubernetesClientSet

func (ts *Tester) KubernetesClientSet() *kubernetes.Clientset

KubernetesClientSet returns Kubernetes Go client.

func (*Tester) LoadConfig

func (ts *Tester) LoadConfig() (eksconfig.Config, error)

LoadConfig reloads configuration from disk to read the latest cluster configuration and its states. It's either reloaded from disk or returned from embedded EKS deployer.

func (*Tester) Provider

func (ts *Tester) Provider() string

Provider returns the kubernetes provider for legacy deployers.

func (*Tester) Up

func (ts *Tester) Up() (err error)

Up should provision a new cluster for testing