Struct InsertBatcher 

pub struct InsertBatcher { /* private fields */ }

INSERT Batcher

Batches INSERT statements for improved throughput.

Implementations

impl InsertBatcher

pub fn new(config: BatchConfig) -> Self

Create a new INSERT batcher

pub fn with_backend(self, backend: BackendConfig) -> Self

Attach the backend the combined INSERTs execute against. Without it the batcher seals and combines but cannot run the SQL.

pub fn add( self: &Arc<Self>, table: String, columns: Vec<String>, values: Vec<Vec<String>>, original_sql: String, ) -> Result<BatchTicket, BatchError>

Add an INSERT to the batch.

Takes &Arc<Self> so a size-triggered flush can seal the batch synchronously (callers observing batch_size see it drop immediately) and then execute the combined INSERT for real on a spawned task. Must be called from within a Tokio runtime.

pub async fn flush_batch(&self, table: &str)

Flush a single table’s batch: seal it and execute the combined INSERT against the backend.

pub async fn flush_all(&self)

Flush all pending batches, executing each combined INSERT.

pub fn batch_size(&self, table: &str) -> usize

Get the current batch size for a table

pub fn stats(&self) -> BatchStats

Get statistics snapshot

pub async fn shutdown(&self)

Shutdown the batcher: stop accepting work and flush whatever is pending (executing each combined INSERT).

pub fn start_auto_flush(self: Arc<Self>) -> JoinHandle<()>

Start auto-flush background task