Struct Batch 

pub struct Batch<'a, P: Payload> { /* private fields */ }

A thin batch view over a slice of messages.

Batch formation is runtime-specific; the core only provides a convenient immutable view for policies and telemetry.

Implementations

impl<'a, P: Payload> Batch<'a, P>

pub const fn new(messages: &'a [Message<P>]) -> Self

Construct a new batch view over a slice of messages.

pub fn messages(&self) -> &'a [Message<P>]

Return the underlying messages slice.

pub fn len(&self) -> usize

Return the number of messages in the batch.

pub fn is_empty(&self) -> bool

Return true if the batch is empty.

pub fn total_payload_bytes(&self) -> usize

Total byte size across message payloads.

pub fn iter(&self) -> Iter<'_, Message<P>>

Iterate over messages.

pub fn first_flagged(&self) -> bool

Convenience: is the first message marked FIRST_IN_BATCH (if present)?

pub fn last_flagged(&self) -> bool

Convenience: is the last message marked LAST_IN_BATCH (if present)?

pub fn assert_flags_consistent(&self)

(Optional) Validate flags are consistent with batch boundaries. Enable only when you want assertions (e.g., in tests) via a feature flag.

Trait Implementations

impl<'a, P: Clone + Payload> Clone for Batch<'a, P>

fn clone(&self) -> Batch<'a, P>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a, P: Debug + Payload> Debug for Batch<'a, P>

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

Formats the value using the given formatter.

impl<'a, P: Payload> Payload for &'a Batch<'a, P>

fn buffer_descriptor(&self) -> BufferDescriptor

Return a descriptor containing the byte size of this payload.

impl<'a, P: Payload> Payload for Batch<'a, P>

fn buffer_descriptor(&self) -> BufferDescriptor

Return a descriptor containing the byte size of this payload.

impl<'a, P: Copy + Payload> Copy for Batch<'a, P>