Struct ReplicationManager 

pub struct ReplicationManager { /* private fields */ }

Implementations

impl ReplicationManager

pub fn new( nodes: Arc<Mutex<HashMap<String, Arc<Node>>>>, replication_factor: usize, node_id: String, ) -> Self

pub fn set_storage(&mut self, storage: Arc<Mutex<Storage>>)

Set the storage for persistent replication

pub fn set_transport(&mut self, transport: Arc<NetworkTransport>)

Set the network transport for distributed replication

pub async fn send_data_update( &self, partition_id: String, data: Vec<u8>, ) -> Result<(), String>

pub async fn send_state_update( &self, partition_id: String, status: ReplicationStatus, ) -> Result<(), String>

pub async fn notify_node_failure(&self, node_id: String) -> Result<(), String>

pub fn start(&mut self)

pub async fn handle_replication_request( &self, message: DistributedMessage, ) -> NetworkResult<Option<DistributedMessage>>

Handle replication request from remote node

pub async fn handle_replication_response( &self, message: DistributedMessage, ) -> NetworkResult<()>

Handle replication response from remote node