Struct ReplicationQueues 

pub struct ReplicationQueues { /* private fields */ }

Central queue manager for the replication pipeline.

Maintains three stages of the pipeline with global dedup:

1. PendingVerify – keys awaiting quorum verification.
2. FetchQueue – quorum-passed keys waiting for a fetch slot.
3. InFlightFetch – keys actively being downloaded.

Implementations

impl ReplicationQueues

pub fn new() -> Self

Create new empty queues.

pub fn add_pending_verify( &mut self, key: XorName, entry: VerificationEntry, ) -> bool

Add a key to pending verification if not already present in any queue.

Returns true if the key was newly added (Rule 8: cross-queue dedup).

pub fn get_pending(&self, key: &XorName) -> Option<&VerificationEntry>

Get a reference to a pending verification entry.

pub fn get_pending_mut( &mut self, key: &XorName, ) -> Option<&mut VerificationEntry>

Get a mutable reference to a pending verification entry.

pub fn remove_pending(&mut self, key: &XorName) -> Option<VerificationEntry>

Remove a key from pending verification.

pub fn pending_keys(&self) -> Vec<XorName>

Collect all pending verification keys (for batch processing).

pub fn pending_count(&self) -> usize

Number of keys in pending verification.

pub fn enqueue_fetch( &mut self, key: XorName, distance: XorName, sources: Vec<PeerId>, )

Enqueue a key for fetch with its distance and verified sources.

No-op if the key is already in any pipeline stage (Rule 8: cross-queue dedup).

pub fn dequeue_fetch(&mut self) -> Option<FetchCandidate>

Dequeue the nearest fetch candidate.

Returns None when the queue is empty. Silently skips candidates that are somehow already in-flight. Concurrency is enforced by the fetch worker, not by this method.

pub fn fetch_queue_count(&self) -> usize

Number of keys waiting in the fetch queue.

pub fn start_fetch( &mut self, key: XorName, source: PeerId, all_sources: Vec<PeerId>, )

Mark a key as in-flight (actively being fetched from source).

pub fn complete_fetch(&mut self, key: &XorName) -> Option<InFlightEntry>

Mark a fetch as completed (success or permanent failure).

pub fn retry_fetch(&mut self, key: &XorName) -> Option<PeerId>

Mark the current fetch attempt as failed and try the next untried source.

Returns the next source peer if one is available, or None if all sources have been exhausted.

pub fn in_flight_count(&self) -> usize

Number of in-flight fetches.

pub fn contains_key(&self, key: &XorName) -> bool

Check if a key is present in any pipeline stage.

pub fn is_bootstrap_work_empty(&self, bootstrap_keys: &HashSet<XorName>) -> bool

Check if all bootstrap-related work is done.

Returns true when none of the given bootstrap keys remain in any queue.

pub fn evict_stale(&mut self, max_age: Duration)

Evict stale pending-verification entries older than max_age.

Trait Implementations

impl Default for ReplicationQueues

fn default() -> Self

Returns the “default value” for a type.