Struct RemoteFragmentIndex 

pub struct RemoteFragmentIndex { /* private fields */ }

In-memory index accumulated from received FragmentIndexAnnouncements.

Maps chunk_id → Vec<FragmentPointer>.

Held in crate::control::server::DaemonState under an Arc<RwLock<>>.

Implementations

impl RemoteFragmentIndex

pub fn new() -> Self

Create an empty index.

pub fn upsert(&mut self, ann: FragmentIndexAnnouncement)

Incorporate a FragmentIndexAnnouncement.

Merges new pointers into the existing list for the chunk, de-duplicating by fragment_id so repeated announcements are idempotent.

pub fn pointers_for(&self, chunk_id: &str) -> &[FragmentPointer]

All known fragment pointers for a chunk. Returns an empty slice if the chunk has never been announced.

pub fn pointers_for_peer<'a, 'b>( &'a self, chunk_id: &'b str, peer_id: &'b str, ) -> impl Iterator<Item = &'a FragmentPointer> + use<'a, 'b>

Pointers for a chunk hosted by a specific peer.

pub fn evict_peer(&mut self, peer_id: &str)

Remove all pointer entries for a given peer_id (e.g. after it is blacklisted or evicted from the network).

pub fn chunk_count(&self) -> usize

Total number of chunks tracked.

pub fn pointer_count(&self) -> usize

Total number of fragment pointers across all chunks.

pub fn chunk_ids(&self) -> impl Iterator<Item = &str>

All chunk IDs for which at least one pointer is known.

Trait Implementations

impl Debug for RemoteFragmentIndex

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

Formats the value using the given formatter.

impl Default for RemoteFragmentIndex

fn default() -> RemoteFragmentIndex

Returns the “default value” for a type.