Skip to main content

flush_with_retry

Function flush_with_retry 

Source
async fn flush_with_retry(
    name: &str,
    cfg: &BatchConfig,
    flusher: &Arc<dyn BatchFlusher>,
    buffer: &mut Vec<Value>,
)
Expand description

Flushes buffer, retrying per cfg on failure. Honours first_fail by dropping the delivered head and retrying only the tail. Entries arriving during a retry sleep simply queue in the channel and form the next batch. When retries are exhausted, the remaining entries are dropped with a tracing::error!.