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

Structs

ReplicationState

The durable replication marker.

Enums

Phase

Replication phase recorded in the marker.

Plan

What the orchestrator should do given the loaded marker (None = fresh).

Functions

cdc_state_key

State key the CDC node will read/advance (must match the executor’s key for a root node whose id is cdc: {name}::cdc).

marker_key

State key holding the replication phase marker.

plan_from_marker

Decide the next action from a loaded marker.