river-data-core 0.12.0

Client, sync runner, and shared types for the river-data platform
Documentation
1
2
3
4
5
6
7
8
9
10
pub const TRIGGER_SYNC: &str = "trigger_sync";
pub const TRIGGER_FULL_SYNC: &str = "trigger_full_sync";
pub const PAUSE: &str = "pause";
pub const RESUME: &str = "resume";
/// Re-fetch named streams from the start of history and ingest with overwrite.
/// Payload: `{ "source_keys": [...], "overwrite": true }`.
pub const RESYNC_STREAMS: &str = "resync_streams";
/// Walk everything the source holds and compare it against what is registered here.
/// Read-only: it writes nothing and its result is the report. Payload: none.
pub const SOURCE_AUDIT: &str = "source_audit";