Module coordinator 

Replication engine coordinator.

The main orchestrator that ties together:

• Peer connections via crate::peer::PeerConnection
• Stream tailing (hot path) via crate::stream::StreamTailer
• Cursor persistence via crate::cursor::CursorStore
• Merkle repair (cold path) for consistency

Architecture

The coordinator manages the full replication lifecycle:

1. Connects to configured peers
2. Tails CDC streams for real-time updates (hot path)
3. Periodically runs Merkle tree repair (cold path)
4. Handles graceful shutdown with in-flight batch draining

Structs

HealthCheck

Comprehensive health status of the replication engine.

PeerHealth

Health status of a single peer.

ReplicationEngine

The main replication engine.

Enums

EngineState

State of the replication engine.