Skip to main content

client_core/sync/
mod.rs

1//! Sync layer — writer (long-lived WS) and reader (short-lived REST backfill).
2//! Lockfile coordinates at most one writer per machine.
3
4pub mod backlog_flusher;
5pub mod local_pusher;
6pub mod lockfile;
7pub mod map;
8pub mod reader;
9pub mod writer;
10
11pub use backlog_flusher::{
12    enqueue_local, flush_once, format_rfc3339_millis, FlushError, FlushGate, FlushGuard,
13    FlushReport, MAX_UNSYNCED,
14};
15pub use local_pusher::{IngestError, LocalPusher, PushOutcome};
16pub use lockfile::{LockKind, Lockfile};
17pub use reader::{backfill_once, BackfillBudget, BackfillError};
18pub use writer::{OnConnectedCallback, OnNewClipCallback, Writer};