Enum ReadResult 

pub enum ReadResult {
    Ok {
        events: Vec<ObservedEvent>,
        next_cursor: u64,
    },
    CursorExpired {
        head_cursor: u64,
        reset_epoch: u64,
    },
}

Outcome of TopicRing::read_since.

Variants

Ok

Zero or more events newer than the requested cursor. next_cursor is the cursor the caller should send on their next poll.

Fields

events: Vec<ObservedEvent>

Events strictly newer than the requested cursor, in insertion order, capped at the requested limit.

next_cursor: u64

Cursor to send on the next poll.

CursorExpired

The caller’s cursor is older than the oldest event still buffered. They must reset to head_cursor - 1 (or 0) and emit a gap.

Fields

head_cursor: u64

Smallest cursor currently buffered. Use head_cursor - 1 (or 0 if head_cursor == 0) as the new since= parameter.

reset_epoch: u64

Current reset_epoch so the caller can detect resets.

Trait Implementations

impl Clone for ReadResult

fn clone(&self) -> ReadResult

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReadResult

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

Formats the value using the given formatter.