Enum TraceEntry 

pub enum TraceEntry {
    StreamMatched {
        stream_name: String,
        event_type: String,
    },
    OperatorResult {
        stream_name: String,
        op_name: String,
        passed: bool,
        detail: Option<String>,
    },
    PatternState {
        stream_name: String,
        active_runs: usize,
        completed: usize,
    },
    EventEmitted {
        stream_name: String,
        fields: Vec<(String, String)>,
    },
}

Trace entry recorded during pipeline execution.

Variants

StreamMatched

Event was routed to a stream for processing.

Fields

stream_name: String

event_type: String

OperatorResult

An operator processed the event.

Fields

stream_name: String

op_name: String

passed: bool

true = event(s) passed through, false = filtered out / empty.

detail: Option<String>

Optional detail (e.g., “temperature=105 > 100”).

PatternState

SASE pattern state changed.

Fields

stream_name: String

active_runs: usize

completed: usize

EventEmitted

Output event emitted from the pipeline.

Fields

stream_name: String

fields: Vec<(String, String)>

Trait Implementations

impl Clone for TraceEntry

fn clone(&self) -> TraceEntry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TraceEntry

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

Formats the value using the given formatter.