Enum FlowEvent 

pub enum FlowEvent {
    FlowStarted {
        execution_id: Uuid,
    },
    FlowCompleted {
        execution_id: Uuid,
        result: FlowResult,
    },
    FlowFailed {
        execution_id: Uuid,
        reason: String,
    },
    FlowTerminated {
        execution_id: Uuid,
    },
    NodeStarted {
        execution_id: Uuid,
        node_id: String,
        node_type: String,
    },
    NodeCompleted {
        execution_id: Uuid,
        node_id: String,
        output: Value,
    },
    NodeSkipped {
        execution_id: Uuid,
        node_id: String,
    },
    NodeFailed {
        execution_id: Uuid,
        node_id: String,
        reason: String,
    },
}

A snapshot of a single lifecycle event emitted during flow execution.

Produced by FlowEngine::start_streaming via a tokio::sync::broadcast channel. All variants are Clone so they can be forwarded to multiple subscribers.

Variants

FlowStarted

A flow execution started.

Fields

execution_id: Uuid

FlowCompleted

A flow execution completed successfully.

Fields

execution_id: Uuid

result: FlowResult

FlowFailed

A flow execution failed (node error or internal error).

Fields

execution_id: Uuid

reason: String

FlowTerminated

A flow execution was terminated externally.

Fields

execution_id: Uuid

NodeStarted

A node is about to execute.

Fields

execution_id: Uuid

node_id: String

node_type: String

NodeCompleted

A node completed successfully.

Fields

execution_id: Uuid

node_id: String

output: Value

NodeSkipped

A node was skipped because its run_if guard evaluated to false.

Fields

execution_id: Uuid

node_id: String

NodeFailed

A node failed (all retry attempts exhausted).

Fields

execution_id: Uuid

node_id: String

reason: String

Trait Implementations

impl Clone for FlowEvent

fn clone(&self) -> FlowEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FlowEvent

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

Formats the value using the given formatter.