Struct PeerCapabilityRegistry 

pub struct PeerCapabilityRegistry { /* private fields */ }

Tick-based registry tracking which protocol-level Capability set each peer advertises.

This is the primary data structure for capability-based peer selection. Advertisements carry a TTL expressed in ticks; callers must supply the current tick to all query operations so that expired entries are correctly filtered out without requiring a background eviction task.

Example

use ipfrs_network::capability_registry::{
    Capability, PeerCapabilityRegistry,
};

let mut registry = PeerCapabilityRegistry::new();
registry.advertise(
    "peer-a".to_string(),
    vec![Capability::Kademlia, Capability::Bitswap { version: 1 }],
    /*current_tick=*/ 0,
    /*ttl_ticks=*/ 100,
);

let peers = registry.peers_with_capability(&Capability::Kademlia, 0);
assert_eq!(peers, vec!["peer-a"]);

Implementations

impl PeerCapabilityRegistry

pub fn new() -> Self

Create an empty registry.

pub fn advertise( &mut self, peer_id: String, capabilities: Vec<Capability>, current_tick: u64, ttl_ticks: u64, )

Insert or replace the advertisement for peer_id.

The advertisement expires at tick current_tick + ttl_ticks.

pub fn peers_with_capability( &self, cap: &Capability, current_tick: u64, ) -> Vec<&str>

Return a sorted list of peer IDs whose valid advertisements include cap.

Only advertisements that pass CapabilityAdvertisement::is_valid at current_tick are considered. The result is sorted alphabetically.

pub fn peer_capabilities( &self, peer_id: &str, current_tick: u64, ) -> Option<&[Capability]>

Return the capability slice for peer_id if its advertisement is valid at current_tick, or None otherwise.

Returns None when:

• the peer is not in the registry, or
• the peer’s advertisement has expired.

pub fn remove_peer(&mut self, peer_id: &str) -> bool

Remove the advertisement for peer_id.

Returns true if the peer was found and removed, false if the peer was not registered.

pub fn evict_expired(&mut self, current_tick: u64) -> usize

Remove all expired advertisements from the registry.

Returns the number of advertisements that were removed.

pub fn stats(&self, current_tick: u64) -> CapabilityRegistryStats

Return a CapabilityRegistryStats snapshot evaluated at current_tick.

Trait Implementations

impl Debug for PeerCapabilityRegistry

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

Formats the value using the given formatter.

impl Default for PeerCapabilityRegistry

fn default() -> PeerCapabilityRegistry

Returns the “default value” for a type.