eks

Documentation

Index

• Variables
• func NodegroupRolePolicies() []string
• type NodegroupService
  • func NewNodegroupService(machinePoolScope *scope.ManagedMachinePoolScope) *NodegroupService
  • func (s *NodegroupService) ReconcilePool() error
  • func (s *NodegroupService) ReconcilePoolDelete() error
• type Service
  • func NewService(controlPlaneScope *scope.ManagedControlPlaneScope) *Service
  • func (s *Service) DeleteControlPlane() (err error)
  • func (s *Service) ReconcileControlPlane(ctx context.Context) error

Variables

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")
	// 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 NodegroupRolePolicies

func NodegroupRolePolicies() []string

NodegroupRolePolicies gives the policies required for a nodegroup role

Types

type NodegroupService

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

func NewNodegroupService(machinePoolScope *scope.ManagedMachinePoolScope) *NodegroupService

NewNodegroupService returns a new service given the api clients.

func (*NodegroupService) ReconcilePool

func (s *NodegroupService) ReconcilePool() error

ReconcilePool is the entrypoint for ManagedMachinePool reconciliation

func (*NodegroupService) ReconcilePoolDelete

func (s *NodegroupService) ReconcilePoolDelete() error

ReconcilePoolDelete is the entrypoint for ManagedMachinePool deletion reconciliation

type Service

type Service struct {
	EC2Client ec2iface.EC2API
	EKSClient eksiface.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