eks

package
v1.5.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 5, 2023 License: Apache-2.0 Imports: 57 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	// ErrClusterExists is an error if a EKS cluster already exists with
	// the same name in the spec but that isn't owned by the CAPI cluster.
	ErrClusterExists = errors.New("an EKS cluster already exists with same name but isn't owned by cluster")
	// ErrUnknownTokenMethod defines an error if a unsupported token generation method is supplied.
	ErrUnknownTokenMethod = errors.New("unknown token method")
	// ErrClusterRoleNameMissing if no role name is specified.
	ErrClusterRoleNameMissing = errors.New("a cluster role name must be specified")
	// ErrClusterRoleNotFound is an error if the specified role couldn't be founbd in AWS.
	ErrClusterRoleNotFound = errors.New("the specified cluster role couldn't be found")
	// ErrNodegroupRoleNotFound is an error if the specified role couldn't be founbd in AWS.
	ErrNodegroupRoleNotFound = errors.New("the specified nodegroup role couldn't be found")
	// ErrFargateRoleNotFound is an error if the specified role couldn't be founbd in AWS.
	ErrFargateRoleNotFound = errors.New("the specified fargate role couldn't be found")
	// ErrCannotUseAdditionalRoles is an error if the spec contains additional role and the
	// EKSAllowAddRoles feature flag isn't enabled.
	ErrCannotUseAdditionalRoles = errors.New("additional rules cannot be added as this has been disabled")
	// ErrNoSecurityGroup is an error when no security group is found for an EKS cluster.
	ErrNoSecurityGroup = errors.New("no security group for EKS cluster")
)

Functions

func FargateRolePolicies added in v0.6.5

func FargateRolePolicies() []string

FargateRolePolicies gives the policies required for a fargate role.

func NodegroupRolePolicies added in v0.6.1

func NodegroupRolePolicies() []string

NodegroupRolePolicies gives the policies required for a nodegroup role.

Types

type EKSAPI added in v0.6.5

type EKSAPI interface {
	eksiface.EKSAPI
	WaitUntilClusterUpdating(input *eks.DescribeClusterInput, opts ...request.WaiterOption) error
}

EKSAPI defines the EKS API interface.

type EKSClient added in v0.6.5

type EKSClient struct {
	eksiface.EKSAPI
}

EKSClient defines a wrapper over EKS API.

func (EKSClient) WaitUntilClusterUpdating added in v0.6.5

func (c EKSClient) WaitUntilClusterUpdating(input *eks.DescribeClusterInput, opts ...request.WaiterOption) error

WaitUntilClusterUpdating is adapted from aws-sdk-go/service/eks/waiters.go.

type FargateService added in v0.6.5

type FargateService struct {
	EKSClient eksiface.EKSAPI
	iam.IAMService
	STSClient stsiface.STSAPI
	// contains filtered or unexported fields
}

FargateService holds a collection of interfaces. The interfaces are broken down like this to group functions together.

func NewFargateService added in v0.6.5

func NewFargateService(fargatePoolScope *scope.FargateProfileScope) *FargateService

NewFargateService returns a new service given the api clients.

func (*FargateService) Reconcile added in v0.6.5

func (s *FargateService) Reconcile() (reconcile.Result, error)

Reconcile is the entrypoint for FargateProfile reconciliation.

func (*FargateService) ReconcileDelete added in v0.6.5

func (s *FargateService) ReconcileDelete() (reconcile.Result, error)

ReconcileDelete is the entrypoint for FargateProfile reconciliation.

type NodegroupService added in v0.6.1

type NodegroupService struct {
	AutoscalingClient autoscalingiface.AutoScalingAPI
	EKSClient         eksiface.EKSAPI
	iam.IAMService
	STSClient stsiface.STSAPI
	// contains filtered or unexported fields
}

NodegroupService holds a collection of interfaces. The interfaces are broken down like this to group functions together. One alternative is to have a large list of functions from the ec2 client.

func NewNodegroupService added in v0.6.1

func NewNodegroupService(machinePoolScope *scope.ManagedMachinePoolScope) *NodegroupService

NewNodegroupService returns a new service given the api clients.

func (*NodegroupService) ReconcilePool added in v0.6.1

func (s *NodegroupService) ReconcilePool() error

ReconcilePool is the entrypoint for ManagedMachinePool reconciliation.

func (*NodegroupService) ReconcilePoolDelete added in v0.6.1

func (s *NodegroupService) ReconcilePoolDelete() error

ReconcilePoolDelete is the entrypoint for ManagedMachinePool deletion reconciliation.

type Service

type Service struct {
	EC2Client ec2iface.EC2API
	EKSClient EKSAPI
	iam.IAMService
	STSClient stsiface.STSAPI
	// contains filtered or unexported fields
}

Service holds a collection of interfaces. The interfaces are broken down like this to group functions together. One alternative is to have a large list of functions from the ec2 client.

func NewService

func NewService(controlPlaneScope *scope.ManagedControlPlaneScope) *Service

NewService returns a new service given the api clients.

func (*Service) DeleteControlPlane

func (s *Service) DeleteControlPlane() (err error)

DeleteControlPlane deletes the EKS control plane.

func (*Service) ReconcileControlPlane

func (s *Service) ReconcileControlPlane(ctx context.Context) error

ReconcileControlPlane reconciles a EKS control plane.

Directories

Path Synopsis
Package mock_eksiface is a generated GoMock package.
Package mock_eksiface is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL