controller

Documentation

Index

• func BuildUpstreamClusterState(ctx context.Context, name, managedTemplateID string, ...) (*eksv1.EKSClusterConfigSpec, string, error)
• func NodeGroupIssueIsUpdatable(code string) bool
• func Register(ctx context.Context, secrets wranglerv1.SecretController, ...)
• func StartEC2Service(ctx context.Context, secretClient wranglerv1.SecretClient, ...) (services.EC2ServiceInterface, error)
• func StartEKSService(ctx context.Context, secretClient wranglerv1.SecretClient, ...) (services.EKSServiceInterface, error)
• type Handler
  • func (h *Handler) OnEksConfigChanged(_ string, config *eksv1.EKSClusterConfig) (*eksv1.EKSClusterConfig, error)
  • func (h *Handler) OnEksConfigRemoved(_ string, config *eksv1.EKSClusterConfig) (*eksv1.EKSClusterConfig, error)

Functions

func BuildUpstreamClusterState

func BuildUpstreamClusterState(ctx context.Context, name, managedTemplateID string, clusterState *eks.DescribeClusterOutput, nodeGroupStates []*eks.DescribeNodegroupOutput, ec2Service services.EC2ServiceInterface, includeManagedLaunchTemplate bool) (*eksv1.EKSClusterConfigSpec, string, error)

BuildUpstreamClusterState builds the upstream cluster state from the given eks cluster and node group states.

func NodeGroupIssueIsUpdatable

func NodeGroupIssueIsUpdatable(code string) bool

NodeGroupIssueIsUpdatable checks to see the node group can be updated with the given issue code.

func Register

func Register(
	ctx context.Context,
	secrets wranglerv1.SecretController,
	eks ekscontrollers.EKSClusterConfigController)

func StartEC2Service

func StartEC2Service(ctx context.Context, secretClient wranglerv1.SecretClient, spec eksv1.EKSClusterConfigSpec) (services.EC2ServiceInterface, error)

StartEC2Service initializes and returns an instance of the EC2ServiceInterface interface, which provides methods for interacting with the EC2 service in AWS.

func StartEKSService

func StartEKSService(ctx context.Context, secretClient wranglerv1.SecretClient, spec eksv1.EKSClusterConfigSpec) (services.EKSServiceInterface, error)

StartEKSService initializes and returns an instance of the EKSServiceInterface interface, which provides methods for interacting with the EKS service in AWS.

Types

type Handler

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

func (*Handler) OnEksConfigChanged

func (h *Handler) OnEksConfigChanged(_ string, config *eksv1.EKSClusterConfig) (*eksv1.EKSClusterConfig, error)

func (*Handler) OnEksConfigRemoved

func (h *Handler) OnEksConfigRemoved(_ string, config *eksv1.EKSClusterConfig) (*eksv1.EKSClusterConfig, error)