Struct MessageBatch 

pub struct MessageBatch {
    pub buffer: Bytes,
    pub messages: Vec<(usize, usize)>,
    pub ids: Vec<Arc<MessageId>>,
}

Zero-copy message batch for efficient bulk processing

Fields

buffer: Bytes

Contiguous buffer containing all messages

messages: Vec<(usize, usize)>

Offsets and lengths of individual messages

ids: Vec<Arc<MessageId>>

Shared message IDs

Implementations

impl MessageBatch

pub fn new(capacity: usize) -> Self

Create a new message batch

pub fn add(&mut self, id: MessageId, payload: Bytes)

Add a message to the batch

pub fn get(&self, index: usize) -> Option<Bytes>

Get a zero-copy view of a message

pub fn iter(&self) -> impl Iterator<Item = (&Arc<MessageId>, Bytes)> + '_

Iterate over messages without copying

Trait Implementations

impl Debug for MessageBatch

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

Formats the value using the given formatter.