Enum RunEvent 

pub enum RunEvent {
    PlanResolved(PlanSnapshot),
    PlanWarning {
        rule: String,
        message: String,
    },
    FileWritten {
        file_name: String,
        rows: i64,
        bytes: u64,
        part_index: usize,
    },
    ChunkStarted {
        chunk_index: i64,
        start_key: String,
        end_key: String,
    },
    ChunkCompleted {
        chunk_index: i64,
        rows: i64,
        file_name: Option<String>,
    },
    ChunkFailed {
        chunk_index: i64,
        error: String,
        attempt: i64,
    },
    RetryAttempted {
        attempt: u32,
        reason: String,
        backoff_ms: u64,
    },
    QualityIssue {
        severity: String,
        message: String,
    },
    SchemaChanged {
        added: Vec<String>,
        removed: Vec<String>,
        type_changed: Vec<(String, String, String)>,
    },
    Warning {
        context: String,
        message: String,
    },
    ParallelismAdjusted {
        from: usize,
        to: usize,
        reason: String,
    },
    ValidationResult {
        passed: bool,
    },
    ReconciliationResult {
        source_count: i64,
        exported_rows: i64,
        matched: bool,
    },
    RunCompleted {
        status: String,
        error_message: Option<String>,
        duration_ms: i64,
    },
}

A single typed event emitted during a pipeline run.

Variants are grouped by DoD question:

• Planned — PlanResolved, PlanWarning
• Happened — FileWritten, ChunkStarted, ChunkCompleted, ChunkFailed, RetryAttempted
• Degraded — QualityIssue, SchemaChanged, Warning
• Succeeded — ValidationResult, ReconciliationResult
• Outcome — RunCompleted

Variants

PlanResolved(PlanSnapshot)

Emitted once at the start of a run with a snapshot of the resolved plan.

PlanWarning

A plan validation diagnostic at Warning or Degraded level.

Fields

rule: String

message: String

FileWritten

One output file was successfully written to the destination.

Fields

file_name: String

rows: i64

bytes: u64

part_index: usize

ChunkStarted

A chunk task transitioned from pending to running.

Fields

chunk_index: i64

start_key: String

end_key: String

ChunkCompleted

A chunk task completed successfully.

Fields

chunk_index: i64

rows: i64

file_name: Option<String>

ChunkFailed

A chunk task failed (may be retried up to max_chunk_attempts).

Fields

chunk_index: i64

error: String

attempt: i64

RetryAttempted

The pipeline is about to retry after a transient error.

Fields

attempt: u32

reason: String

backoff_ms: u64

QualityIssue

One quality rule fired (severity: "FAIL" or "WARN").

Fields

severity: String

message: String

SchemaChanged

The output schema differs from the previously stored snapshot.

Fields

added: Vec<String>

Columns added since the last run, formatted as "name (type)".

removed: Vec<String>

Column names removed since the last run.

type_changed: Vec<(String, String, String)>

(column, old_type, new_type) for columns whose type changed.

Warning

A non-fatal warning that does not fit another variant.

Fields

context: String

message: String

ParallelismAdjusted

The OPT-2 concurrency governor changed the active parallelism in response to source pressure. from/to are permit counts; reason describes the trigger (e.g. "pressure rising: backed off").

Fields

from: usize

to: usize

reason: String

ValidationResult

Output file row-count validation completed.

Fields

passed: bool

ReconciliationResult

Source COUNT(*) reconciliation completed.

Fields

source_count: i64

exported_rows: i64

matched: bool

RunCompleted

Terminal event — the run has reached its final state.

Fields

status: String

error_message: Option<String>

duration_ms: i64

Trait Implementations

impl Clone for RunEvent

fn clone(&self) -> RunEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RunEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RunEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for RunEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.