Struct WalReceiver 

pub struct WalReceiver { /* private fields */ }

WAL Receiver manages the follower’s connection to the leader.

Implementations

impl WalReceiver

pub fn new( leader_addr: String, wal_dir: impl Into<PathBuf>, store: Arc<EventStore>, ) -> Result<Self>

Create a new WAL receiver.

leader_addr is the host:port of the leader’s replication port (e.g. “core-leader:3910”). wal_dir is the directory for the follower’s local WAL files.

pub fn set_metrics(&mut self, metrics: Arc<MetricsRegistry>)

Set the Prometheus metrics registry for replication metrics.

pub fn status(&self) -> FollowerReplicationStatus

Get the current follower replication status for health reporting.

pub fn shutdown(&self)

Signal the receiver to stop reconnecting and shut down.

Called during follower → leader promotion.

pub fn repoint(&self, new_leader: &str)

Change the leader address and force a reconnect.

Called by the sentinel via POST /internal/repoint to redirect this follower to a newly promoted leader.

pub async fn run(self: Arc<Self>)

Run the receiver loop with auto-reconnect. This runs until shutdown is signalled.

Exponential backoff: 1s initial, doubles each attempt, capped at 30s.