Struct AgentRegistry 

pub struct AgentRegistry { /* private fields */ }

Tracks spawned agents and provides inter-agent messaging.

Implementations

impl AgentRegistry

pub fn new() -> AgentRegistry

pub fn with_hooks(self, hooks: Arc<dyn RegistryHooks>) -> AgentRegistry

Attach lifecycle hooks to the registry.

pub fn with_send_context(self, enabled: bool) -> AgentRegistry

Configure whether send() injects sender identity into messages.

pub async fn register(&self, agent: SpawnedAgent) -> Result<(), AgentError>

Register a spawned agent. Returns error if the ID already exists.

pub fn get(&self, id: &str) -> Option<Arc<RuntimeAgent>>

Clone an Arc handle to a registered agent’s RuntimeAgent.

pub fn get_spawned(&self, id: &str) -> Option<Arc<SpawnedAgent>>

Get the full SpawnedAgent metadata (agent + spec + timestamp).

pub fn list(&self) -> Vec<SpawnedAgentInfo>

List metadata for all registered agents.

pub fn list_with_specs(&self) -> Vec<SpawnedAgentEntry>

List all registered agents with their specs serialized as YAML for session persistence.

pub async fn remove(&self, id: &str) -> Option<Arc<SpawnedAgent>>

Remove an agent from the registry and return it.

pub async fn send( &self, from: &str, to: &str, message: &str, ) -> Result<AgentResponse, AgentError>

Send a message from one agent to another and return the response.

pub async fn broadcast( &self, from: &str, message: &str, ) -> Vec<(String, Result<AgentResponse, AgentError>)>

Broadcast a message to all agents except the sender.

Clones all target Arcs under a single brief read lock, then drives all chat() calls concurrently after releasing the lock.

pub fn count(&self) -> usize

Number of currently registered agents.

pub fn contains(&self, id: &str) -> bool

Returns true if the registry contains an agent with this ID.

Trait Implementations

impl Debug for AgentRegistry

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

Formats the value using the given formatter.

impl Default for AgentRegistry

fn default() -> AgentRegistry

Returns the “default value” for a type.