Struct ReplicationManager 

pub struct ReplicationManager { /* private fields */ }

Replication manager that coordinates replication state and operations.

This manages:

• Server replication role (Primary, Replica, Standalone)
• Write access control (replicas are read-only)
• Change streaming for replica consumers
• Replication status reporting

Implementations

impl ReplicationManager

pub fn new_primary(changelog: Arc<ChangeLog>) -> Self

Create a new replication manager in primary mode.

pub fn new_standalone(changelog: Arc<ChangeLog>) -> Self

Create a new replication manager in standalone mode.

pub fn new_replica( changelog: Arc<ChangeLog>, applier: Arc<ReplicaApplier>, primary_addr: String, ) -> Self

Create a new replication manager in replica mode.

pub async fn can_write(&self) -> bool

Check if writes are allowed (i.e., not a replica).

pub async fn role(&self) -> ReplicationRole

Get the current replication role.

pub async fn is_replica(&self) -> bool

Check if this server is a replica.

pub async fn is_primary(&self) -> bool

Check if this server is the primary.

pub async fn status(&self) -> ReplicationStatus

Get the current replication status.

pub fn current_lsn(&self) -> u64

Get the current LSN.

pub fn stream_changes( &self, from_lsn: u64, batch_size: u32, ) -> StreamChangesResponse

Stream changes from the given LSN.

pub fn stream_changes_filtered( &self, from_lsn: u64, batch_size: u32, entity_filter: Option<&[String]>, ) -> StreamChangesResponse

Stream changes with entity filter.

pub fn applied_lsn(&self) -> Option<u64>

Get the applied LSN (for replicas).

pub fn changelog(&self) -> &ChangeLog

Get a reference to the changelog.

pub async fn promote_to_primary(&self)

Promote this server to primary.

This is used when the primary fails and a replica needs to take over.

pub async fn demote_to_replica(&self, primary_addr: String)

Demote this server to replica.

This is used when another server becomes primary.