Struct AgentRegistry 

pub struct AgentRegistry { /* private fields */ }

Agent Registry - single source of truth for agent management

Implementations

impl AgentRegistry

pub fn new(max_agents: usize, timeout_ms: u64) -> Self

Create a new agent registry

Arguments

• max_agents - Maximum number of concurrent agents (default: 100)
• timeout_ms - Inactivity timeout in milliseconds (default: 60000)

pub fn with_defaults() -> Self

Create registry with default settings (100 agents, 60s timeout)

pub fn register(&mut self, agent_info: AgentInfo) -> Result<(), String>

Register a new agent

pub fn deregister(&mut self, agent_id: &str) -> Result<(), String>

Deregister an agent

pub fn heartbeat(&mut self, agent_id: &str) -> Result<(), String>

Update heartbeat for an agent

pub fn get(&self, agent_id: &str) -> Option<&AgentInfo>

Get agent info

pub fn get_all(&self) -> Vec<&AgentInfo>

Get all agents

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

Get agents with stale heartbeats (older than configured timeout)

pub fn prune_inactive_agents(&mut self) -> usize

Prune inactive agents

Returns

Number of agents pruned

pub fn count(&self) -> usize

Get number of registered agents

pub fn has_sensory_agents(&self) -> bool

Check if any agent has sensory capability (for stream gating)

pub fn has_motor_agents(&self) -> bool

Check if any agent has motor capability (for stream gating)

pub fn has_visualization_agents(&self) -> bool

Check if any agent has visualization capability (for stream gating)

pub fn count_sensory_agents(&self) -> usize

Get count of agents with sensory capability

pub fn count_motor_agents(&self) -> usize

Get count of agents with motor capability

pub fn count_visualization_agents(&self) -> usize

Get count of agents with visualization capability

pub fn get_timeout_ms(&self) -> u64

Get the configured timeout threshold in milliseconds