Struct ChainCtx 

#[non_exhaustive]
pub struct ChainCtx {
    pub thread: usize,
    pub queues: ShardQueues,
    pub budget: Arc<InflightBudget>,
    pub pipeline: String,
}

Per-thread wiring handed to the chain factory — everything the terminal .sink(...) stage needs, so assemblies stop threading queues, budget, and the pipeline name by hand.

Passed by value, once per pipeline thread; move the fields into the chain being built. Deliberately not Clone — see the module docs on drop ordering.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

thread: usize

Zero-based pipeline thread index.

queues: ShardQueues

This thread’s clone of the shard-queue senders.

budget: Arc<InflightBudget>

The shared in-flight byte budget.

pipeline: String

The pipeline name — ChainBuilder::with_metrics’s first argument.

Trait Implementations

impl Debug for ChainCtx

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

Formats the value using the given formatter.