Skip to main content

Module orchestrator

faucet_cli::replication

Module orchestrator 

Source
Expand description

Two-phase snapshot→CDC orchestration. Reuses executor::run_expanded for each phase; seeds the CDC bookmark from a position captured before the snapshot so the handoff has no gap (idempotent at the boundary under write_mode: upsert).

Structs§

ReplicationOptions
Inputs for one faucet replicate invocation.

Functions§

run_replication
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).