Struct GraphExecutor 

pub struct GraphExecutor {
    pub max_steps: usize,
}

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

Fields

max_steps: usize

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

Implementations

impl GraphExecutor

pub fn new(max_steps: usize) -> Self

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

执行 Graph（阻塞模式）。

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

接收 Arc<Graph> 以避免克隆。与 execute_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.

Trait Implementations

impl Clone for GraphExecutor

fn clone(&self) -> GraphExecutor

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.