Enum ReadResult 

pub enum ReadResult {
    Events(Vec<CdcEvent>),
    StreamTrimmed {
        cursor: String,
        oldest_id: String,
    },
    Empty,
}

Result of reading from a stream, accounting for trim scenarios.

Variants

Events(Vec<CdcEvent>)

Successfully read events (may be empty if no new events).

StreamTrimmed

Stream was trimmed past our cursor.

This means we’ve missed events and should:

1. Log a warning (potential data gap)
2. Reset cursor to oldest_id
3. Emit a metric for alerting

The cold path (Merkle repair) will eventually fix any gaps.

Fields

cursor: String

Our cursor that’s now invalid

oldest_id: String

The oldest available entry in the stream

Empty

Stream is empty (no entries at all).

Implementations

impl ReadResult

pub fn events(self) -> Vec<CdcEvent>

Get events if this is a successful read, empty vec otherwise.

pub fn is_trimmed(&self) -> bool

Check if the stream was trimmed.

Trait Implementations

impl Debug for ReadResult

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

Formats the value using the given formatter.