workflow

Documentation

Index

• Constants
• func DefineWorkflow(workflow *flow.Workflow, context *flow.Context) error
• type Workflow
  • func NewWorkflow() *Workflow
  • func (w *Workflow) Create()
  • func (w *Workflow) GetWorkflow()
  • func (w *Workflow) SetContext(ctx *flow.Context)
  • func (w *Workflow) Step(invoke operation.Modifier, compensate operation.Modifier)

Constants

const (
	PASS  = "pass"
	ERROR = "error"
)

Functions

func DefineWorkflow

func DefineWorkflow(workflow *flow.Workflow, context *flow.Context) error

Types

type Workflow

type Workflow struct {
	Workflow *goflow.FlowService
	Dag      *flow.Dag
	// context  *flow.Context
	Name string
}

func NewWorkflow

func NewWorkflow() *Workflow

func (*Workflow) Create

func (w *Workflow) Create()

func (*Workflow) GetWorkflow

func (w *Workflow) GetWorkflow()

func (*Workflow) SetContext

func (w *Workflow) SetContext(ctx *flow.Context)

func (*Workflow) Step

func (w *Workflow) Step(
	invoke operation.Modifier,
	compensate operation.Modifier,
)