Struct BatchProcessor 

pub struct BatchProcessor { /* private fields */ }

Batch processor that assembles messages into batches and processes them

Implementations

impl BatchProcessor

pub fn new(handler: Arc<dyn BatchHandler>, config: BatchConfig) -> Self

Create a new batch processor

pub async fn start(&mut self) -> WorkerResult<()>

Start the batch processor background task

pub async fn enqueue(&self, message: ReceivedMessage<Value>) -> WorkerResult<()>

Add a message to the batch queue

pub async fn shutdown(&self) -> WorkerResult<()>

Shutdown the batch processor gracefully