workload

Documentation

Index

• type Create
  • func NewCreate(provider providers.Provider, clusterManager interfaces.ClusterManager, ...) *Create
  • func (c *Create) Run(ctx context.Context, clusterSpec *cluster.Spec, validator interfaces.Validator) error
• type Delete
  • func NewDelete(provider providers.Provider, writer filewriter.FileWriter, ...) *Delete
  • func (c *Delete) Run(ctx context.Context, workload *types.Cluster, clusterSpec *cluster.Spec) error
• type Upgrade
  • func NewUpgrade(clientFactory interfaces.ClientFactory, provider providers.Provider, ...) *Upgrade
  • func (c *Upgrade) Run(ctx context.Context, cluster *types.Cluster, clusterSpec *cluster.Spec, ...) error

Types

type Create

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

Create is the workflow that creates a workload clusters.

func NewCreate

func NewCreate(provider providers.Provider,
	clusterManager interfaces.ClusterManager, gitOpsManager interfaces.GitOpsManager,
	writer filewriter.FileWriter,
	eksdInstaller interfaces.EksdInstaller,
	packageInstaller interfaces.PackageInstaller,
	clusterCreator interfaces.ClusterCreator,
	clientFactory interfaces.ClientFactory,
) *Create

NewCreate builds a new create construct.

func (*Create) Run

func (c *Create) Run(ctx context.Context, clusterSpec *cluster.Spec, validator interfaces.Validator) error

Run executes the tasks to create a workload cluster.

type Delete

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

Delete is the workflow that deletes a workload clusters.

func NewDelete

func NewDelete(provider providers.Provider,
	writer filewriter.FileWriter,
	clusterManager interfaces.ClusterManager,
	clusterDeleter interfaces.ClusterDeleter,
	gitopsManager interfaces.GitOpsManager,
) *Delete

NewDelete builds a new delete construct.

func (*Delete) Run

func (c *Delete) Run(ctx context.Context, workload *types.Cluster, clusterSpec *cluster.Spec) error

Run executes the tasks to delete a workload cluster.

type Upgrade

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

Upgrade is a schema for upgrade cluster.

func NewUpgrade

func NewUpgrade(clientFactory interfaces.ClientFactory,
	provider providers.Provider,
	clusterManager interfaces.ClusterManager, gitOpsManager interfaces.GitOpsManager,
	writer filewriter.FileWriter,
	clusterUpgrader interfaces.ClusterUpgrader,
	eksdInstaller interfaces.EksdInstaller,
	packageInstaller interfaces.PackageInstaller,
) *Upgrade

NewUpgrade builds a new upgrade construct.

func (*Upgrade) Run

func (c *Upgrade) Run(ctx context.Context, cluster *types.Cluster, clusterSpec *cluster.Spec, validator interfaces.Validator) error

Run Upgrade implements upgrade functionality for workload cluster's upgrade operation.