Struct BatchProcessor 

pub struct BatchProcessor { /* private fields */ }

O(1) batch processor for fixed-size batch accumulation.

Accumulates items until batch is full, then signals ready for processing. Common pattern for batching network writes, disk flushes, metric exports.

Implementations

impl BatchProcessor

pub fn new(batch_size: u64) -> Self

Create with specified batch size

pub fn for_network() -> Self

Create for network operations (batch size 1000)

pub fn for_disk() -> Self

Create for disk operations (batch size 100)

pub fn for_metrics() -> Self

Create for metrics export (batch size 50)

pub fn add(&mut self) -> bool

Add item to batch, returns true if batch is now full

pub fn add_many(&mut self, n: u64) -> u64

Add multiple items, returns number of batches completed

pub fn is_ready(&self) -> bool

Check if batch is ready (full)

pub fn fill_percentage(&self) -> f64

Get current batch fill percentage

pub fn remaining(&self) -> u64

Get items remaining until full batch

pub fn batches_completed(&self) -> u64

Get total batches completed

pub fn total_items(&self) -> u64

Get total items processed

pub fn flush(&mut self)

Flush current batch (mark complete regardless of count)

pub fn reset(&mut self)

Reset all counters

Trait Implementations

impl Clone for BatchProcessor

fn clone(&self) -> BatchProcessor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BatchProcessor

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

Formats the value using the given formatter.

impl Default for BatchProcessor

fn default() -> Self

Returns the “default value” for a type.