Struct UnwrappedEnvelope 

pub struct UnwrappedEnvelope {
    pub payload: Value,
    pub reason: Option<String>,
    pub error_kind: Option<String>,
    pub error_message: Option<String>,
    pub record_index: Option<u64>,
    pub pipeline: Option<String>,
    pub row: Option<String>,
    pub sink: Option<String>,
    pub ts_ms: Option<i64>,
}

A DLQ envelope parsed back into its original payload plus the metadata needed to inspect and replay it. Produced by unwrap_envelope.

Fields

payload: Value

The original record that was quarantined — replayed verbatim.

reason: Option<String>

The stage that quarantined the row (build_envelope’s reason field). None for envelopes written before the field existed.

error_kind: Option<String>

The FaucetError variant name (error.kind), e.g. "Sink", "QualityFailure". None if the envelope omits it.

error_message: Option<String>

Human-readable failure message (error.message), if present.

record_index: Option<u64>

Position of the record within its original page.

pipeline: Option<String>

Pipeline name that produced the envelope, if present.

row: Option<String>

Matrix row id that produced the envelope, if present.

sink: Option<String>

Sink name the record was destined for, if present.

ts_ms: Option<i64>

Epoch-millis timestamp the envelope was written, if present.

Trait Implementations

impl Clone for UnwrappedEnvelope

fn clone(&self) -> UnwrappedEnvelope

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for UnwrappedEnvelope

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

Formats the value using the given formatter.

impl PartialEq for UnwrappedEnvelope

fn eq(&self, other: &UnwrappedEnvelope) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for UnwrappedEnvelope