Expand description
检查点 + 持久化 — Checkpoint, Policy, Codec, Store, MutationLog, Trace。
Re-exports§
pub use crate::ids::TraceId;
Structs§
- Checkpoint
- 执行检查点 — 物化快照 + 执行游标。
- Checkpoint
Blob - 跨 Codec 的统一载体 — 存储层操作的对象。
- Checkpoint
Id - Checkpoint 唯一标识。
- Execution
Trace - 执行追踪 — 强类型 Mutation 审计日志。
- Exported
Trace - 导出的追踪记录 — 统一 JSON 序列化,供外部消费。
- Exported
Trace Step - Frame
- 向后兼容 — CheckpointPolicy 已迁移至 checkpoint_policy 模块。 v0.5 使用 TriggerPolicy + RetentionPolicy 替代。 执行帧 — 保存单个 Graph 的执行位置。
- Frame
Info - Checkpoint 边界描述 — Engine 传递给 Sink 的最小上下文。
- Frame
Stack - 帧栈 — 保存完整的执行位置历史。
- InMemory
Blob Store - 基于内存的 Checkpoint 存储后端。
- InMemory
Mutation Log - 基于内存的 MutationLog 实现。
- Memory
Sink - 内存 Sink — 将所有 checkpoint 记录到内存。
- Memory
Trace Sink - 内存 TraceSink — v0.4 默认实现。
- Mutation
LogEntry - Mutation 日志条目 — 持久化审计记录。
- NodeId
- 节点标识。
- Noop
Checkpoint Sink - 空 Sink — 不记录任何内容。
- Serde
Checkpoint Codec - 基于 Serde + JSON 的默认 Codec 实现。
- Trace
Step - 执行步骤记录 — 单个节点的 Mutation 审计。
- Typed
Checkpoint Store - 类型化 Checkpoint 存储 — Codec + BlobStore 的组合。
Enums§
- Checkpoint
Policy Deprecated - v0.4 的 CheckpointPolicy — 已弃用,请使用 TriggerPolicy。
- Checkpoint
Store Error - Checkpoint 存储操作错误。
- Retention
Policy - Checkpoint 保留策略 — 决定保留多少个。
- Trigger
Policy - Checkpoint 触发策略 — 决定何时保存。
Traits§
- Blob
Checkpoint Store - Checkpoint 存储后端 SPI — bytes in / bytes out。
- Checkpoint
Codec - Checkpoint 序列化/反序列化接口。
- Checkpoint
Sink - Checkpoint Sink SPI — 执行引擎通知 Sink 到达了合法的恢复边界。
- Mutation
LogStore - MutationLog 存储后端 SPI。
- Trace
Sink - 审计日志接收器 — Executor 通过 TraceSink 记录每一步。
Functions§
- mutations_
to_ log_ entries - Mutation 到 JSON 的转换器 — 供执行循环使用。
Type Aliases§
- Checkpoint
Save Fn - Checkpoint 保存回调类型别名。