Skip to main content

Checkpointer

Trait Checkpointer 

Source
pub trait Checkpointer<S>: Send + Sync
where S: GraphStateTrait,
{ // Required method fn save_state(&self, node_id: &str, state: &S) -> Result<()>; // Provided method fn load_state(&self, _node_id: &str) -> Result<Option<S>> { ... } }
Expand description

状态检查点存储抽象。

当前仅在 InMemoryCheckpointer 中用于开发/调试场景,未来可以替换为 基于数据库或对象存储的持久化实现。

Required Methods§

Source

fn save_state(&self, node_id: &str, state: &S) -> Result<()>

保存指定节点执行后的完整状态快照。

Provided Methods§

Source

fn load_state(&self, _node_id: &str) -> Result<Option<S>>

加载某个节点最近一次保存的状态快照。

默认实现返回 Ok(None),表示未找到对应检查点。

Implementors§