Struct CompiledGraph 

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

已编译完成、可执行的状态图。

Implementations

impl<S> CompiledGraph<S>

where S: GraphStateTrait,

pub fn with_checkpointer<C>(self, checkpointer: C) -> Self

where C: Checkpointer<S> + 'static,

挂载一个检查点存储实现。图的执行并不强依赖检查点存在。

pub async fn invoke(&self, state: S) -> Result<S>

按有向图顺序依次执行节点：

• 从 entry 节点开始；
• 每个节点运行后通过 apply_update 合并状态；
• 若存在条件边，则优先根据 router 结果选下一跳；
• 否则选择第一条普通出边；
• 若到达 finish 节点或无出边，则结束执行。

pub async fn resume(&self, node_id: &str) -> Result<S>

从某个节点的检查点恢复执行的占位接口：

• 若未挂载 Checkpointer，返回错误；
• 若找不到对应节点的检查点，同样返回错误；
• 目前的实现会从加载出的状态重新执行整张图（仍从 entry 开始）， 未来可以扩展为从任意节点继续执行。