Struct ReplicationManager 

pub struct ReplicationManager { /* private fields */ }

Replication manager

Manages package replication across multiple nodes with configurable consistency levels, automatic failover, and conflict resolution.

Implementations

impl ReplicationManager

pub fn new(config: ReplicationConfig) -> Self

Create a new replication manager

pub fn add_node(&mut self, node: ReplicationNode) -> Result<(), TorshError>

Add a replication node

pub fn remove_node(&mut self, node_id: &str) -> Result<(), TorshError>

Remove a replication node

pub fn replicate_package( &mut self, package_id: &str, version: &str, _data: &[u8], ) -> Result<(), TorshError>

Replicate a package to all nodes

pub fn get_package( &self, package_id: &str, version: &str, ) -> Result<String, TorshError>

Get package from best available replica

pub fn health_check(&mut self) -> Result<(), TorshError>

Perform health check on all nodes

pub fn synchronize(&mut self) -> Result<(), TorshError>

Synchronize replicas across nodes

pub fn resolve_conflicts(&mut self) -> Result<(), TorshError>

Detect and resolve conflicts

pub fn get_statistics(&self) -> &ReplicationStatistics

Get replication statistics

pub fn get_node_status(&self, node_id: &str) -> Option<NodeStatus>

Get node status

pub fn list_nodes(&self) -> Vec<&ReplicationNode>

List all nodes

pub fn list_replicas( &self, package_id: &str, version: &str, ) -> Vec<&ReplicaMetadata>

List replicas for a package

pub fn get_conflicts(&self) -> Vec<&ReplicationConflict>

Get active conflicts