Struct MessageData 

pub struct MessageData {
    pub offset: u64,
    pub partition: u32,
    pub key: Option<Bytes>,
    pub value: Bytes,
    pub timestamp: i64,
    pub headers: Vec<(String, Vec<u8>)>,
}

Serialized message data for transport

Fields

offset: u64

Message offset in the partition

partition: u32

Partition the message belongs to

key: Option<Bytes>

Optional message key

value: Bytes

Message value/payload

timestamp: i64

Timestamp in milliseconds since epoch

headers: Vec<(String, Vec<u8>)>

Record headers (key-value metadata)

Implementations

impl MessageData

pub fn new(offset: u64, value: impl Into<Bytes>, timestamp: i64) -> MessageData

Create a new message

pub fn with_key(self, key: impl Into<Bytes>) -> MessageData

Set the key

pub fn with_partition(self, partition: u32) -> MessageData

Set the partition

pub fn with_header( self, key: impl Into<String>, value: impl Into<Vec<u8>>, ) -> MessageData

Add a header

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

Get the value as bytes

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

Get the key as bytes if present

pub fn size(&self) -> usize

Get the size of this message (key + value + headers)

Trait Implementations

impl Clone for MessageData

fn clone(&self) -> MessageData

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MessageData

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for MessageData

fn deserialize<__D>( __deserializer: __D, ) -> Result<MessageData, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for MessageData

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

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for MessageData

impl StructuralPartialEq for MessageData