async fn run_loop(
name: String,
cfg: BatchConfig,
flusher: Arc<dyn BatchFlusher>,
rx: Receiver<Value>,
)Expand description
The background flush loop: buffers entries from rx and flushes on size,
inactivity, age, or channel close (drain-on-drop).