Struct InMemoryAgentRegistry 

pub struct InMemoryAgentRegistry { /* private fields */ }

In-memory AgentRegistry adapter — the default, infra-free implementation.

A first-class type (not test-only, per hex rule 6): services and tests run against it without standing up external infrastructure. Cheap to clone (shares one map); reads (find_by_skill, get) dominate writes, hence the RwLock.

Implementations

impl InMemoryAgentRegistry

pub fn new() -> Self

Create an empty registry.

Trait Implementations

impl AgentRegistry for InMemoryAgentRegistry

fn register<'life0, 'async_trait>( &'life0 self, card: AgentCard, endpoint: String, ) -> Pin<Box<dyn Future<Output = Result<AgentId, RegistryError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Register (or replace) an agent. The id is derived from the card’s name; re-registering the same name upserts (last-writer-wins).

fn mark<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 AgentId, liveness: Liveness, ) -> Pin<Box<dyn Future<Output = Result<(), RegistryError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Record what a liveness probe found. Returns RegistryError::NotFound if the agent was deregistered while the probe was in flight.

fn deregister<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 AgentId, ) -> Pin<Box<dyn Future<Output = Result<(), RegistryError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Remove an agent. Returns RegistryError::NotFound if it was not registered.

fn get<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 AgentId, ) -> Pin<Box<dyn Future<Output = Result<Option<RegisteredAgent>, RegistryError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Look up an agent by id; Ok(None) when absent.

fn find_by_skill<'life0, 'life1, 'async_trait>( &'life0 self, skill: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<RegisteredAgent>, RegistryError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Find every agent whose card advertises a matching skill. A skill matches when its id or any of its tags equals skill, case-insensitively.

fn list<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<RegisteredAgent>, RegistryError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List every registered agent.

impl Clone for InMemoryAgentRegistry

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for InMemoryAgentRegistry

fn default() -> Self

Returns the “default value” for a type.