Struct ReplicationManager 

pub struct ReplicationManager { /* private fields */ }

Replication manager.

Implementations

impl ReplicationManager

pub fn new(config: ReplicationConfig) -> Self

Create a new replication manager.

pub fn with_defaults() -> Self

Create with default configuration.

pub fn create_replicas( &self, data_id: String, size_bytes: u64, available_workers: &[WorkerId], ) -> Result<ReplicaSet>

Create replica set for data.

pub fn get_replicas(&self, data_id: &str) -> Option<ReplicaSet>

Get replica set for data.

pub async fn quorum_read(&self, data_id: &str) -> Result<Vec<WorkerId>>

Perform quorum read.

pub async fn quorum_write(&self, data_id: &str) -> Result<Vec<WorkerId>>

Perform quorum write.

pub fn update_worker_health(&self, health: WorkerHealth)

Update worker health.

pub fn mark_replica_failed( &self, data_id: &str, worker_id: WorkerId, ) -> Result<()>

Mark replica as failed.

pub fn check_rereplication( &self, available_workers: &[WorkerId], ) -> Vec<(String, WorkerId)>

Check and perform re-replication if needed.

pub fn add_replica(&self, data_id: &str, worker_id: WorkerId) -> Result<()>

Add replica to existing set.

pub fn remove_replica(&self, data_id: &str, worker_id: WorkerId) -> Result<()>

Remove replica.

pub fn get_statistics(&self) -> ReplicationStatistics

Get statistics.

Trait Implementations

impl Clone for ReplicationManager

fn clone(&self) -> ReplicationManager

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.