Struct MessageBatch 

pub struct MessageBatch<T> {
    pub id: String,
    pub messages: Vec<ReceivedBatchMessage<T>>,
    pub created_at: Instant,
    pub metadata: BatchMetadata,
}

A batch of messages to be processed together.

Fields

id: String

Unique identifier for this batch

messages: Vec<ReceivedBatchMessage<T>>

Messages in this batch

created_at: Instant

When this batch was created

metadata: BatchMetadata

Metadata about the batch

Implementations

impl<T> MessageBatch<T>

pub fn new(id: String, messages: Vec<ReceivedBatchMessage<T>>) -> Self

Create a new message batch

pub fn len(&self) -> usize

Get the number of messages in this batch

pub fn is_empty(&self) -> bool

Check if batch is empty

pub fn age(&self) -> Duration

Get batch age

Trait Implementations

impl<T> Clone for MessageBatch<T>

where T: Clone,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for MessageBatch<T>

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

Formats the value using the given formatter.