Struct Message 

pub struct Message {
    pub offset: Offset,
    pub data: Bytes,
    pub byte_len: u64,
}

Stored message plus bookkeeping metadata used by storage backends.

Fields

offset: Offset

Message offset (unique identifier within stream)

data: Bytes

Message data

byte_len: u64

Byte length (for memory tracking)

Implementations

impl Message

pub fn new(offset: Offset, data: Bytes) -> Self

Create a stored message and derive its tracked byte length.

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.