Enum StreamLine 

pub enum StreamLine {
    Sample(IngestRow),
    Meta(String),
}

One line of an explorer ndjson stream, as the input side reads it.

A stream interleaves its samples with tagged non-sample rows — {"row": "dropped",…} where the bus outran the observer (RFC 09 §5.1 O6), {"row":"seed",…} at the seed boundary — and a consumer that wants the samples must tell those apart from a row it cannot parse: metadata is skipped and counted as skipped, a malformed row is an error naming the reason. Before this split, echo’s own honesty lines poisoned the echo | pub --from ndjson round trip the dialect exists for (#235).

Variants

Sample(IngestRow)

A publishable sample row.

Meta(String)

A tagged non-sample row; the value is the "row" tag ("dropped", "seed", …). Stream metadata — skip it, count the skip.

Trait Implementations

impl Clone for StreamLine

fn clone(&self) -> StreamLine

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamLine

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

Formats the value using the given formatter.

impl Eq for StreamLine

impl PartialEq for StreamLine

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for StreamLine