Struct LogBatch 

pub struct LogBatch { /* private fields */ }

Pre-encoded log.stream.v1.GetResponse stored for a retained sequence batch.

Implementations

impl LogBatch

pub fn from_response_bytes( sequence_number: u64, response_bytes: impl Into<Bytes>, ) -> Self

Wrap protobuf bytes already encoded as log.stream.v1.GetResponse.

pub fn from_entries(sequence_number: u64, kvs: Vec<(Bytes, Bytes)>) -> Self

Build a log batch from key-value pairs.

pub fn from_response(response: StreamGetResponse) -> Self

Build a log batch from an owned response.

pub fn sequence_number(&self) -> u64

Sequence number under which this batch was loaded.

pub fn into_response_bytes(self) -> Bytes

Consume the batch into its pre-encoded response bytes.

pub fn decode_response(&self) -> Result<StreamGetResponse, String>

Decode the stored response for paths that need to inspect entries.

Trait Implementations

impl Clone for LogBatch

fn clone(&self) -> LogBatch

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LogBatch

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

Formats the value using the given formatter.