Struct ReplicaManager 

pub struct ReplicaManager { /* private fields */ }

Manager for replica placement and lifecycle

Implementations

impl ReplicaManager

pub fn new(config: ReplicationConfig) -> Self

Create a new replica manager

pub fn register_node(&self, topology: NodeTopology)

Register a node with its topology

pub fn deregister_node(&self, node_id: &str)

Remove a node from available nodes

pub fn create_replica_set( &self, shard_id: &str, replication_factor: Option<u32>, ) -> Result<ReplicaSet, ReplicationError>

Create a new replica set for a shard

pub fn get_replica_set(&self, shard_id: &str) -> Option<ReplicaSet>

Get replica set for a shard

pub fn update_replica_state( &self, shard_id: &str, node_id: &str, state: ReplicaState, lag_ms: Option<u64>, ) -> Result<(), ReplicationError>

Update replica state

pub fn record_replica_failure( &self, shard_id: &str, node_id: &str, ) -> Result<(), ReplicationError>

Record a replica failure

pub fn promote_replica( &self, shard_id: &str, new_primary_node: &str, ) -> Result<(), ReplicationError>

Promote a replica to primary

pub fn add_replica( &self, shard_id: &str, node_id: &str, ) -> Result<(), ReplicationError>

Add a new replica to a shard

pub fn remove_replica( &self, shard_id: &str, node_id: &str, ) -> Result<(), ReplicationError>

Remove a replica from a shard

pub fn check_under_replicated(&self) -> Vec<(String, usize)>

Get nodes that need replicas (automatic failover check)

pub fn auto_failover( &self, shard_id: &str, ) -> Result<Option<String>, ReplicationError>

Auto-failover: promote replica if primary is down

pub fn get_stats(&self) -> ReplicationStats

Get replication statistics

pub fn config(&self) -> &ReplicationConfig

Get configuration