Skip to main content

flush_once

client_core::sync::backlog_flusher

Function flush_once 

Source 
pub async fn flush_once(
    store: &Store,
    client: &RestClient,
    enc_key: [u8; 32],
) -> Result<FlushReport, FlushError>
Expand description

Push every synced=false clip in created_at ASC order. Stops on the first transient (5xx / Network) error; drops rows on permanent (4xx / Decode) errors; drops rows whose plaintext content is missing (media-only).

Idempotent via idempotency_key = clip.id — relay-side dedup absorbs retries from interrupted flushes.