Struct ClickHouseWriter 

pub struct ClickHouseWriter { /* private fields */ }

Background ClickHouse writer with bounded-channel backpressure.

Created via ClickHouseWriter::new. Batches are sent to the background thread via send. Call shutdown to drain the channel and wait for completion.

Implementations

impl ClickHouseWriter

pub fn new( config: ClickHouseConfig, capacity: usize, ) -> Result<Self, ClickHouseError>

Create a new writer with bounded channel of capacity batches for backpressure.

Spawns a background thread that drains the channel and sends batches to ClickHouse.

pub fn send(&self, batch: RecordBatch) -> Result<(), ClickHouseError>

Send a batch to the background writer.

Blocks if the channel is full (backpressure).

pub fn metrics(&self) -> WriterMetricsSnapshot

Snapshot current writer metrics without shutting the writer down.

pub fn shutdown(self) -> WriterStats

Shutdown the writer, drain remaining batches, and return statistics.