flow

Documentation

Index

• Variables
• type Engine
  • func NewEngine() *Engine
  • func (e *Engine) Start(ctx context.Context, param *WorkflowParam) (string, error)
  • func (e *Engine) Transition(ctx context.Context, param *WorkflowParam) error
  • func (e *Engine) Validate(ctx context.Context, instanceID string) error
• type WorkflowEventCatalog
• type WorkflowParam

Variables

var ErrWorkflowNotExists = errors.New("workflow not exists")

ErrWorkflowNotExists is returned when workflow not exists

Types

type Engine

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

func NewEngine

func NewEngine() *Engine

func (*Engine) Start

func (e *Engine) Start(ctx context.Context, param *WorkflowParam) (string, error)

Start start workflow

func (*Engine) Transition

func (e *Engine) Transition(ctx context.Context, param *WorkflowParam) error

Transition transition next workflow task

func (*Engine) Validate

func (e *Engine) Validate(ctx context.Context, instanceID string) error

Validate 验证流程执行合法性

type WorkflowEventCatalog

type WorkflowEventCatalog struct {
	OperationID string `json:"operation_id"`
	Topic       string `json:"topic"`
	Schema      string `json:"schema"`
}

type WorkflowParam

type WorkflowParam struct {
	ID             string `json:"id"`
	InstanceID     string `json:"instance_id"`
	TaskInstanceID string `json:"task_instance_id"`
	Input          string `json:"input"`
}

WorkflowParam workflow runtime param