workflow

Documentation

Index

• func InitWorkflowService()
• func ProcessWorkflow(workflow *v2.WorkflowSchema) error
• func ProcessWorkflows() error
• func RegisterWorkflowAction(name string, handler v2.IWorkflowAction)
• func ShutdownWorkflowService() error
• func ValidateStatus(obj *v2.WorkflowSchema)
• type AgentTaskAction
  • func (a AgentTaskAction) Execute(action *v2.WorkflowAction, d interface{}, theAccount *v2.AccountSchema, ...) error
• type CreateAgentAction
  • func (a CreateAgentAction) Execute(action *v2.WorkflowAction, d interface{}, theAccount *v2.AccountSchema, ...) error
• type WaitForOnlineAction
  • func (a WaitForOnlineAction) Execute(action *v2.WorkflowAction, d interface{}, theAccount *v2.AccountSchema, ...) error

Functions

func InitWorkflowService

func InitWorkflowService()

func ProcessWorkflow

func ProcessWorkflow(workflow *v2.WorkflowSchema) error

func ProcessWorkflows

func ProcessWorkflows() error

func RegisterWorkflowAction

func RegisterWorkflowAction(name string, handler v2.IWorkflowAction)

func ShutdownWorkflowService

func ShutdownWorkflowService() error

func ValidateStatus

func ValidateStatus(obj *v2.WorkflowSchema)

Types

type AgentTaskAction

type AgentTaskAction struct{}

func (AgentTaskAction) Execute

func (a AgentTaskAction) Execute(action *v2.WorkflowAction, d interface{}, theAccount *v2.AccountSchema, wctx v2.WorkflowContext) error

Execute enqueues the task on first run, then polls it to a terminal status.

Storing TaskID on the action is what makes a step re-run idempotent: without it, every pass through this function appended a fresh task. The dedupe key is the backstop for the window where the id is lost before it is persisted.

type CreateAgentAction

type CreateAgentAction struct{}

func (CreateAgentAction) Execute

func (a CreateAgentAction) Execute(action *v2.WorkflowAction, d interface{}, theAccount *v2.AccountSchema, _ v2.WorkflowContext) error

type WaitForOnlineAction

type WaitForOnlineAction struct{}

func (WaitForOnlineAction) Execute

func (a WaitForOnlineAction) Execute(action *v2.WorkflowAction, d interface{}, theAccount *v2.AccountSchema, _ v2.WorkflowContext) error