Enum ReadOutput

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

Reply which can be a batch of records, or a sequence number if the request could not be satisfied.

Variants

Batch(SequencedRecordBatch)

Batch of records. This batch can be empty only if a ReadLimit was provided in the associated read request, but the first record that could have been returned would violate the limit.

FirstSeqNum(u64)

Sequence number for the first record on this stream, in case the requested start_seq_num is smaller. If returned in a streaming read session, this will be a terminal reply, to signal that there is uncertainty about whether some records may be omitted. The client can re-establish the session starting at this sequence number.

NextSeqNum(u64)

Sequence number for the next record on this stream, in case the requested start_seq_num was larger. If returned in a streaming read session, this will be a terminal reply.

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.