Struct AgentLifecycleManager 

pub struct AgentLifecycleManager { /* private fields */ }

Manages the full lifecycle of a single agent from fork to cleanup.

Implementations

impl AgentLifecycleManager

pub fn new( supervisor: Arc<dyn Supervisor>, scheduler: Arc<AgentScheduler>, access_manager: Arc<Mutex<AccessManager>>, a2a: Arc<A2AProtocol>, event_bus: EventBus, max_execution_time_secs: u64, allowed_tools: Vec<String>, network_access: bool, workspace_path: String, ) -> Self

Create a new lifecycle manager.

pub fn set_max_execution_time(&self, secs: u64)

Hot-reload max execution time without restart.

pub async fn spawn_and_run( &self, seed: &Seed, priority: Priority, ) -> Result<ExecutionResult>

Fork an agent, register it in A2A and access control, submit to scheduler, run the seed, then clean up.

pub async fn execute_directive( &self, directive: &Directive, env: &ExecEnv, priority: Priority, ) -> Result<ExecutionResult>

Fork an agent, register it in A2A and access control, submit to scheduler, run the directive + exec env, then clean up (RFC-027).

Mirrors spawn_and_run but operates on the unified-intent types. The legacy Seed variant stays for Phase 6.

pub async fn execute_with_feedback( &self, directive: &Directive, env: &ExecEnv, prev_result: &ExecutionResult, gaps: &[String], priority: Priority, ) -> Result<ExecutionResult>

Execute a directive with feedback from a previous failed attempt (RFC-027).

Injects the previous result’s output and the review gaps into the directive’s constraints so the agent sees what went wrong.

pub async fn terminate(&self, agent_id: AgentId) -> Result<()>

Kill an agent and clean up all registered state.

pub fn reap_zombies(&self) -> Vec<Uuid>

Reap finished zombie tasks and log the cleanup.

Trait Implementations

impl Clone for AgentLifecycleManager

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.