Module replay_loop 

Structs

ReplayProgress

Tracks how far behind the standby is from the primary.

Constants

CATCH_UP_TICK_INTERVAL 🔒

Traits

ReplayHandler

Callback that the replay loop calls for each command. The implementation should deserialize and call apply() on the standby engine.

Functions

apply_replay_message 🔒

is_caught_up_to_stream_tail 🔒

is_promote_signal 🔒

Check if the shutdown signal is a real promote (Ok) vs sender dropped (Err). Only returns true for an explicit promote signal.

refresh_catch_up_state 🔒

run_replay_loop

Runs the standby replay loop: subscribes to NATS JetStream and continuously replays engine commands to keep the standby engine caught up with the primary.