Back to godoc.org

Package clusterworkflow

v0.0.0-...-083858d
Latest Go to latest

The highest tagged major version is .

Published: today | License: Apache-2.0 | Module: github.com/banzaicloud/pipeline

Index

Constants

const CreateNodePoolActivityName = "create-node-pool"
const CreateNodePoolLabelSetActivityName = "create-node-pool-label-set"
const CreateNodePoolWorkflowName = "create-node-pool"
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"

func CreateNodePoolWorkflow

func CreateNodePoolWorkflow(ctx workflow.Context, input CreateNodePoolWorkflowInput) error

func DeleteClusterWorkflow

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

type ClusterGroupManager

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

type CreateNodePoolActivity

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

func NewCreateNodePoolActivity

func NewCreateNodePoolActivity(
	clusters cluster.Store,
	eksNodePoolCreator NodePoolCreator,
) CreateNodePoolActivity

NewCreateNodePoolActivity returns a new CreateNodePoolActivity.

func (CreateNodePoolActivity) Execute

func (a CreateNodePoolActivity) Execute(ctx context.Context, input CreateNodePoolActivityInput) error

type CreateNodePoolActivityInput

type CreateNodePoolActivityInput struct {
	ClusterID   uint
	UserID      uint
	RawNodePool cluster.NewRawNodePool
}

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 CreateNodePoolWorkflowInput

type CreateNodePoolWorkflowInput struct {
	ClusterID   uint
	UserID      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 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 NodePoolCreator

type NodePoolCreator interface {
	CreateNodePool(
		ctx context.Context,
		userID uint,
		c cluster.Cluster,
		rawNodePool cluster.NewRawNodePool,
	) error
}

NodePoolCreator creates a new node pool. This is a temporary interface to decouple some EKS specific logic from the clusterworkflow package. Once we get rid of the common node pool create workflow, this will go away as well.

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
}

Package Files

Documentation was rendered with GOOS=linux and GOARCH=amd64.

Jump to identifier

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to identifier