Struct Record 

pub struct Record {
    pub attributes: i8,
    pub timestamp_delta: i64,
    pub offset_delta: i32,
    pub key: Option<Bytes>,
    pub value: Option<Bytes>,
    pub headers: Vec<RecordHeader>,
}

A single record in a v2 crate::record::RecordBatch.

Fields

attributes: i8

Reserved — currently always 0.

timestamp_delta: i64

Signed varlong delta from the batch’s first_timestamp.

offset_delta: i32

Signed varint delta from the batch’s base_offset.

key: Option<Bytes>

Record key. None when the on-wire key length is -1.

value: Option<Bytes>

Record value. None when the on-wire value length is -1.

headers: Vec<RecordHeader>

Record headers.

Implementations

impl Record

pub fn encoded_len(&self) -> Result<usize>

Return the exact encoded length of this record, including its body length prefix.

pub fn encode(&self, buf: &mut BytesMut) -> Result<()>

Encode this record into buf — body length + body bytes.

pub fn decode(buf: &mut Bytes) -> Result<Self>

Decode one record from buf. Validates that the body length fits in the remaining buffer before splitting.

Trait Implementations

impl Clone for Record

fn clone(&self) -> Record

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Record

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

Formats the value using the given formatter.

impl Eq for Record

impl PartialEq for Record

fn eq(&self, other: &Record) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for Record