Enum GraphEvent 

pub enum GraphEvent {
    GraphStart {
        trace_id: TraceId,
    },
    NodeStart {
        node_name: String,
        trace_id: TraceId,
        span_id: SpanId,
        step: usize,
    },
    NodeEnd {
        node_name: String,
        trace_id: TraceId,
        span_id: SpanId,
        success: bool,
        duration: Duration,
    },
    Node {
        span_id: SpanId,
        node_name: String,
        event: FlowEvent,
    },
    BarrierWaiting {
        barrier_id: BarrierId,
        node_name: String,
        span_id: SpanId,
    },
    BarrierResolved {
        barrier_id: BarrierId,
        decision: BarrierDecision,
    },
    ObservedError {
        error: ObservedError,
        node_name: String,
    },
    CheckpointSaved {
        checkpoint_id: CheckpointId,
        node_name: String,
        step: usize,
    },
    GraphComplete {
        result: GraphResult,
    },
    GraphError {
        error: GraphError,
        state: State,
    },
}

Graph 层流式事件。

Variants

GraphStart

Graph 执行开始（恰好一次）

Fields

trace_id: TraceId

NodeStart

节点开始执行

Fields

node_name: String

trace_id: TraceId

span_id: SpanId

step: usize

NodeEnd

节点执行完成

Fields

node_name: String

trace_id: TraceId

span_id: SpanId

success: bool

duration: Duration

Node

节点内部事件（通过 FlowEvent 中间层）

Fields

span_id: SpanId

node_name: String

event: FlowEvent

BarrierWaiting

Barrier 暂停 — 等待外部审批信号。

Fields

barrier_id: BarrierId

node_name: String

span_id: SpanId

BarrierResolved

Barrier 决策已应用

Fields

barrier_id: BarrierId

decision: BarrierDecision

ObservedError

观测错误 — 不影响 control flow

Fields

error: ObservedError

node_name: String

CheckpointSaved

Checkpoint 已保存。

Fields

checkpoint_id: CheckpointId

node_name: String

step: usize

GraphComplete

Graph 执行完成（恰好一次）

Fields

result: GraphResult

GraphError

Graph 执行出错（恰好一次）

Fields

error: GraphError

state: State

Trait Implementations

impl Debug for GraphEvent

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

Formats the value using the given formatter.