workflow

Documentation

Index

• Constants
• func ExpiryJobWorkflow(ctx workflow.Context, input ExpiryJobWorkflowInput) error
• type ExpiryActivity
  • func NewExpiryActivity(clusterDeleter clusterDeleter) ExpiryActivity
  • func (a ExpiryActivity) Execute(ctx context.Context, input ExpiryActivityInput) error
• type ExpiryActivityInput
• type ExpiryJobWorkflowInput

Constants

const ExpireActivityName = "expire-cluster-activity"

const (
	ExpiryJobWorkflowName = "expiry-job"
)

Functions

func ExpiryJobWorkflow

func ExpiryJobWorkflow(ctx workflow.Context, input ExpiryJobWorkflowInput) error

ExpiryJobWorkflow triggers the cluster deletion at a given date

Types

type ExpiryActivity

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

func NewExpiryActivity

func NewExpiryActivity(clusterDeleter clusterDeleter) ExpiryActivity

func (ExpiryActivity) Execute

func (a ExpiryActivity) Execute(ctx context.Context, input ExpiryActivityInput) error

type ExpiryActivityInput

type ExpiryActivityInput struct {
	ClusterID uint
}

type ExpiryJobWorkflowInput

type ExpiryJobWorkflowInput struct {
	ClusterID  uint
	ExpiryDate string
}

ExpiryJobWorkflowInput defines the fixed inputs of the expiry workflow