Struct GraphExecutor 

pub struct GraphExecutor {
    pub max_steps: usize,
    /* private fields */
}

Graph 执行器 — 可配置运行时参数。

支持可选的 Checkpoint 集成，实现持久化执行。

Fields

max_steps: usize

全局运行时步数限制。 1 Step = 1 Node Entry。

Implementations

impl GraphExecutor

pub fn new(max_steps: usize) -> Self

创建基础执行器（无 Checkpoint）。

pub fn with_checkpoint( max_steps: usize, store: Arc<dyn CheckpointStore>, policy: CheckpointPolicy, graph: &Graph, ) -> Self

创建带 Checkpoint 的执行器。

pub fn set_store(&mut self, store: Arc<dyn CheckpointStore>)

设置 Checkpoint 存储后端。

pub fn set_policy(&mut self, policy: CheckpointPolicy)

设置 Checkpoint 频率策略。

pub fn register_reducer(&mut self, key: &str, reducer: Reducer)

注册 key 的 Reducer（用于 ParallelNode 合并策略）。

pub fn set_checkpoint_score(self, score: CheckpointScore) -> Self

设置 Adaptive Checkpoint 评分器。

pub fn set_graph(&mut self, graph: &Graph)

设置图结构指纹。

pub async fn execute( &self, graph: Arc<Graph>, initial_state: State, ) -> Result<GraphResult, GraphError>

执行 Graph（阻塞模式）。

Blocking is derived from stream. 内部消费 stream 直到结束。

⚠️ BarrierNode 不支持阻塞模式。 如果图中包含 BarrierNode， 会提前返回错误，引导用户使用 execute_stream()。

pub fn execute_stream( &self, graph: Arc<Graph>, initial_state: State, ) -> GraphExecution

流式执行 Graph，返回 GraphExecution（stream + handle）。

Stream is primary, Blocking is derived.

pub async fn resume_from( &self, store: &dyn CheckpointStore, trace_id: &TraceId, graph: &Arc<Graph>, ) -> Result<GraphExecution, GraphError>

从 Checkpoint 恢复执行。

1. 加载 trace_id 对应的最新 Checkpoint
2. 校验 graph_hash（Strict 模式）
3. 从 current_node 继续执行

参数

• store — Checkpoint 存储后端
• trace_id — 要恢复的执行 Trace ID
• graph — 当前图定义（用于 hash 校验）

错误

• Checkpoint 不存在 → NotFound
• 图结构已变更 → InvalidGraph（Strict 模式）

Trait Implementations

impl Clone for GraphExecutor

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for GraphExecutor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for GraphExecutor

fn default() -> Self

Returns the “default value” for a type.