Struct AgentManager 

pub struct AgentManager {
    pub db: Arc<Mutex<Connection>>,
    /* private fields */
}

Fields

db: Arc<Mutex<Connection>>

Implementations

impl AgentManager

pub fn new(db: Connection) -> Self

pub async fn spawn(&self, manifest: AgentManifest) -> Result<ProcessId>

pub async fn stop(&self, pid: ProcessId) -> Result<StopResult>

pub fn pause(&self, pid: ProcessId) -> Result<()>

pub fn resume(&self, pid: ProcessId) -> Result<()>

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

pub fn get_state(&self, pid: ProcessId) -> Option<LifecycleState>

pub fn enforce_budget(&self, pid: ProcessId) -> Result<bool>

Check if agent has exceeded its token budget; if so, pause it and return true.