Struct BatchEncoder 

pub struct BatchEncoder { /* private fields */ }

Batch encoder for high-throughput message encoding

Implementations

impl BatchEncoder

pub fn new() -> Self

Create a new batch encoder with default capacity

pub fn with_capacity(capacity: usize) -> Self

Create a new batch encoder with specified capacity

pub fn add_message(&mut self, key: Option<&[u8]>, value: &[u8], timestamp: i64)

Add a message to the batch

pub fn add_messages(&mut self, messages: &[BatchMessage])

Add multiple messages efficiently

pub fn finish(self) -> Bytes

Finish encoding and return the buffer

pub fn len(&self) -> usize

Get current encoded size

pub fn is_empty(&self) -> bool

Check if buffer is empty

pub fn message_count(&self) -> usize

Get number of messages encoded

pub fn reset(&mut self)

Reset encoder for reuse

pub fn stats(&self) -> EncoderStatsSnapshot

Get encoder statistics

Trait Implementations

impl Default for BatchEncoder

fn default() -> Self

Returns the “default value” for a type.