eks

Documentation

Overview

Package eks implements EKS cluster operations.

Index

• Constants
• func ClusterDeleted(err error) bool
• func ManangedNodeGroupDelete(err error) bool
• func PollEKS(ctx context.Context, stopc chan struct{}, lg *zap.Logger, ...) <-chan ClusterStatus
• func PollEKSManagedNodeGroup(ctx context.Context, stopc chan struct{}, lg *zap.Logger, ...) <-chan ManagedNodeGroupStatus
• type ClusterStatus
• type ManagedNodeGroupStatus
• 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) FetchLogsManagedNodeGroup() (err error)
  • func (ts *Tester) IsUp() (up bool, err error)
  • func (ts *Tester) Kubeconfig() (string, error)
  • func (ts *Tester) KubectlCommand() (*osexec.Cmd, 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 (
	ClusterStatusCREATING          = "CREATING"
	ClusterStatusACTIVE            = "ACTIVE"
	ClusterStatusUPDATING          = "UPDATING"
	ClusterStatusDELETING          = "DELETING"
	ClusterStatusFAILED            = "FAILED"
	ClusterStatusDELETEDORNOTEXIST = "DELETED/NOT-EXIST"
)

https://docs.aws.amazon.com/eks/latest/APIReference/API_Cluster.html#AmazonEKS-Type-Cluster-status

CREATING
ACTIVE
UPDATING
DELETING
FAILED

const (
	ManagedNodeGroupStatusCREATING          = "CREATING"
	ManagedNodeGroupStatusACTIVE            = "ACTIVE"
	ManagedNodeGroupStatusUPDATING          = "UPDATING"
	ManagedNodeGroupStatusDELETING          = "DELETING"
	ManagedNodeGroupStatusCREATEFAILED      = "CREATE_FAILED"
	ManagedNodeGroupStatusUPDATEFAILED      = "UPDATE_FAILED"
	ManagedNodeGroupStatusDELETEFAILED      = "DELETE_FAILED"
	ManagedNodeGroupStatusDEGRADED          = "DEGRADED"
	ManagedNodeGroupStatusDELETEDORNOTEXIST = "DELETED/NOT-EXIST"
)

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

CREATING
ACTIVE
DELETING
FAILED
UPDATING

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

TemplateCluster is the CloudFormation template for EKS cluster.

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

TemplateClusterRole is the CloudFormation template for EKS cluster role.

const TemplateManagedNodeGroup = `` /* 2414-byte string literal not displayed */

TemplateManagedNodeGroup is the CloudFormation template for EKS managed node group. https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-eks-nodegroup.html

const TemplateManagedNodeGroupRole = `` /* 1256-byte string literal not displayed */

TemplateManagedNodeGroupRole is the CloudFormation template for EKS managed node group role. https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-eks-nodegroup.html

const TemplateVPC = `` /* 5892-byte string literal not displayed */

TemplateVPC 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 ManangedNodeGroupDelete

func ManangedNodeGroupDelete(err error) bool

ManangedNodeGroupDelete returns true if error from EKS API indicates that the EKS managed node group has already been deleted.

func PollEKS

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

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

func PollEKSManagedNodeGroup

func PollEKSManagedNodeGroup(
	ctx context.Context,
	stopc chan struct{},
	lg *zap.Logger,
	eksAPI eksiface.EKSAPI,
	clusterName string,
	nodeGroupName string,
	desiredNodeGroupStatus string,
	initialWait time.Duration,
	wait time.Duration,
) <-chan ManagedNodeGroupStatus

PollEKSManagedNodeGroup periodically fetches the managed node group status until the node group becomes the desired state.

Types

type ClusterStatus

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

ClusterStatus represents the CloudFormation status.

type ManagedNodeGroupStatus

type ManagedNodeGroupStatus struct {
	NodeGroup *awseks.Nodegroup
	Error     error
}

ManagedNodeGroupStatus 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) FetchLogsManagedNodeGroup

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

FetchLogsManagedNodeGroup downloads logs from managed node group instances.

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

func (ts *Tester) KubectlCommand() (*osexec.Cmd, error)

KubectlCommand returns "kubectl" command object for API reachability tests.

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