Struct RecordBatchMessage 

pub struct RecordBatchMessage {
    pub key: Option<Vec<u8>>,
    pub value: Option<Vec<u8>>,
    pub timestamp_ms: i64,
    pub headers: Vec<RecordBatchHeader>,
}

Fields

key: Option<Vec<u8>>

value: Option<Vec<u8>>

timestamp_ms: i64

headers: Vec<RecordBatchHeader>

Implementations

impl RecordBatchMessage

pub fn new( key: Option<Vec<u8>>, value: Option<Vec<u8>>, timestamp_ms: i64, ) -> Self

pub fn header(self, key: impl Into<String>, value: Option<Vec<u8>>) -> Self

Trait Implementations

impl Clone for RecordBatchMessage

fn clone(&self) -> RecordBatchMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RecordBatchMessage

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

Formats the value using the given formatter.

impl Eq for RecordBatchMessage

impl PartialEq for RecordBatchMessage

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for RecordBatchMessage