Struct SplitTarget 

#[non_exhaustive]
pub struct SplitTarget { /* private fields */ }

The per-sink handles a split branch needs, resolved by name from the chain factory’s ChainCtx via ChainCtx::sink. The bundle carries the sink’s name, so SplitBuilder::add does not repeat it.

Implementations

impl SplitTarget

pub fn new( name: String, queues: ShardQueues, budget: Arc<InflightBudget>, ) -> Self

Bundle a named sink’s queues and the shared in-flight budget. Chunking starts at ChunkConfig::default; override it with with_chunk. (Builder pipelines do not call this; ChainCtx::sink hands out a fully resolved SplitTarget.)

pub fn with_chunk(self, chunk: ChunkConfig) -> Self

Set this branch’s terminal-stage chunking, the manual-assembly counterpart to the per-sink YAML chunk: block.

Trait Implementations

impl Clone for SplitTarget

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SplitTarget

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

Formats the value using the given formatter.