workflow

type Context struct {
	sync.Locker //锁

	Data     map[string]interface{} `json:"data"`     // 共享数据
	NodeID   string                 `json:"nodeID"`   // 当前节点ID
	Workflow *Workflow              `json:"workflow"` // 所属工作流
}

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

type Node struct {
	ID          string                  `json:"ID"`          // 节点唯一标识
	Action      func(ctx Context) error `json:"-"`           // 执行函数
	RetryPolicy int                     `json:"RetryPolicy"` // 重试次数
	DependsOn   []string                `json:"DependsOn"`   // 依赖的节点ID
}

type State string

type Workflow struct {
	ID    string          `json:"id"` //工作流唯一ID
	Nodes map[string]Node //节点集合
	State State           `json:"state"` //当前工作流状态

	Success map[string]bool `json:"success"`
	// contains filtered or unexported fields
}