Enum StreamNodeResult 

pub enum StreamNodeResult {
    Continue {
        deltas: Vec<StateDelta>,
        next: NextStep,
        span_id: SpanId,
        observed: Option<ObservedError>,
        metadata: Option<NodeMetadata>,
    },
    Pause {
        deltas: Vec<StateDelta>,
        barrier_id: BarrierId,
        node_name: String,
        span_id: SpanId,
        timeout: Option<Duration>,
        default_action: BarrierDefaultAction,
    },
    Fallback {
        deltas: Vec<StateDelta>,
        reason: String,
        node_name: String,
    },
}

节点流式执行结果。

Variants

Continue

节点正常完成（统一 Done + Observed）

Fields

deltas: Vec<StateDelta>

状态增量

next: NextStep

下一步

span_id: SpanId

执行实例 ID

observed: Option<ObservedError>

可选的观测错误（不影响 control flow）

metadata: Option<NodeMetadata>

节点元数据（可选 — 用于 Adaptive Checkpoint 等）

Pause

Barrier 暂停，等待外部决策

Fields

deltas: Vec<StateDelta>

状态增量（Barrier 进入等待前的修改）

barrier_id: BarrierId

Barrier 审批请求 ID

node_name: String

节点名称

span_id: SpanId

执行实例 ID

timeout: Option<Duration>

超时时间（None = 无限等待）

default_action: BarrierDefaultAction

超时默认行为

Fallback

节点主动声明走备用路径（控制流，非错误）。

与 GraphError::Terminal 不同：Fallback 是节点主动声明的降级策略， executor 根据 fallback 边路由到备用节点。

Fields

deltas: Vec<StateDelta>

状态增量（Fallback 前的修改）

reason: String

降级原因

node_name: String

节点名称

Trait Implementations

impl Debug for StreamNodeResult

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

Formats the value using the given formatter.