Struct BatchProcessor 

pub struct BatchProcessor { /* private fields */ }

Batch processor for processing messages in groups

Implementations

impl BatchProcessor

pub fn new() -> Self

Create a new batch processor with default settings

pub fn with_batch_size(self, size: usize) -> Self

Set the batch size

pub fn with_timeout_ms(self, timeout_ms: u64) -> Self

Set the timeout in milliseconds

pub fn create_batches(&self, messages: Vec<Message>) -> Vec<MessageBatch>

Create batches from a vector of messages

pub fn process<F>( &self, messages: Vec<Message>, callback: F, ) -> Result<(), String>

where F: FnMut(&[Message]) -> Result<(), String>,

Process messages in batches with a callback function

Trait Implementations

impl Default for BatchProcessor

fn default() -> Self

Returns the “default value” for a type.