Documentation
¶
Index ¶
Constants ¶
const DeleteNodePoolWorkflowName = "pke-aws-delete-node-pool"
DeleteNodePoolWorkflowName is the name of the PKE node pool deletion workflow.
const DeleteStoredNodePoolActivityName = "pke-aws-delete-stored-node-pool"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DeleteNodePoolWorkflow ¶
type DeleteNodePoolWorkflow struct{}
DeleteNodePoolWorkflow defines a Cadence workflow encapsulating high level input-independent components required to delete an PKE node pool.
func NewDeleteNodePoolWorkflow ¶
func NewDeleteNodePoolWorkflow() *DeleteNodePoolWorkflow
NewDeleteNodePoolWorkflow instantiates an EKS node pool deletion workflow.
func (DeleteNodePoolWorkflow) Execute ¶
func (w DeleteNodePoolWorkflow) Execute(ctx workflow.Context, input DeleteNodePoolWorkflowInput) (err error)
Execute runs the workflow.
func (DeleteNodePoolWorkflow) Register ¶
func (w DeleteNodePoolWorkflow) Register(worker worker.Registry)
Register registers the activity in the worker.
type DeleteNodePoolWorkflowInput ¶
type DeleteNodePoolWorkflowInput struct {
ClusterID uint
ClusterName string
NodePoolName string
OrganizationID uint
Region string
SecretID string
// Note: ClusterAPI.DeleteCluster, ClusterAPI.UpdateCluster node pool
// deletions should not change the cluster status (DELETING/UPDATING),
// because success could not yet mean RUNNING status and errors should be
// handled by the higher level workflow, but NodePoolAPI.DeleteNodePool node
// pool deletions should update the cluster status.
ShouldUpdateClusterStatus bool
}
DeleteNodePoolWorkflowInput defines the input parameters of an PKE node pool deletion.
type DeleteStoredNodePoolActivity ¶
type DeleteStoredNodePoolActivity struct {
// contains filtered or unexported fields
}
DeleteStoredNodePoolActivity collects the necessary component dependencies for executing a stored node pool deletion operation.
func NewDeleteStoredNodePoolActivity ¶
func NewDeleteStoredNodePoolActivity(nodePoolStore pke.NodePoolStore) *DeleteStoredNodePoolActivity
NewDeleteStoredNodePoolActivity instantiates an activity object for deleting stored node pools.
func (*DeleteStoredNodePoolActivity) Execute ¶
func (a *DeleteStoredNodePoolActivity) Execute(ctx context.Context, input DeleteStoredNodePoolActivityInput) error
Execute executes a stored node pool deletion operation with the specified input parameters.
func (DeleteStoredNodePoolActivity) Register ¶
func (a DeleteStoredNodePoolActivity) Register(worker worker.Registry)
Register registers the stored node pool deletion activity.
type DeleteStoredNodePoolActivityInput ¶
type DeleteStoredNodePoolActivityInput struct {
ClusterID uint
ClusterName string
NodePoolName string
OrganizationID uint
}
DeleteStoredNodePoolActivityInput encapsulates the dynamic parameters of the stored node pool deletion operation.
type MockAWSFactory ¶
MockAWSFactory is an autogenerated mock for the AWSFactory type.
Source Files