clusterworkflow

Documentation

Index

• Constants
• type ClusterGroupManager
• type CreateNodePoolLabelSetActivity
  • func NewCreateNodePoolLabelSetActivity(dynamicClientFactory DynamicClientFactory, namespace string) CreateNodePoolLabelSetActivity
  • func (a CreateNodePoolLabelSetActivity) Execute(ctx context.Context, input CreateNodePoolLabelSetActivityInput) error
• type CreateNodePoolLabelSetActivityInput
• type DeleteClusterActivity
  • func MakeDeleteClusterActivity(clusterDeleter cluster.Deleter) DeleteClusterActivity
  • func (a DeleteClusterActivity) Execute(ctx context.Context, input DeleteClusterActivityInput) error
• type DeleteClusterActivityInput
• type DeleteClusterWorkflow
  • func NewDeleteClusterWorkflow(v2IntegratedServiceEnabled bool) *DeleteClusterWorkflow
  • func (w *DeleteClusterWorkflow) Execute(ctx workflow.Context, input DeleteClusterWorkflowInput) error
• type DeleteClusterWorkflowInput
• type DeleteNodePoolLabelSetActivity
  • func NewDeleteNodePoolLabelSetActivity(dynamicClientFactory DynamicClientFactory, namespace string) DeleteNodePoolLabelSetActivity
  • func (a DeleteNodePoolLabelSetActivity) Execute(ctx context.Context, input DeleteNodePoolLabelSetActivityInput) error
• type DeleteNodePoolLabelSetActivityInput
• type DynamicClientFactory
• type RemoveClusterFromGroupActivity
  • func MakeRemoveClusterFromGroupActivity(clusterGroupManager ClusterGroupManager) RemoveClusterFromGroupActivity
  • func (a RemoveClusterFromGroupActivity) Execute(ctx context.Context, input RemoveClusterFromGroupActivityInput) error
• type RemoveClusterFromGroupActivityInput
• type SetClusterStatusActivity
  • func NewSetClusterStatusActivity(store cluster.Store) SetClusterStatusActivity
  • func (a SetClusterStatusActivity) Execute(ctx context.Context, input SetClusterStatusActivityInput) error
• type SetClusterStatusActivityInput

Constants

const CreateNodePoolLabelSetActivityName = "create-node-pool-label-set"

const DeleteClusterActivityName = "delete-cluster"

const DeleteClusterWorkflowName = "delete-cluster"

const DeleteNodePoolLabelSetActivityName = "delete-node-pool-label-set"

const RemoveClusterFromGroupActivityName = "remove-cluster-from-group"

const SetClusterStatusActivityName = "set-cluster-status"

Types

type ClusterGroupManager

type ClusterGroupManager interface {
	RemoveClusterFromGroup(ctx context.Context, clusterID uint) error
}

type CreateNodePoolLabelSetActivity

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

func NewCreateNodePoolLabelSetActivity

func NewCreateNodePoolLabelSetActivity(
	dynamicClientFactory DynamicClientFactory,
	namespace string,
) CreateNodePoolLabelSetActivity

NewCreateNodePoolLabelSetActivity returns a new CreateNodePoolLabelSetActivity.

func (CreateNodePoolLabelSetActivity) Execute

func (a CreateNodePoolLabelSetActivity) Execute(ctx context.Context, input CreateNodePoolLabelSetActivityInput) error

type CreateNodePoolLabelSetActivityInput

type CreateNodePoolLabelSetActivityInput struct {
	ClusterID   uint
	RawNodePool cluster.NewRawNodePool
}

type DeleteClusterActivity

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

func MakeDeleteClusterActivity

func MakeDeleteClusterActivity(clusterDeleter cluster.Deleter) DeleteClusterActivity

func (DeleteClusterActivity) Execute

func (a DeleteClusterActivity) Execute(ctx context.Context, input DeleteClusterActivityInput) error

type DeleteClusterActivityInput

type DeleteClusterActivityInput struct {
	ClusterID uint
	Force     bool
}

type DeleteClusterWorkflow

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

func NewDeleteClusterWorkflow

func NewDeleteClusterWorkflow(v2IntegratedServiceEnabled bool) *DeleteClusterWorkflow

func (*DeleteClusterWorkflow) Execute

func (w *DeleteClusterWorkflow) Execute(ctx workflow.Context, input DeleteClusterWorkflowInput) error

type DeleteClusterWorkflowInput

type DeleteClusterWorkflowInput struct {
	ClusterID uint
	Force     bool
}

type DeleteNodePoolLabelSetActivity

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

func NewDeleteNodePoolLabelSetActivity

func NewDeleteNodePoolLabelSetActivity(
	dynamicClientFactory DynamicClientFactory,
	namespace string,
) DeleteNodePoolLabelSetActivity

NewDeleteNodePoolLabelSetActivity returns a new DeleteNodePoolLabelSetActivity.

func (DeleteNodePoolLabelSetActivity) Execute

func (a DeleteNodePoolLabelSetActivity) Execute(ctx context.Context, input DeleteNodePoolLabelSetActivityInput) error

type DeleteNodePoolLabelSetActivityInput

type DeleteNodePoolLabelSetActivityInput struct {
	ClusterID    uint
	NodePoolName string
}

type DynamicClientFactory

type DynamicClientFactory interface {
	// FromClusterID creates a dynamic Kubernetes client for a cluster from a cluster ID.
	FromClusterID(ctx context.Context, clusterID uint) (dynamic.Interface, error)
}

DynamicClientFactory returns a dynamic Kubernetes client.

type RemoveClusterFromGroupActivity

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

func MakeRemoveClusterFromGroupActivity

func MakeRemoveClusterFromGroupActivity(clusterGroupManager ClusterGroupManager) RemoveClusterFromGroupActivity

func (RemoveClusterFromGroupActivity) Execute

func (a RemoveClusterFromGroupActivity) Execute(ctx context.Context, input RemoveClusterFromGroupActivityInput) error

type RemoveClusterFromGroupActivityInput

type RemoveClusterFromGroupActivityInput struct {
	ClusterID uint
}

type SetClusterStatusActivity

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

func NewSetClusterStatusActivity

func NewSetClusterStatusActivity(store cluster.Store) SetClusterStatusActivity

func (SetClusterStatusActivity) Execute

func (a SetClusterStatusActivity) Execute(ctx context.Context, input SetClusterStatusActivityInput) error

type SetClusterStatusActivityInput

type SetClusterStatusActivityInput struct {
	ClusterID     uint
	Status        string
	StatusMessage string
}