Struct ReplicationManager 

pub struct ReplicationManager { /* private fields */ }

Replication Manager

Manages database replication across multiple nodes.

Implementations

impl ReplicationManager

pub fn new(node_id: String, config: ReplicationConfig) -> Self

Create a new Replication Manager with no transport configured.

Note: replicate_changes() on a manager built this way always fails with TdbError::DistributedTransportNotConfigured — there is no way to honestly ship changes to replicas without a transport. Use ReplicationManager::with_transport (with a real network-backed transport, or crate::consensus::transport::LoopbackSimulationTransport for single-node tests) to actually replicate.

pub fn with_transport( node_id: String, config: ReplicationConfig, transport: Arc<dyn NetworkTransport>, ) -> Self

Create a new Replication Manager backed by a real (or explicitly-simulated) NetworkTransport. This is the constructor production code should use.

pub async fn add_replica( &mut self, node_id: String, endpoint: String, ) -> Result<()>

Add a replica node

pub async fn remove_replica(&mut self, node_id: &str) -> Result<()>

Remove a replica node

pub async fn promote_to_master(&mut self, node_id: &str) -> Result<()>

Promote a slave to master (failover)

pub async fn record_change( &mut self, txn_id: String, data: Vec<u8>, ) -> Result<u64>

Record a change for replication

pub async fn replicate_changes( &mut self, changes: Vec<ReplicationChange>, ) -> Result<()>

Replicate changes to all replicas

pub async fn check_replica_health(&self) -> Result<()>

Check replica health and update status

pub async fn resolve_conflict( &mut self, change1: &ReplicationChange, change2: &ReplicationChange, ) -> Result<ReplicationChange>

Handle conflict in master-master replication

pub async fn check_and_failover(&mut self) -> Result<bool>

Perform automatic failover if master is down

pub fn node_id(&self) -> &str

Get node ID

pub fn role(&self) -> ReplicaRole

Get current role

pub fn stats(&self) -> ReplicationStats

Get statistics

pub fn replica_count(&self) -> usize

Get replica count

pub fn healthy_replica_count(&self) -> usize

Get healthy replica count

pub fn current_lsn(&self) -> u64

Get current LSN

pub fn change_buffer_size(&self) -> usize

Get change buffer size