Struct BatcherHandle 

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

A handle to the background batcher worker.

This handle is cheap to clone and can be shared across threads. It provides methods to insert rows and control the batcher lifecycle.

Implementations

impl<T: ClickInsertable + Send + 'static> BatcherHandle<T>

pub async fn insert(&self, row: T) -> Result<()>

Insert a single row into the batch.

This method waits if the internal channel is full (Backpressure). Use this for data integrity when you want to slow down the producer rather than dropping data.

Errors

Returns an error if the batcher worker has terminated.

pub fn try_insert(&self, row: T) -> Result<()>

Try to insert a single row without blocking.

This method fails immediately if the channel is full (Load Shedding). Use this for high-availability scenarios where dropping data is preferable to blocking the application.

Errors

Returns Channel full if the channel is at capacity. Returns Channel closed if the worker has terminated.

pub async fn insert_many(&self, rows: Vec<T>) -> Result<()>

Insert multiple rows into the batch.

This treats the vector as a single unit for channel capacity purposes.

pub async fn flush(&self) -> Result<FlushStats>

Force a flush of the current buffer and wait for completion.

This ensures all data currently in the buffer is sent to ClickHouse.

pub async fn close(self) -> Result<()>

Close the batcher and flush remaining data.

This signals the worker to finish processing pending items, flush the buffer, and then terminate.

Trait Implementations

impl<T: Clone> Clone for BatcherHandle<T>

fn clone(&self) -> BatcherHandle<T>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.