Skip to main content

SinkBundle

etl_core::sink

Trait SinkBundle 

Source 
pub trait SinkBundle {
    type Writer: ShardWriter;

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

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§

Source

type Writer: ShardWriter

The connector’s ShardWriter implementation.

Required Methods§

Source

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

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

Implementors§