Enum ReadOutput

pub enum ReadOutput {
    Batch(SequencedRecordBatch),
    FirstSeqNum(u64),
    NextSeqNum(u64),
}

Batch of records, or a sequence number if the read could not be satisfied. An empty batch or a sequence number output will be a terminal message in a session.

Variants

Batch(SequencedRecordBatch)

Batch of records. It can only be empty when not in a session context (which implies a limit), if the first record that could have been retrieved would violate the limit.

FirstSeqNum(u64)

Sequence number for the first record on this stream. Typically this will be returned when the requested start_seq_num was smaller. It may also be returned during a session, if the stream gets concurrently trimmed.

NextSeqNum(u64)

Sequence number that will be assigned to the next record on this stream. This will be returned either because the requested start_seq_num was larger, or in case of a limited read, equal to it.

Trait Implementations

impl Clone for ReadOutput

fn clone(&self) -> ReadOutput

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ReadOutput

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

Formats the value using the given formatter.