Expand description
执行引擎 — ExecutionEngine, ExecutionLoop, Session。
Structs§
- Checkpoint
Config - Checkpoint 保存配置 — 传入
run_execution_loop即可启用自动保存。 - Checkpoint
Save Sink - Checkpoint 保存 Sink — 包装 CheckpointConfig 为 CheckpointSink。
- Execution
Control - 控制信号容器 — 节点写入,Executor 读取。
- Execution
Engine - 执行引擎 — 借用 State,持有 Mutation 缓冲、流发射器等运行时资源。
- Execution
Session - 执行会话 — 持有 State 所有权 + FrameStack + Graph 引用。
- Node
Metadata - 节点元数据 — 提供给 Executor 的额外信息。
- Owned
Execution Engine - 拥有 State 所有权的执行引擎 — 用于 Parallel 分支等需要独立 State 的场景。
- Session
Checkpoint - 会话检查点 — 完整恢复快照。
- Session
Checkpoint Sink - Session 的 Checkpoint Sink — 将 checkpoint 事件写入 FrameStack。
Enums§
- Execution
Signal - 控制信号 — 独立枚举,Barrier 挂起不是路由。
- Next
Action - 节点执行后的下一步路由。
- Session
Error - Session 操作错误。
Traits§
- Execution
View - 受限视图 — Leaf 节点需要的最小能力。
- Executor
State - 完整能力 — Composite 节点 + LeafAdapter 使用。
Type Aliases§
- Execution
Context - 向后兼容别名 —
ExecutionContext→ExecutionEngine。