Struct BufferedBatchWriter 

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

Generic asynchronous batch writer with threshold, delayed, and overflow flushing.

Implementations

impl<T> BufferedBatchWriter<T>

where T: Send + 'static,

pub fn new<BatchFn, BatchFuture, OneFn, OneFuture>( config: BufferedBatchConfig, write_batch: BatchFn, write_one: OneFn, ) -> Self

where BatchFn: Fn(Vec<T>) -> BatchFuture + Send + Sync + 'static, BatchFuture: Future<Output = ()> + Send + 'static, OneFn: Fn(T) -> OneFuture + Send + Sync + 'static, OneFuture: Future<Output = ()> + Send + 'static,

Creates a writer from product-owned persistence callbacks.

pub async fn record(self: &Arc<Self>, item: T)

Records one item, scheduling a threshold or delayed flush as needed.

pub async fn flush(self: &Arc<Self>)

Flushes the current buffer and schedules any remaining buffered items.

pub fn cancel(&self)

Cancels delayed flush tasks. Call BufferedBatchWriter::flush afterwards during shutdown.