Struct ReplicationManager 

pub struct ReplicationManager { /* private fields */ }

Replication manager for data redundancy

Implementations

impl ReplicationManager

pub fn new(cluster_state: Arc<ClusterState>, config: ReplicationConfig) -> Self

Create a new replication manager

pub async fn start(&mut self) -> Result<(), ReplicationError>

Start replication processes

pub async fn replicate_operation( &self, operation: Operation, primary_node: &NodeId, ) -> Result<(), ReplicationError>

Queue an operation for replication

pub async fn sync_with_node( &self, node_id: &NodeId, ) -> Result<(), ReplicationError>

Synchronize data with a specific node

pub async fn handle_node_failure( &self, failed_node: &NodeId, ) -> Result<(), ReplicationError>

Handle node failure and promote replica

pub async fn check_health(&self) -> ReplicationHealth

Check replication health

pub async fn get_status(&self) -> ReplicationStatusSnapshot

Get replication status

pub fn command_sender(&self) -> Sender<ReplicationCommand>

Get command sender for external commands