Enum RuntimeEvent 

pub enum RuntimeEvent {
    ExecutionStarted {
        trace_id: TraceId,
        graph_name: String,
    },
    NodeStarted {
        node_name: String,
        trace_id: TraceId,
        span_id: SpanId,
        step: usize,
    },
    NodeCompleted {
        node_name: String,
        trace_id: TraceId,
        span_id: SpanId,
        duration: Duration,
    },
    NodeFailed {
        node_name: String,
        trace_id: TraceId,
        span_id: SpanId,
        error: String,
    },
    BranchStarted {
        node_name: String,
        branch_name: String,
        span_id: SpanId,
    },
    BranchCompleted {
        node_name: String,
        branch_name: String,
        span_id: SpanId,
        success: bool,
        duration: Duration,
    },
    BarrierWaiting {
        barrier_id: BarrierId,
        node_name: String,
        span_id: SpanId,
    },
    BarrierResolved {
        barrier_id: BarrierId,
    },
    CheckpointCreated {
        checkpoint_id: CheckpointId,
        node_name: String,
        step: usize,
    },
    ExecutionCompleted {
        trace_id: TraceId,
        duration: Duration,
    },
}

控制面事件 — 低频、生命周期事件。

Variants

ExecutionStarted

执行开始

Fields

trace_id: TraceId

graph_name: String

NodeStarted

节点开始执行

Fields

node_name: String

trace_id: TraceId

span_id: SpanId

step: usize

NodeCompleted

节点执行完成

Fields

node_name: String

trace_id: TraceId

span_id: SpanId

duration: Duration

NodeFailed

节点执行失败

Fields

node_name: String

trace_id: TraceId

span_id: SpanId

error: String

BranchStarted

分支开始执行（并行节点）

Fields

node_name: String

branch_name: String

span_id: SpanId

BranchCompleted

分支执行完成（并行节点）

Fields

node_name: String

branch_name: String

span_id: SpanId

success: bool

duration: Duration

BarrierWaiting

Barrier 等待外部决策

Fields

barrier_id: BarrierId

node_name: String

span_id: SpanId

BarrierResolved

Barrier 决策已应用

Fields

barrier_id: BarrierId

CheckpointCreated

Checkpoint 已保存

Fields

checkpoint_id: CheckpointId

node_name: String

step: usize

ExecutionCompleted

执行完成

Fields

trace_id: TraceId

duration: Duration

Trait Implementations

impl Clone for RuntimeEvent

fn clone(&self) -> RuntimeEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RuntimeEvent

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

Formats the value using the given formatter.