Module context_impl 

Functions

aggregate_sink_errors 🔒

Combine per-sink errors from a fan-out into a single anyhow::Error. The first failing sink’s error is used as the source so the original chain is preserved; the message lists every failing sink_id and its error stringified.

resolve_since_timestamp_log_store_epoch 🔒