eksadapter

func NewClusterManager ¶

func NewClusterManager(workflowClient client.Client, enterprise bool) eks.ClusterManager

NewClusterManager returns a new eks.ClusterManager that manages clusters asynchronously via Cadence workflows.

func NewNodePoolManager ¶

func NewNodePoolManager(
	awsFactory awsworkflow.AWSFactory,
	cloudFormationFactory awsworkflow.CloudFormationAPIFactory,
	dynamicClientFactory cluster.DynamicKubeClientFactory,
	enterprise bool,
	getUserID func(ctx context.Context) (userID uint),
	namespace string,
	workflowClient client.Client,
) eks.NodePoolManager

NewNodePoolManager returns a new eks.NodePoolManager that manages node pools asynchronously via Cadence workflows.

func NewNodePoolProcessor ¶

func NewNodePoolProcessor(db *gorm.DB, imageSelector eks.ImageSelector) nodePoolProcessor

NewNodePoolProcessor returns a new cluster.NodePoolProcessor that processes an EKS node pool request.

Note: once persistence is properly separated from Gorm, this should be moved to the EKS package, since it contains business processing rules.

func NewNodePoolStore ¶

func NewNodePoolStore(db *gorm.DB) eks.NodePoolStore

NewNodePoolStore returns a new eks.NodePoolStore that provides an interface to EKS node pool persistence.

func NewNodePoolValidator ¶

func NewNodePoolValidator(db *gorm.DB) nodePoolValidator

NewNodePoolValidator returns a new cluster.NodePoolValidator that validates an EKS node pool request.

Note: once persistence is properly separated from Gorm, this should be moved to the EKS package, since it contains business validation rules.