Struct StorageReplicationTracker 

pub struct StorageReplicationTracker {
    pub entries: HashMap<u64, BlockReplicationEntry>,
    pub next_block_id: u64,
    pub default_desired_replicas: usize,
}

Tracks replication of content blocks across a peer network.

Fields

entries: HashMap<u64, BlockReplicationEntry>

All tracked block entries keyed by block_id.

next_block_id: u64

Counter used to issue monotonically increasing block IDs.

default_desired_replicas: usize

Replication factor applied when register_block receives None.

Implementations

impl StorageReplicationTracker

pub fn new(default_desired_replicas: usize) -> Self

Creates a new tracker with the given default replication factor.

pub fn register_block( &mut self, cid: String, desired_replicas: Option<usize>, ) -> u64

Registers a new block and returns its assigned block_id.

If desired_replicas is None, the tracker’s default is used.

pub fn add_replica( &mut self, block_id: u64, peer_id: String, current_tick: u64, is_primary: bool, ) -> bool

Records that peer_id holds a replica of block_id at current_tick.

• Returns false if block_id is not tracked.
• If the peer already has a replica, its tick is updated; otherwise a new ReplicaLocation is appended.
• Returns true on success.

pub fn remove_replica(&mut self, block_id: u64, peer_id: &str) -> bool

Removes the replica held by peer_id from block_id.

Returns false when the block or peer is not found.

pub fn under_replicated_blocks(&self) -> Vec<&BlockReplicationEntry>

Returns all blocks that are ReplicationStatus::UnderReplicated or ReplicationStatus::Critical, sorted by block_id ascending.

pub fn generate_tasks(&self) -> Vec<ReplicationTask>

Generates replication tasks for every block with a positive deficit.

Tasks are ordered by priority descending then block_id ascending.

pub fn get_entry(&self, block_id: u64) -> Option<&BlockReplicationEntry>

Returns a reference to the entry for block_id, if tracked.

pub fn stats(&self) -> ReplicationStats

Computes aggregate statistics across all tracked blocks.