flowchart

func (*Workflow) AddAspect ¶

func (w *Workflow) AddAspect(aspect node.Aspect) error

AddAspect 添加全局切面

func (*Workflow) AddNode ¶

func (w *Workflow) AddNode(n node.Node) error

AddNode 向工作流添加一个执行节点

func (*Workflow) Close ¶

func (w *Workflow) Close()

func (*Workflow) Err ¶

func (w *Workflow) Err() error

func (*Workflow) Get ¶

func (w *Workflow) Get(key string) (any, error)

func (*Workflow) GetPoolInfo ¶

func (w *Workflow) GetPoolInfo() map[string]any

func (*Workflow) GetStats ¶

func (w *Workflow) GetStats() map[string]any

func (*Workflow) Input ¶

func (w *Workflow) Input(key string, value any) error

Input 输入初始数据

func (*Workflow) IsClosed ¶

func (w *Workflow) IsClosed() bool

func (*Workflow) IsRunning ¶

func (w *Workflow) IsRunning() bool

func (*Workflow) Reset ¶

func (w *Workflow) Reset(ctx context.Context) error

func (*Workflow) ResizePool ¶

func (w *Workflow) ResizePool(newSize int) error

func (*Workflow) Run ¶

func (w *Workflow) Run(input map[string]any) error

Run 运行工作流（阻塞直到所有节点完成） 所有节点同时提交到协程池，通过 FlowContext.Wait 自行等待依赖就绪

func (*Workflow) RunNode ¶

func (w *Workflow) RunNode(n node.Node)

RunNode 执行单个节点（包含切面 + 拦截器调用链）

func (*Workflow) Start ¶

func (w *Workflow) Start() error

Start 异步启动工作流

func (*Workflow) Wait ¶

func (w *Workflow) Wait() error

Wait 阻塞等待工作流完成