Struct BatchCollector 

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

Implementations

impl<T: Clone> BatchCollector<T>

pub fn new(config: BatchConfig) -> Self

pub fn add(&self, item: BatchItem<T>) -> BatchAddResult

pub fn add_data(&self, data: T) -> BatchAddResult

pub fn should_flush(&self) -> bool

pub fn drain(&self) -> Vec<BatchItem<T>>

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn clear(&self)