Enum PipelineEvent 

pub enum PipelineEvent {
    PipelineStarted {
        pipeline_name: String,
        run_id: String,
    },
    NodeStarted {
        node_id: String,
        handler_type: String,
    },
    NodeCompleted {
        node_id: String,
        status: StageStatus,
        duration_ms: u64,
    },
    EdgeSelected {
        from_node: String,
        to_node: String,
        edge_label: String,
        selection_step: u8,
    },
    RetryScheduled {
        node_id: String,
        attempt: u32,
        max_retries: u32,
        delay_ms: u64,
    },
    GoalGateCheck {
        node_id: String,
        satisfied: bool,
    },
    CheckpointSaved {
        node_id: String,
    },
    PipelineCompleted {
        status: StageStatus,
        total_duration_ms: u64,
        nodes_executed: usize,
    },
    Error {
        node_id: Option<String>,
        message: String,
    },
    HumanInputRequested {
        node_id: String,
        question: String,
        choices: Vec<String>,
    },
    HumanInputReceived {
        node_id: String,
        answer: String,
    },
}

Events emitted during pipeline execution.

Variants

PipelineStarted

Pipeline execution started.

Fields

pipeline_name: String

run_id: String

NodeStarted

A node has started executing.

Fields

node_id: String

handler_type: String

NodeCompleted

A node has completed.

Fields

node_id: String

status: StageStatus

duration_ms: u64

EdgeSelected

An edge was selected for traversal.

Fields

from_node: String

to_node: String

edge_label: String

selection_step: u8

RetryScheduled

A retry is about to happen.

Fields

node_id: String

attempt: u32

max_retries: u32

delay_ms: u64

GoalGateCheck

A goal gate check was performed.

Fields

node_id: String

satisfied: bool

CheckpointSaved

A checkpoint was saved.

Fields

node_id: String

PipelineCompleted

Pipeline execution completed.

Fields

status: StageStatus

total_duration_ms: u64

nodes_executed: usize

Error

An error occurred.

Fields

node_id: Option<String>

message: String

HumanInputRequested

Human input requested.

Fields

node_id: String

question: String

choices: Vec<String>

HumanInputReceived

Human input received.

Fields

node_id: String

answer: String

Implementations

impl PipelineEvent

pub fn pipeline_started(name: &str, run_id: &str) -> Self

pub fn node_started(id: &str, handler: &str) -> Self

pub fn node_completed(id: &str, status: StageStatus, duration_ms: u64) -> Self

pub fn edge_selected(from: &str, to: &str, label: &str, step: u8) -> Self

pub fn error(node_id: Option<&str>, message: &str) -> Self

Trait Implementations

impl Clone for PipelineEvent

fn clone(&self) -> PipelineEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PipelineEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for PipelineEvent

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for PipelineEvent

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.