Expand description
Background sync loop that continuously drives CDC-to-OLAP replication.
The single public entry point spawn_sync_loop starts a Tokio task that
calls rhei_core::SyncEngine::sync_once on a fixed interval. A DDL read-lock
prevents schema mutations from racing with an in-progress cycle. Shutdown
is cooperative via a tokio_util::sync::CancellationToken.
Functionsยง
- spawn_
sync_ loop - Spawn a background task that continuously polls CDC and syncs to OLAP.