Struct AdaptiveBatcher 

pub struct AdaptiveBatcher { /* private fields */ }

Adaptive batch size calculator.

Tracks recent ingestion velocity and adjusts batch size accordingly.

Implementations

impl AdaptiveBatcher

pub fn new(config: BatchConfig) -> Self

Create a new adaptive batcher.

pub fn record_events(&mut self, count: usize) -> usize

Record events and get the current target batch size.

Call this each time events are drained from the ring buffer.

pub fn batch_size(&self) -> usize

Get the current target batch size.

pub fn reset(&mut self)

Reset the batcher state.