Struct Record 

pub struct Record {
    pub offset: i64,
    pub timestamp: i64,
    pub key: Option<Bytes>,
    pub value: Option<Bytes>,
    pub headers: Vec<Header>,
}

One record inside a magic-v2 batch.

std::fmt::Display is Java DefaultRecord.toString (key=N bytes; null is 0 bytes, not keySize -1).

Fields

offset: i64

Log offset after decode; relative to the batch base when building with RecordBatch::from_records.

timestamp: i64

Timestamp in milliseconds since the Unix epoch.

key: Option<Bytes>

Optional key.

value: Option<Bytes>

Optional value.

headers: Vec<Header>

Record headers.

Implementations

impl Record

pub const EMPTY_HEADERS: &'static [Header]

Java Record.EMPTY_HEADERS.

pub const MAX_RECORD_OVERHEAD: i32 = 21

Java DefaultRecord.MAX_RECORD_OVERHEAD (max bytes excluding key, value, and headers).

pub fn offset(&self) -> i64

Java Record.offset.

pub fn timestamp(&self) -> i64

Java Record.timestamp.

pub fn key(&self) -> Option<&[u8]>

Java Record.key (None is Java null).

pub fn has_key(&self) -> bool

Java Record.hasKey.

pub fn value(&self) -> Option<&[u8]>

Java Record.value (None is Java null).

pub fn has_value(&self) -> bool

Java Record.hasValue.

pub fn key_size(&self) -> i32

Java Record.keySize (-1 when there is no key).

pub fn value_size(&self) -> i32

Java Record.valueSize (-1 when the value is null).

pub fn headers(&self) -> &[Header]

Java Record.headers.

pub fn last_header(&self, key: &str) -> Option<&Header>

Java Headers.lastHeader.

pub fn headers_for_key<'a>( &'a self, key: &'a str, ) -> impl Iterator<Item = &'a Header> + 'a

Java Headers.headers(String).

pub fn has_magic(&self, magic: i8) -> bool

Java Record.hasMagic. Magic-v2 is true when magic is 2 or greater.

pub fn is_compressed(&self) -> bool

Java DefaultRecord.isCompressed (always false; compression is on the batch).

pub fn has_timestamp_type(&self, _timestamp_type: TimestampType) -> bool

Java DefaultRecord.hasTimestampType (always false; timestamp type is on the batch).

pub fn size_of_body_in_bytes( &self, offset_delta: i32, timestamp_delta: i64, ) -> Result<i32>

Java DefaultRecord.sizeOfBodyInBytes (no length-prefix varint).

offset_delta / timestamp_delta are the magic-v2 relative fields (offset - baseOffset, timestamp - baseTimestamp).

pub fn size_in_bytes( &self, offset_delta: i32, timestamp_delta: i64, ) -> Result<i32>

Java DefaultRecord.sizeInBytes(int, long, ByteBuffer, ByteBuffer, Header[]).

Body size plus the zigzag varint that prefixes the body on the wire.

pub fn record_size_upper_bound(&self) -> Result<i32>

Java DefaultRecord.recordSizeUpperBound (MAX_RECORD_OVERHEAD plus key, value, and headers; not the on-wire size).

pub fn from_end_transaction_marker( timestamp: i64, marker: &EndTransactionMarker, ) -> Result<Self>

Control record for EndTransactionMarker (Java MemoryRecordsBuilder.appendEndTxnMarker).

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 Display 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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for Record