Struct NodeCapabilityRegistry 

pub struct NodeCapabilityRegistry { /* private fields */ }

Thread-safe registry that maps peer IDs to their node-level capability advertisements.

Example

use ipfrs_network::capability_registry::{
    NodeCapability, NodeCapabilities, NodeCapabilityRegistry,
};

let registry = NodeCapabilityRegistry::default();

let caps = NodeCapabilities::new(
    "peer-1",
    vec![NodeCapability::ContentRouting],
    "0.2.0",
);
registry.register(caps);

let found = registry.find_by_capability("content_routing");
assert_eq!(found.len(), 1);

Implementations

impl NodeCapabilityRegistry

pub fn new() -> Self

Create an empty registry.

pub fn register(&self, caps: NodeCapabilities)

Register or replace the capability advertisement for the peer described by caps.peer_id.

pub fn unregister(&self, peer_id: &str)

Remove the advertisement for peer_id from the registry.

This is a no-op when the peer is not registered.

pub fn get(&self, peer_id: &str) -> Option<NodeCapabilities>

Return a clone of the NodeCapabilities for peer_id, or None if the peer is not registered.

pub fn find_by_capability(&self, name: &str) -> Vec<NodeCapabilities>

Return clones of all non-expired peer records that advertise the capability identified by name.

Expiry is evaluated relative to now_ms obtained from the system clock at the time of the call.

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

Remove all expired entries from the registry and return the number of entries that were evicted.

pub fn peer_count(&self) -> usize

Return the number of peers currently registered (including expired ones that have not yet been evicted).

pub fn capability_histogram(&self) -> HashMap<String, usize>

Return a histogram mapping each capability name to the number of currently-registered peers (including stale ones) that advertise it.

Trait Implementations

impl Debug for NodeCapabilityRegistry

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

Formats the value using the given formatter.

impl Default for NodeCapabilityRegistry

fn default() -> NodeCapabilityRegistry

Returns the “default value” for a type.