Enum RecordRef 

pub enum RecordRef<'a> {
    Lean {
        batch: &'a LeanBatch,
        record: &'a LeanRecord,
    },
    Full(&'a Record),
}

One record, without a record having been built for it.

A key, value or header list is materialised when asked for, not at decode time — which is the point: every slice of a batch buffer increments the same atomic refcount, so a caller that skips a record should not pay for it.

Variants

Lean

Fields

batch: &'a LeanBatch

record: &'a LeanRecord

Full(&'a Record)

From a batch the lean reader handed back.

Implementations

impl RecordRef<'_>

pub fn offset(&self) -> i64

pub fn timestamp(&self) -> i64

pub fn key(&self) -> Option<Bytes>

pub fn value(&self) -> Option<Bytes>

pub fn headers(&self) -> Result<Vec<(Bytes, Option<Bytes>)>>

Errors

If the header block is malformed.

Trait Implementations

impl<'a> Clone for RecordRef<'a>

fn clone(&self) -> RecordRef<'a>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Copy for RecordRef<'a>

impl<'a> Debug for RecordRef<'a>

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

Formats the value using the given formatter.