Struct CapabilityRegistry 

pub struct CapabilityRegistry { /* private fields */ }

Central registry for peer capability advertisements.

The registry enforces:

• Requirement filtering — peers must satisfy require_all and require_any from the CapabilityConfig to be accepted.
• Capacity limiting — at most max_peers entries are held.
• TTL expiry — stale entries can be purged via CapabilityRegistry::purge_expired.

All methods take &mut self; the registry is not internally synchronised. Wrap in an Arc<Mutex<_>> for concurrent access.

Implementations

impl CapabilityRegistry

pub fn new(config: CapabilityConfig) -> Self

Create a new registry with the given configuration.

pub fn register(&mut self, peer: PeerCapabilitySet) -> bool

Register peer in the registry.

Returns true on success, false when:

• The peer does not meet the configured requirements (meets_requirements), or
• The registry is at capacity (max_peers).

If the same peer_id is already present the old entry is replaced (the stats counters still increment as if it were a new registration).

pub fn meets_requirements(&self, peer: &PeerCapabilitySet) -> bool

Returns true if peer satisfies the configured require_all and require_any constraints.

• require_all: the peer must possess every listed capability.
• require_any: the peer must possess at least one listed capability (no constraint when the list is empty).

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

Remove the peer identified by peer_id from the registry.

Returns true if the peer was present and removed, false otherwise.

pub fn get_peer(&self, peer_id: &str) -> Option<&PeerCapabilitySet>

Retrieve the PeerCapabilitySet for peer_id, if present.

pub fn peers_with_capability( &self, cap: &PeerCapability, ) -> Vec<&PeerCapabilitySet>

Return all peers that advertise cap.

pub fn peers_with_all(&self, caps: &[PeerCapability]) -> Vec<&PeerCapabilitySet>

Return all peers that advertise every capability in caps.

pub fn peers_with_any(&self, caps: &[PeerCapability]) -> Vec<&PeerCapabilitySet>

Return all peers that advertise at least one capability in caps.

pub fn purge_expired(&mut self, now: u64) -> usize

Remove all peers whose advertised_at is older than now - ttl_ms.

Returns the number of entries purged.

pub fn capability_name(cap: &PeerCapability) -> &'static str

Returns a &'static str label for well-known capability variants.

For PeerCapability::Custom the returned string is always "custom". Use PeerCapability::key when you need the full dynamic key including the custom payload.

pub fn peer_count(&self) -> usize

Returns the number of peers currently in the registry.

pub fn stats(&self) -> &CapabilityStats

Returns a reference to the runtime statistics snapshot.

The snapshot reflects the live state of the registry; the histogram entries are decremented on removal, so they track currently registered peers rather than lifetime totals.

pub fn local_capabilities(&self) -> &[PeerCapability]

Returns the local capabilities configured for this node.