workflows

Documentation

Index

• Constants
• type DeploymentWorkflow
  • func NewDeploymentWorkflow(deploymentPlan *mrds.DeploymentPlanActivities, ...) *DeploymentWorkflow
  • func (d *DeploymentWorkflow) RunDeployment(ctx workflow.Context, params RunDeploymentWorkflowParams) error
• type OperationsWorkflow
  • func NewOperationsWorkflow(metaInstanceActivities *mrds.MetaInstanceActivities, ...) *OperationsWorkflow
  • func (d *OperationsWorkflow) RunOperation(ctx workflow.Context, params RunOperationWorkflowParams) (*RunOperationWorkflowResponse, error)
• type RunDeploymentWorkflowParams
• type RunOperationWorkflowParams
• type RunOperationWorkflowResponse

Constants

const OperationsWorkflowName = "RunOperation"

const RunDeploymentWorkflowName = "RunDeployment"

Types

type DeploymentWorkflow

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

func NewDeploymentWorkflow

func NewDeploymentWorkflow(
	deploymentPlan *mrds.DeploymentPlanActivities,
	metaInstance *mrds.MetaInstanceActivities,
	registry worker.Registry,
) *DeploymentWorkflow

DeploymentWorkflow is a Temporal workflow that deploys a new cluster.

func (*DeploymentWorkflow) RunDeployment

func (d *DeploymentWorkflow) RunDeployment(ctx workflow.Context, params RunDeploymentWorkflowParams) error

type OperationsWorkflow

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

func NewOperationsWorkflow

func NewOperationsWorkflow(
	metaInstanceActivities *mrds.MetaInstanceActivities,
	schedulerActivities *scheduler.SchedulerActivities,
	runtimeActivities runtime.RuntimeActivities,
	registry worker.Registry,
) *OperationsWorkflow

func (*OperationsWorkflow) RunOperation

func (d *OperationsWorkflow) RunOperation(ctx workflow.Context, params RunOperationWorkflowParams) (*RunOperationWorkflowResponse, error)

type RunDeploymentWorkflowParams

type RunDeploymentWorkflowParams struct {
	DeploymentPlan      *mrdspb.DeploymentPlanRecord
	Deployment          *mrdspb.Deployment
	ChildWorkflowParams []RunOperationWorkflowParams
}

type RunOperationWorkflowParams

type RunOperationWorkflowParams struct {
	MetaInstanceID string
	OperationID    string
	OperationType  mrdspb.OperationType
}

type RunOperationWorkflowResponse

type RunOperationWorkflowResponse struct {
	MetaInstance *mrdspb.MetaInstance
}