controller

Documentation

Index

• func BuildUpstreamClusterState(name, managedTemplateID string, clusterState *eks.DescribeClusterOutput, ...) (*eksv1.EKSClusterConfigSpec, string, error)
• func NodeGroupIssueIsUpdatable(code string) bool
• func Register(ctx context.Context, secrets wranglerv1.SecretController, ...)
• func StartAWSSessions(secretsCache wranglerv1.SecretCache, spec eksv1.EKSClusterConfigSpec) (*session.Session, *eks.EKS, 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(name, managedTemplateID string, clusterState *eks.DescribeClusterOutput, nodeGroupStates []*eks.DescribeNodegroupOutput, ec2Service services.EC2ServiceInterface, includeManagedLaunchTemplate bool) (*eksv1.EKSClusterConfigSpec, string, error)

buildUpstreamClusterState

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 StartAWSSessions

func StartAWSSessions(secretsCache wranglerv1.SecretCache, spec eksv1.EKSClusterConfigSpec) (*session.Session, *eks.EKS, error)

StartAWSSessions starts AWS sessions.

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)