Struct AgentRegistry 

pub struct AgentRegistry { /* private fields */ }

Thread-safe agent registry with parent/child hierarchy and sqlitegraph persistence.

Uses a hybrid approach: in-memory AgentTree for fast reads, write-through to sqlitegraph on register and disconnect. On startup, agents are loaded from the database — all agents start offline and must re-register.

Implementations

impl AgentRegistry

pub fn new(graph: &SqliteGraph) -> Result<Self>

Create a new registry, loading existing agents from the database. All agents from the DB start in offline state — they must re-register. Only agents that were explicitly retired before shutdown have their IDs added to the reuse pool. Agents that are simply offline after restart keep their IDs reserved until they re-register or are explicitly retired.

pub fn register( &self, graph: &SqliteGraph, name: &str, kind: &str, parent_id: Option<String>, ) -> Result<AgentInfo>

Register an agent and return its server-assigned ID.

If an active agent with the same name already exists (and no parent_id is specified), the existing agent is returned — registration is idempotent. This lets agents reconnect without creating duplicates.

For subagents (parent_id provided), a new child agent is always created with a hierarchical ID like id1.1, id1.2, etc.

pub fn retire(&self, graph: &SqliteGraph, agent_id: &str) -> Result<Vec<String>>

Retire an agent and all descendants. Retired IDs are added to the reuse pool. Returns list of affected IDs.

pub fn disconnect( &self, graph: &SqliteGraph, agent_id: &str, ) -> Result<Vec<String>>

Disconnect agent — marks agent and descendants as Retired. Kept for backward compatibility with DELETE /agents/{id}.

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

pub fn list_all(&self) -> Result<Vec<AgentInfo>>

pub fn is_active(&self, agent_id: &str) -> Result<bool>

pub fn list_active(&self) -> Result<Vec<AgentInfo>>

pub fn get_children(&self, agent_id: &str) -> Result<Vec<AgentInfo>>

pub fn heartbeat( &self, graph: &SqliteGraph, agent_id: &str, status: AgentStatusSnapshot, ) -> Result<()>

Record a heartbeat, updating the agent’s status snapshot and timestamp.

pub fn get_stale_agents(&self, threshold_minutes: i64) -> Result<Vec<AgentInfo>>

Return active agents whose last heartbeat is older than threshold_minutes.

pub fn purge_retired(&self, threshold_hours: i64) -> Result<usize>

Remove retired agents that haven’t heartbeated in 24+ hours. Returns the number of purged agents.