Struct MessageBatch 

pub struct MessageBatch { /* private fields */ }

Batch of messages for efficient processing

Implementations

impl MessageBatch

pub fn new() -> Self

Create a new message batch with default max size (100)

pub fn with_capacity(max_size: usize) -> Self

Create a new message batch with specified max size

pub fn push(&mut self, message: Message) -> bool

Add a message to the batch

Returns true if the message was added, false if the batch is full

pub fn len(&self) -> usize

Get the number of messages in the batch

pub fn is_empty(&self) -> bool

Check if the batch is empty

pub fn is_full(&self) -> bool

Check if the batch is full

pub fn messages(&self) -> &[Message]

Get the messages in the batch

pub fn drain(&mut self) -> Vec<Message>

Take all messages from the batch, leaving it empty

pub fn validate(&self) -> Result<(), ValidationError>

Validate all messages in the batch

pub fn split(self, chunk_size: usize) -> Vec<MessageBatch>

Split the batch into smaller batches of the specified size

pub fn merge(&mut self, other: MessageBatch) -> Vec<Message>

Merge another batch into this one

Returns the messages that didn’t fit if the combined size exceeds max_size

Trait Implementations

impl AsMut<[Message]> for MessageBatch

fn as_mut(&mut self) -> &mut [Message]

Converts this type into a mutable reference of the (usually inferred) input type.

impl AsRef<[Message]> for MessageBatch

fn as_ref(&self) -> &[Message]

Converts this type into a shared reference of the (usually inferred) input type.

impl Clone for MessageBatch

fn clone(&self) -> MessageBatch

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MessageBatch

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

Formats the value using the given formatter.

impl Default for MessageBatch

fn default() -> Self

Returns the “default value” for a type.

impl Extend<Message> for MessageBatch

fn extend<T: IntoIterator<Item = Message>>(&mut self, iter: T)

Extends a collection with the contents of an iterator.

fn extend_one(&mut self, item: A)

🔬This is a nightly-only experimental API. (extend_one)

Extends a collection with exactly one element.

fn extend_reserve(&mut self, additional: usize)

🔬This is a nightly-only experimental API. (extend_one)

Reserves capacity in a collection for the given number of additional elements.

impl FromIterator<Message> for MessageBatch

fn from_iter<T: IntoIterator<Item = Message>>(iter: T) -> Self

Creates a value from an iterator.

impl Index<usize> for MessageBatch

type Output = Message

The returned type after indexing.

fn index(&self, index: usize) -> &Self::Output

Performs the indexing (container[index]) operation.

impl IndexMut<usize> for MessageBatch

fn index_mut(&mut self, index: usize) -> &mut Self::Output

Performs the mutable indexing (container[index]) operation.

impl<'a> IntoIterator for &'a MessageBatch

type Item = &'a Message

The type of the elements being iterated over.

type IntoIter = Iter<'a, Message>

Which kind of iterator are we turning this into?

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value.

impl<'a> IntoIterator for &'a mut MessageBatch

type Item = &'a mut Message

The type of the elements being iterated over.

type IntoIter = IterMut<'a, Message>

Which kind of iterator are we turning this into?

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value.

impl IntoIterator for MessageBatch

type Item = Message

The type of the elements being iterated over.

type IntoIter = IntoIter<Message>

Which kind of iterator are we turning this into?

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value.