Trait SinkBundle 

pub trait SinkBundle {
    type Writer: ShardWriter;

    // Required method
    fn into_parts(self) -> SinkParts<Self::Writer>;
}

A sink ready for assembly: the writer, the shard/replica topology, pool tuning, and optional metadata (metric labels, readiness probe).

Consumed once by the pipeline builder, which turns it into shard queues, per-shard metrics, and a spawned SinkPool.

Required Associated Types

type Writer: ShardWriter

The connector’s ShardWriter implementation.

Required Methods

fn into_parts(self) -> SinkParts<Self::Writer>

Decompose into the parts the builder wires up. Consuming: the endpoints move into the sink pool.

Implementations on Foreign Types

impl SinkBundle for ClickHouseSink

type Writer = ClickHouseWriter

fn into_parts(self) -> SinkParts<ClickHouseWriter>

Implementors

impl<W> SinkBundle for SinkParts<W>

where W: ShardWriter,

type Writer = W