Enum FlowEvent 

pub enum FlowEvent {
    NodeStarted {
        node_id: String,
        span_id: SpanId,
    },
    NodeCompleted {
        node_id: String,
        span_id: SpanId,
        duration: Duration,
    },
    NodeFailed {
        node_id: String,
        error: String,
    },
    StateChanged {
        node_id: String,
        key: String,
        value: Value,
    },
    ParallelStarted {
        node_id: String,
        branch_count: usize,
        span_id: SpanId,
    },
    ParallelCompleted {
        node_id: String,
        span_id: SpanId,
        duration: Duration,
    },
    BranchCompleted {
        branch_name: String,
        node_id: String,
        span_id: SpanId,
        success: bool,
        duration: Duration,
    },
    Custom {
        node_id: String,
        payload: Box<dyn Any + Send + Sync>,
    },
}

节点内部事件 — 解耦的通用事件中间层。

Variants

NodeStarted

节点开始执行

Fields

node_id: String

span_id: SpanId

NodeCompleted

节点执行完成

Fields

node_id: String

span_id: SpanId

duration: Duration

NodeFailed

节点执行失败

Fields

node_id: String

error: String

StateChanged

状态变更

Fields

node_id: String

key: String

value: Value

ParallelStarted

并行节点开始执行

Fields

node_id: String

branch_count: usize

span_id: SpanId

ParallelCompleted

并行节点执行完成

Fields

node_id: String

span_id: SpanId

duration: Duration

BranchCompleted

并行分支执行完成

Fields

branch_name: String

node_id: String

span_id: SpanId

success: bool

duration: Duration

Custom

自定义事件 — 具体节点类型通过此变体注入内部事件。

Fields

node_id: String

payload: Box<dyn Any + Send + Sync>

Trait Implementations

impl Debug for FlowEvent

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

Formats the value using the given formatter.