Struct Message 

pub struct Message { /* private fields */ }

The Message frame contains information required to parse the message, a calculated CRC used to verify message integrity, and the encoded records.

Implementations

impl Message

pub fn new(headers: Headers, records: &[u8], crc: u32) -> Self

Constructs a Message instance with the provided Headers, records batch and CRC.

pub fn single(records: &[u8], version: u32) -> Self

Shorthand method for constructing a Message instance with a batch size of 1.

pub fn batch(records: &[u8], batch_size: u32, version: u32) -> Self

Shorthand method for constructing a Message instance with a provided batch size.

pub fn encode(&self, buffer: &mut Vec<u8>)

Encodes this Message instance into the provided buffer.

pub fn headers(&self) -> &Headers

The message headers containing information about the records batch.

pub fn records(&self) -> &[u8]

The encoded records batch.

Trait Implementations

impl Clone for Message

fn clone(&self) -> Message

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Message

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

Formats the value using the given formatter.

impl PartialEq for Message

fn eq(&self, other: &Message) -> 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 Message