Struct SinkRuntime 

pub struct SinkRuntime {
    pub queues: ShardQueues,
    pub drain: Box<dyn FnOnce(Duration) -> Pin<Box<dyn Future<Output = DrainReport> + Send>> + Send>,
    pub probe: Option<Box<dyn Fn() -> Pin<Box<dyn Future<Output = Result<(), SinkError>> + Send>> + Sync + Send>>,
}

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: Box<dyn FnOnce(Duration) -> Pin<Box<dyn Future<Output = DrainReport> + Send>> + Send>

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

probe: Option<Box<dyn Fn() -> Pin<Box<dyn Future<Output = Result<(), SinkError>> + Send>> + Sync + Send>>

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<(), Error>

Formats the value using the given formatter.