workflows

Documentation

Index

• func DSLWorkflow(ctx workflow.Context, steps []DSLStep) error
• func ExecuteActivityWorkflow(ctx workflow.Context, input ExecuteActivityWorkflowInput) error
• func ReceiveSignalWorkflow(ctx workflow.Context, input ReceiveSignalWorkflowInput) error
• type DSLStep
• type ExecuteActivityWorkflowInput
• type ReceiveSignalWorkflowInput

Functions

func DSLWorkflow

func DSLWorkflow(ctx workflow.Context, steps []DSLStep) error

DSLWorkflow executes a list of DSLStep instructions.

func ExecuteActivityWorkflow

func ExecuteActivityWorkflow(ctx workflow.Context, input ExecuteActivityWorkflowInput) error

func ReceiveSignalWorkflow

func ReceiveSignalWorkflow(ctx workflow.Context, input ReceiveSignalWorkflowInput) error

Types

type DSLStep

type DSLStep struct {
	Activity string      `json:"a,omitempty"`
	Input    interface{} `json:"i,omitempty"`
	Child    []DSLStep   `json:"c,omitempty"`
	Repeat   int         `json:"r,omitempty"`
}

DSL step: either an activity or a child workflow (which is always this workflow)

type ExecuteActivityWorkflowInput

type ExecuteActivityWorkflowInput struct {
	Count    int
	Activity string
	Input    interface{}
}

type ReceiveSignalWorkflowInput

type ReceiveSignalWorkflowInput struct {
	Count int
	Name  string
}