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";