pub async fn run_replication(
cfg: &PipelineConfig,
compiled: &CompiledReplication,
opts: ReplicationOptions,
) -> CliResult<()>Expand description
Run the two-phase replication. Validates, bootstraps (captures + seeds the
CDC position), snapshots (if not already done), then streams CDC (looping
until SIGTERM when continuous).