Module replication 

Leader-follower replication via WAL shipping.

When ALLSOURCE_REPLICATION_ENABLED=true on a leader node, the WAL shipper opens a TCP listener on ALLSOURCE_REPLICATION_PORT (default 3910) and streams WAL entries to connected followers using newline-delimited JSON.

Followers use the WAL receiver to connect, subscribe, validate, and replay entries into their local EventStore.

Re-exports

pub use wal_receiver::FollowerReplicationStatus;

pub use wal_receiver::WalReceiver;

pub use wal_shipper::ReplicationMode;

pub use wal_shipper::ReplicationStatus;

pub use wal_shipper::WalShipper;

Modules

protocol

Replication protocol message types for leader-follower WAL shipping.

wal_receiver

WAL Receiver — connects to the leader and replays WAL entries on a follower.

wal_shipper

WAL Shipper — streams WAL entries from the leader to connected followers.