Struct ClickHouseWriter 

pub struct ClickHouseWriter { /* private fields */ }

Writes sealed batches: one INSERT ... FORMAT <fmt> per batch (the format — RowBinary or Native — is baked into insert_sql), carrying the batch’s deduplication token so retries — including on other replicas — are idempotent within the server’s dedup window. The transport is format-agnostic: frames concatenate to the request body (RowBinary rows or a stream of Native blocks). write_batch returning Ok is the durable-ack point (the server confirmed the insert, materialized views included, thanks to wait_end_of_query=1).

Implementations

impl ClickHouseWriter

pub fn insert_sql(&self) -> &str

The exact INSERT statement this writer issues.

Trait Implementations

impl Clone for ClickHouseWriter

fn clone(&self) -> ClickHouseWriter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ClickHouseWriter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl ShardWriter for ClickHouseWriter

type Endpoint = ClickHouseEndpoint

A connected replica endpoint (e.g. one HTTP client per replica).

async fn write_batch( &self, endpoint: &ClickHouseEndpoint, batch: &SealedBatch, ) -> Result<(), SinkError>

Write batch to endpoint durably.

async fn probe(&self, endpoint: &ClickHouseEndpoint) -> Result<(), SinkError>

Connectivity probe for readiness. Defaults to healthy.

fn attach_metrics(&mut self, meter: Option<Meter>)

Receive a Meter scoped spate_<component_type>_sink_* for the sink’s own metric families, pre-labelled with the standard pipeline/component/component_type. Called once by the builder before the writer is shared across shard workers; resolve handles here and store them (they are Arc-backed, so write_batch’s &self can touch them). None when the sink’s component_type cannot scope a family: the default "custom" (reserved for pipeline-author metrics) or a reserved root opts out silently, and a malformed value is logged and also yields None — so declare a distinct component_type via SinkParts::with_component_type to receive a scope. Defaults to ignoring it.