Struct AgentManager 

pub struct AgentManager { /* private fields */ }

Core agent manager implementation

Manages agent lifecycles without GUI dependencies. GUI/Tauri-specific features are in the GUI crate’s wrapper.

Implementations

impl AgentManager

pub fn new(db_path: PathBuf) -> AgentManager

Create a new AgentManager with the given database path

pub async fn spawn_agent(&self, id: String, name: String)

Spawn a lightweight agent task that listens for commands

This is a basic implementation. GUI can override spawn behavior by wrapping this manager.

pub async fn spawn_agent_with_request(&self, request: AgentSpawnRequest)

Spawn a lightweight agent using an explicit configuration request.

pub async fn get_agent_status(&self, id: &str) -> Option<AgentInfo>

Get status information for a specific agent

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

List all active agents

pub async fn update_activity(&self, id: &str)

Update last activity timestamp for an agent

pub async fn send_event(&self, id: &str, payload: String)

Publish an event to a specific agent if present

pub async fn shutdown_all(&self, grace_secs: u64)

Gracefully shutdown all agents, waiting up to grace_secs for completion

pub fn default_db_path() -> PathBuf

Compute a default DB path under the user’s data dir

Trait Implementations

impl AgentSpawner for AgentManager

fn spawn_agent<'life0, 'async_trait>( &'life0 self, id: String, name: String, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, AgentManager: 'async_trait,

Spawn an agent and return its id

fn spawn_agent_with_request<'life0, 'async_trait>( &'life0 self, request: AgentSpawnRequest, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, AgentManager: 'async_trait,

Spawn an agent with an explicit request payload.

fn send_event<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, payload: String, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, AgentManager: 'async_trait,

Send an event envelope to a running agent

fn load_state<'life0, 'life1, 'async_trait>( &'life0 self, _id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Option<String>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, AgentManager: 'async_trait,

Attempt to restore state for an agent

fn shutdown_all<'life0, 'async_trait>( &'life0 self, grace_secs: u64, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, AgentManager: 'async_trait,

Shutdown all agents with a grace period

impl Clone for AgentManager

fn clone(&self) -> AgentManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl OrchestratorAgentManager for AgentManager

fn get_agent_status<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Option<AgentInfo>> + Send + 'async_trait>>

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

Get status information for a specific agent.

fn list_agents<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Vec<AgentInfo>> + Send + 'async_trait>>

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

List all active agents.

fn update_activity<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Update last activity timestamp for an agent.