Struct BatchWriter 

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

Performance optimization utilities

Inspired by SierraDB’s focus on high-throughput operations.

Design Principles

• Batch operations for reduced overhead
• Minimal allocations
• Zero-copy where possible
• Lock-free when feasible Batch writer for high-throughput ingestion

Accumulates items in a buffer and flushes when:

• Buffer reaches capacity
• Time threshold exceeded
• Explicit flush called

Example

let mut writer = BatchWriter::new(100, Duration::from_millis(100));
writer.add(item)?;
if writer.should_flush() {
    writer.flush()?;
}

Implementations

impl<T> BatchWriter<T>

pub fn new(capacity: usize, flush_interval: Duration) -> Self

Create new batch writer

Arguments

• capacity: Maximum items before auto-flush
• flush_interval: Maximum time between flushes

pub fn add(&mut self, item: T)

Add item to buffer

pub fn should_flush(&self) -> bool

Check if buffer should be flushed

pub fn len(&self) -> usize

Get current buffer size

pub fn is_empty(&self) -> bool

Check if buffer is empty

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

Flush buffer and return items

pub fn time_since_flush(&self) -> Duration

Get time since last flush