Skip to main content

Module checkpoint

Module checkpoint 

Source
Expand description

检查点 + 持久化 — Checkpoint, Policy, Codec, Store, MutationLog, Trace。

Re-exports§

pub use crate::ids::TraceId;

Structs§

Checkpoint
执行检查点 — 物化快照 + 执行游标。
CheckpointBlob
跨 Codec 的统一载体 — 存储层操作的对象。
CheckpointId
Checkpoint 唯一标识。
ExecutionTrace
执行追踪 — 强类型 Mutation 审计日志。
ExportedTrace
导出的追踪记录 — 统一 JSON 序列化,供外部消费。
ExportedTraceStep
Frame
向后兼容 — CheckpointPolicy 已迁移至 checkpoint_policy 模块。 v0.5 使用 TriggerPolicy + RetentionPolicy 替代。 执行帧 — 保存单个 Graph 的执行位置。
FrameInfo
Checkpoint 边界描述 — Engine 传递给 Sink 的最小上下文。
FrameStack
帧栈 — 保存完整的执行位置历史。
InMemoryBlobStore
基于内存的 Checkpoint 存储后端。
InMemoryMutationLog
基于内存的 MutationLog 实现。
MemorySink
内存 Sink — 将所有 checkpoint 记录到内存。
MemoryTraceSink
内存 TraceSink — v0.4 默认实现。
MutationLogEntry
Mutation 日志条目 — 持久化审计记录。
NodeId
节点标识。
NoopCheckpointSink
空 Sink — 不记录任何内容。
SerdeCheckpointCodec
基于 Serde + JSON 的默认 Codec 实现。
TraceStep
执行步骤记录 — 单个节点的 Mutation 审计。
TypedCheckpointStore
类型化 Checkpoint 存储 — Codec + BlobStore 的组合。

Enums§

CheckpointPolicyDeprecated
v0.4 的 CheckpointPolicy — 已弃用,请使用 TriggerPolicy。
CheckpointStoreError
Checkpoint 存储操作错误。
RetentionPolicy
Checkpoint 保留策略 — 决定保留多少个。
TriggerPolicy
Checkpoint 触发策略 — 决定何时保存。

Traits§

BlobCheckpointStore
Checkpoint 存储后端 SPI — bytes in / bytes out。
CheckpointCodec
Checkpoint 序列化/反序列化接口。
CheckpointSink
Checkpoint Sink SPI — 执行引擎通知 Sink 到达了合法的恢复边界。
MutationLogStore
MutationLog 存储后端 SPI。
TraceSink
审计日志接收器 — Executor 通过 TraceSink 记录每一步。

Functions§

mutations_to_log_entries
Mutation 到 JSON 的转换器 — 供执行循环使用。

Type Aliases§

CheckpointSaveFn
Checkpoint 保存回调类型别名。