Struct StorageReplicationManager 

pub struct StorageReplicationManager {
    pub policy: RmReplicationPolicy,
    pub nodes: HashMap<String, ReplicaNode>,
    pub replicas: HashMap<String, Vec<RmReplicaLocation>>,
}

Manages block replication across a set of storage nodes.

Tracks the health and capacity of each node, records where each CID is stored, and exposes methods to query replication status, select candidate nodes for new replicas, and evict stale nodes.

Fields

policy: RmReplicationPolicy

Policy controlling replication factors and node selection.

nodes: HashMap<String, ReplicaNode>

Registered nodes, keyed by node_id.

replicas: HashMap<String, Vec<RmReplicaLocation>>

Replica locations, keyed by CID. Each entry is a list of locations.

Implementations

impl StorageReplicationManager

pub fn new(policy: RmReplicationPolicy) -> Self

Create a new manager with the supplied policy.

pub fn register_node( &mut self, node: ReplicaNode, ) -> Result<(), ReplicationError>

Register a new storage node.

Returns ReplicationError::NodeAlreadyRegistered if a node with the same node_id is already present.

pub fn deregister_node(&mut self, node_id: &str) -> Result<(), ReplicationError>

Remove a node and all replica records that reference it.

Returns ReplicationError::NodeNotFound if the node is not present.

pub fn mark_healthy(&mut self, node_id: &str, now: u64) -> bool

Mark a node as healthy and update its last_seen timestamp.

Returns true if the node was found.

pub fn mark_unhealthy(&mut self, node_id: &str) -> bool

Mark a node as unhealthy.

Returns true if the node was found.

pub fn record_replica( &mut self, cid: String, node_id: &str, checksum: u64, now: u64, ) -> Result<(), ReplicationError>

Record that a CID has been stored on a node.

Returns ReplicationError::NodeNotFound if node_id is not registered.

pub fn verify_replica(&mut self, cid: &str, node_id: &str, now: u64) -> bool

Update the verified_at timestamp for a specific CID + node pair.

Returns true if the replica record was found and updated.

pub fn remove_replica(&mut self, cid: &str, node_id: &str) -> bool

Remove a specific replica location.

Returns true if the location was found and removed.

pub fn replication_status(&self, cid: &str) -> RmReplicationStatus

Return the replication status for a CID.

A “healthy replica” is one where both the replica record exists and the backing node is registered and marked healthy.

pub fn under_replicated_cids(&self) -> Vec<&str>

Return all CIDs that are UnderReplicated or Missing, sorted.

pub fn over_replicated_cids(&self) -> Vec<&str>

Return all CIDs that are OverReplicated, sorted.

pub fn select_nodes_for_replication( &self, cid: &str, count: usize, ) -> Vec<&ReplicaNode>

Select up to count healthy nodes suitable for storing a new replica of cid.

Eligibility criteria (in order of filtering):

1. Node must be healthy.
2. Node must not already hold a replica of the given CID.
3. Node’s utilization must be ≤ max_node_utilization.

Among eligible nodes, those with the most available_bytes are preferred.

pub fn evict_stale_nodes(&mut self, max_age_ms: u64, now: u64) -> usize

Remove nodes whose last_seen is more than max_age_ms milliseconds before now, and clean up associated replica records.

Returns the number of nodes evicted.

pub fn cid_count(&self) -> usize

Returns the total number of distinct CIDs being tracked.

pub fn node_count(&self) -> usize

Returns the total number of registered nodes.

pub fn healthy_node_count(&self) -> usize

Returns the number of nodes currently marked as healthy.

pub fn stats(&self) -> RmReplicationStats

Compute aggregate statistics for the current state.