Struct HybridBatcher 

pub struct HybridBatcher<T> { /* private fields */ }

Hybrid batcher that flushes based on time, count, or size thresholds. Whichever threshold is hit first triggers the flush.

Implementations

impl<T> HybridBatcher<T>

pub fn new(config: BatchConfig) -> Self

pub fn push(&mut self, item: T, size_bytes: usize) -> Option<FlushReason>

Add an item to the batch, returns flush reason if threshold hit

pub fn should_flush_time(&self) -> bool

Check if time threshold exceeded

pub fn take_batch(&mut self) -> Vec<T>

Take the current batch for flushing

pub fn is_empty(&self) -> bool

Check if batch is empty

pub fn stats(&self) -> (usize, usize, Duration)

Get current batch stats

impl<T: SizedItem> HybridBatcher<T>

Extension methods for SyncItem batching (avoids orphan rules)

pub fn add(&mut self, item: T) -> Option<FlushReason>

Add an item using its intrinsic size

pub fn add_batch(&mut self, items: Vec<T>)

Add multiple items at once

pub fn take_if_ready(&mut self) -> Option<FlushBatch<T>>

Take the batch if any threshold is ready

pub fn force_flush(&mut self) -> Option<FlushBatch<T>>

Force flush regardless of thresholds (for manual flush or shutdown)

pub fn force_flush_with_reason( &mut self, reason: FlushReason, ) -> Option<FlushBatch<T>>

Force flush with a specific reason

impl<T: BatchableItem> HybridBatcher<T>

Extension methods for batchable items (have ID for contains check)

pub fn contains(&self, id: &str) -> bool

Check if an item with the given ID is in the pending batch.