Struct InMemoryCheckpointer 

pub struct InMemoryCheckpointer<S>
where
    S: GraphStateTrait,
{ /* private fields */ }

纯内存版检查点存储，用于开发与测试。

• 按节点 id 存储最新一次执行后的状态快照；
• 使用互斥锁保证线程安全；
• 仅适用于单进程、低并发场景。

Implementations

impl<S> InMemoryCheckpointer<S>

where S: GraphStateTrait,

pub fn new() -> Self

pub fn get(&self, node_id: &str) -> Option<S>

Trait Implementations

impl<S> Checkpointer<S> for InMemoryCheckpointer<S>

where S: GraphStateTrait,

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

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

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

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