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