eksadapter

Documentation

Index

• func NewClusterManager(workflowClient client.Client, enterprise bool) eks.ClusterManager
• func NewNodePoolManager(awsFactory awsworkflow.AWSFactory, ...) eks.NodePoolManager
• func NewNodePoolProcessor(db *gorm.DB, imageSelector eks.ImageSelector) nodePoolProcessor
• func NewNodePoolStore(db *gorm.DB) eks.NodePoolStore
• func NewNodePoolValidator(db *gorm.DB) nodePoolValidator

Functions

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.