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
- type CreateAgentAction
- type WaitForOnlineAction
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 ¶ added in v1.0.79
type AgentTaskAction struct{}
func (AgentTaskAction) Execute ¶ added in v1.0.79
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
Source Files
Click to show internal directories.
Click to hide internal directories.