Skip to main content

run_loop

Function run_loop 

Source
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).