Struct ReadBatch 

pub struct ReadBatch {
    pub records: Vec<SequencedRecord>,
    pub tail: Option<StreamPosition>,
}

Fields

records: Vec<SequencedRecord>

Records that are durably sequenced on the stream, retrieved based on the requested criteria. This can only be empty in response to a unary read (i.e. not SSE), if the request cannot be satisfied without violating an explicit bound (count, bytes, or until).

tail: Option<StreamPosition>

Sequence number that will be assigned to the next record on the stream, and timestamp of the last record. This will only be present when reading recent records.

Implementations

impl ReadBatch

pub fn encode(format: Format, batch: ReadBatch) -> Self

Trait Implementations

impl Clone for ReadBatch

fn clone(&self) -> ReadBatch

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReadBatch

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

Formats the value using the given formatter.

impl Serialize for ReadBatch

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.