Struct SinkRuntime 

pub struct SinkRuntime {
    pub queues: ShardQueues,
    pub drain: SinkDrainFn,
    pub probe: Option<SinkProbeFn>,
}

The sink half the runtime drives: the shared shard-queue handle plus a drain hook invoked once at shutdown with the remaining drain budget.

Built by the sink layer (SinkPool) or by tests; the runtime is deliberately ignorant of worker internals.

Fields

queues: ShardQueues

Sending side of the per-shard chunk queues (the runtime only uses capacity introspection; the chain’s terminal stage holds clones).

drain: SinkDrainFn

Drain the sink: flush what’s pending within the budget, fail the acknowledgements of anything abandoned, and report.

probe: Option<SinkProbeFn>

Optional connectivity probe (e.g. SinkPool::probe_all). The runtime probes at startup and then periodically, driving the sinks-connected half of /readyz. Without a probe the flag is set unconditionally.

Trait Implementations

impl Debug for SinkRuntime

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

Formats the value using the given formatter.