Struct StorageReplicationManager 

pub struct StorageReplicationManager {
    pub targets: HashMap<ReplicaId, ReplicaTarget>,
    pub pending_ops: VecDeque<ReplicationOp>,
    pub replication_log: Vec<ReplicationLogEntry>,
    pub config: SrmReplicationConfig,
    /* private fields */
}

Production-grade storage replication manager.

Maintains:

• A registry of up to max_replicas ReplicaTarget nodes.
• A bounded VecDeque of pending ReplicationOps.
• A rolling Vec of the last MAX_LOG_ENTRIES ReplicationLogEntry records.
• Accumulated SrmReplicationStats.

Call process_batch periodically to drain the queue and simulate replication outcomes using the inline xorshift64 PRNG.

Fields

targets: HashMap<ReplicaId, ReplicaTarget>

Registered replication targets indexed by their ReplicaId.

pending_ops: VecDeque<ReplicationOp>

Bounded queue of pending replication operations.

replication_log: Vec<ReplicationLogEntry>

Rolling log of recent replication attempts.

config: SrmReplicationConfig

Manager configuration.

Implementations

impl StorageReplicationManager

pub fn new(config: SrmReplicationConfig) -> Self

Create a new manager with the given configuration.

The PRNG is seeded deterministically from the config values so that unit tests are reproducible without an external random source.

pub fn with_defaults() -> Self

Create a manager with default configuration.

pub fn add_replica(&mut self, target: ReplicaTarget) -> Result<(), SrmError>

Register a new replication target.

Errors

• SrmError::RegistryFull if max_replicas is already reached.
• SrmError::DuplicateReplica if the id is already registered.

pub fn remove_replica( &mut self, id: ReplicaId, ) -> Result<ReplicaTarget, SrmError>

Remove a replication target by id.

Errors

• SrmError::ReplicaNotFound if no target with id is registered.

pub fn mark_unhealthy(&mut self, id: ReplicaId) -> Result<(), SrmError>

Mark a replica as unhealthy. Does nothing (ok) if the replica is already unhealthy.

Errors

• SrmError::ReplicaNotFound if no target with id is registered.

pub fn mark_healthy(&mut self, id: ReplicaId) -> Result<(), SrmError>

Mark a previously unhealthy replica as healthy again.

Errors

• SrmError::ReplicaNotFound if no target with id is registered.

pub fn set_priority( &mut self, id: ReplicaId, priority: u32, ) -> Result<(), SrmError>

Update the priority of a registered replica.

Errors

• SrmError::ReplicaNotFound if no target with id is registered.

pub fn enqueue_put(&mut self, cid: [u8; 32], data_len: usize) -> bool

Enqueue a Put replication operation.

Returns false (and increments queue_overflow_count) if the queue is full.

pub fn enqueue_delete(&mut self, cid: [u8; 32]) -> bool

Enqueue a Delete replication operation.

Returns false if the queue is full.

pub fn enqueue_sync(&mut self, since_ts: u64) -> bool

Enqueue a full incremental Sync operation.

Returns false if the queue is full.

pub fn process_batch(&mut self) -> SrmBatchResult

Drain up to batch_size pending operations and simulate replication.

For each operation the manager iterates over all healthy replicas and uses xorshift64 (seeded from the CID + replica-id) to decide success or failure (success probability ≈ 7/8 for Put/Delete, 3/4 for Sync). Results are appended to the rolling log (capped at MAX_LOG_ENTRIES). Statistics are updated atomically per batch.

pub fn check_quorum(&self, required: usize) -> bool

Return true if at least required replicas are currently healthy.

pub fn recovery_plan(&self) -> Vec<ReplicaId>

Return the ids of all unhealthy replicas that need re-synchronisation.

pub fn replication_stats(&self) -> SrmReplicationStats

Return a snapshot of current statistics.

pub fn healthy_replica_count(&self) -> usize

Return the number of healthy replicas.

pub fn replica_count(&self) -> usize

Return the number of registered replicas.

pub fn replica_health_counts(&self) -> (usize, usize)

Return (healthy, unhealthy) counts.

pub fn get_replica(&self, id: &ReplicaId) -> Option<&ReplicaTarget>

Return a reference to a replica by id.

pub fn get_replica_mut(&mut self, id: &ReplicaId) -> Option<&mut ReplicaTarget>

Return a mutable reference to a replica by id.

pub fn pending_count(&self) -> usize

Return the number of pending operations.

pub fn log_entries_for_kind(&self, kind: &str) -> Vec<&ReplicationLogEntry>

Return entries from the replication log whose op_kind matches kind.

pub fn failed_log_entries(&self) -> Vec<&ReplicationLogEntry>

Return only failed log entries.

pub fn drain_pending(&mut self) -> usize

Drain the pending queue and discard all operations (useful for shutdown).

pub fn clear_log(&mut self)

Clear the replication log.

pub fn reset_stats(&mut self)

Reset statistics (but not configuration or targets).

pub fn clock(&self) -> u64

Return the current fake clock value (milliseconds).

pub fn total_bytes_across_targets(&self) -> u64

Return total bytes replicated across all registered targets.

pub fn most_active_replica(&self) -> Option<&ReplicaTarget>

Return the replica with the most bytes replicated, if any.

pub fn least_active_replica(&self) -> Option<&ReplicaTarget>

Return the replica with the fewest bytes replicated (least-loaded), if any.

pub fn has_minimum_quorum(&self) -> bool

True if a quorum of at least min_replicas healthy targets is available.

pub fn replicas_by_priority(&self) -> Vec<ReplicaId>

Return the list of replica ids sorted by priority (ascending = highest priority first).

pub fn healthy_replica_ids(&self) -> Vec<ReplicaId>

Return all healthy replica ids.

pub fn unhealthy_replica_ids(&self) -> Vec<ReplicaId>

Return all unhealthy replica ids.

pub fn last_log_entry(&self) -> Option<&ReplicationLogEntry>

Return the most-recent log entry, if any.

pub fn log_success_count(&self) -> usize

Count log entries that succeeded.

pub fn log_failure_count(&self) -> usize

Count log entries that failed.

pub fn log_success_rate(&self) -> f64

Compute the success rate across all log entries (0.0 if log is empty).

pub fn log_total_bytes(&self) -> usize

Sum of bytes in all log entries.

pub fn log_entries_for_replica( &self, id: &ReplicaId, ) -> Vec<&ReplicationLogEntry>

Return all log entries for a specific replica.

Trait Implementations

impl Debug for StorageReplicationManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.