Struct AgentApi 

pub struct AgentApi { /* private fields */ }

Agent management system calls.

Implementations

impl AgentApi

pub fn new( supervisor: Arc<dyn Supervisor>, budget_manager: Arc<BudgetManager>, memory_manager: Arc<MemoryManager>, event_bus: Option<EventBus>, ) -> Self

Create a new AgentApi.

pub fn set_hnsw_index(&mut self, index: Arc<HnswMemoryIndex>)

Attach an HNSW index for semantic search.

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

List running agents.

pub async fn kill(&self, agent_id: &str) -> Result<()>

Kill a running agent.

pub fn check_budget(&self, agent_id: &AgentId) -> BudgetInfo

Check budget for an agent.

pub fn set_budget(&self, limit: BudgetLimit)

Set budget for an agent.

pub fn remove_budget(&self, agent_id: &AgentId)

Remove budget for an agent.

pub fn reserve_budget( &self, agent_id: &AgentId, tokens: u64, ) -> Result<(), BudgetExceeded>

Reserve tokens for an agent.

pub fn reset_budget(&self, agent_id: &AgentId)

Reset budget window for an agent.

pub fn full_budget_info(&self, agent_id: &AgentId) -> Option<FullBudgetInfo>

Get full budget info (limits + usage) for an agent.

pub fn all_budget_info(&self) -> Vec<FullBudgetInfo>

Get full budget info for all agents with configured budgets.

pub async fn memory_stats(&self) -> (usize, usize)

Get memory stats.

pub async fn remember(&self, entry: MemoryEntry) -> Result<String>

Store a memory entry.

pub async fn search_memory( &self, query: &str, memory_type: Option<MemoryType>, limit: usize, ) -> Result<Vec<MemoryEntry>>

Search memory entries.

pub async fn semantic_search_memory( &self, query: &str, memory_type: Option<MemoryType>, limit: usize, ) -> Result<Vec<SemanticHit>>

Semantic search using HNSW index.

Falls back to regular search if HNSW index is not available.

pub fn memory_manager(&self) -> &Arc<MemoryManager>

Memory manager reference.

pub async fn rebuild_hnsw_index(&self) -> Result<usize>

Rebuild the HNSW index from all stored memories.