Skip to main content

Module replication

Module replication 

Source
Expand description

faucet replicate — consistent snapshot → CDC streaming handoff.

A CLI-level orchestration layer (like schedule/serve) over expand + executor::run_expanded. See docs/superpowers/specs/2026-06-13-replication-snapshot-cdc-handoff-design.md.

Re-exports§

pub use orchestrator::ReplicationOptions;
pub use orchestrator::run_replication;

Modules§

compiled
Load-time validation of the replication: block against the pipeline.
orchestrator
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).
spec
Serde config types for the replication: block (faucet replicate).
state
Persistent phase/position marker for faucet replicate, plus the pure phase-decision logic. The marker lives at {name}::__replication__; the CDC bookmark lives at {name}::cdc (the CDC node’s executor state key).