Struct AgentCapabilityRegistry 

pub struct AgentCapabilityRegistry { /* private fields */ }

Maps capability id → ordered list of agents that implement it.

Concurrent access via RwLock. Reads (the hot path during dispatch) are non-blocking under contention; writes (registration, usage tracking) are infrequent.

Implementations

impl AgentCapabilityRegistry

pub fn new() -> Self

pub fn register( &self, capability: impl Into<String>, agent_id: impl Into<String>, )

Register agent_id as a provider for capability. Idempotent — re-registering is a no-op (insertion order is preserved on the first registration).

pub fn unregister(&self, capability: &str, agent_id: &str)

Remove agent_id from capability. Used by the bundle uninstall path (when it exists). Idempotent.

pub fn agents_for(&self, capability: &str) -> Vec<String>

Snapshot of all agents registered for capability, in registration order.

pub fn all_agents(&self) -> Vec<String>

Snapshot of every agent registered for any capability, deduplicated. Useful for the FFI surface’s list_agents(None) call.

pub fn select(&self, capability: &str, hint: Option<&str>) -> Option<String>

Pick one agent for capability. Returns None only when no agents are registered. See module docs for the selection strategy.

pub fn note_used(&self, capability: &str, agent_id: &str)

Record that agent_id successfully served capability. Updates the last-used timestamp for [select]’s MRU tiebreaker. Silent no-op if the entry isn’t registered.

pub fn capability_count(&self) -> usize

Number of distinct capabilities tracked. For diagnostics.

Trait Implementations

impl Debug for AgentCapabilityRegistry

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

Formats the value using the given formatter.

impl Default for AgentCapabilityRegistry

fn default() -> AgentCapabilityRegistry

Returns the “default value” for a type.