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) CreateMNG() 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 TemplateCluster = `` /* 1278-byte string literal not displayed */

TemplateCluster is the CloudFormation template for EKS cluster.

const TemplateClusterRoleBasic = `` /* 1033-byte string literal not displayed */

TemplateClusterRoleBasic is the CloudFormation template for EKS cluster role.

const TemplateClusterRoleLB = `` /* 1281-byte string literal not displayed */

TemplateClusterRoleLB is the CloudFormation template for EKS cluster role with policies required for NLB service operation.

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)

const TemplateVPCPublic = `` /* 5984-byte string literal not displayed */

TemplateVPCPublic is the CloudFormation template for EKS VPC.

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

TemplateVPCPublicPrivate is the CloudFormation template for EKS VPC.

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) CreateMNG

func (ts *Tester) CreateMNG() error

CreateMNG creates/adds EKS "Managed Node Group"s. The existing node groups won't be recreated.

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