Struct BasicSupervisor 

pub struct BasicSupervisor { /* private fields */ }

Basic in-memory supervisor implementation with AgentRuntime integration.

Implementations

impl BasicSupervisor

pub fn new(event_bus: EventBus, runtime: AgentRuntime) -> Self

Creates a new supervisor with the given event bus and agent runtime.

pub fn set_resource_monitor(&mut self, rm: Arc<ResourceMonitor>)

Attach a resource monitor for agent count tracking.

pub fn pool(&self) -> &AgentPool

Access the agent pool for session continuation.

Trait Implementations

impl Supervisor for BasicSupervisor

fn fork<'life0, 'life1, 'async_trait>( &'life0 self, spec: &'life1 Seed, ) -> Pin<Box<dyn Future<Output = Result<AgentId>> + Send + 'async_trait>>

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

Fork a new agent from a seed specification.

fn exec<'life0, 'async_trait>( &'life0 self, id: AgentId, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Start executing an agent.

fn run_with_seed<'life0, 'life1, 'async_trait>( &'life0 self, id: AgentId, seed: &'life1 Seed, ) -> Pin<Box<dyn Future<Output = Result<ExecutionResult>> + Send + 'async_trait>>

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

Fork and execute an agent with its seed, running to completion. Returns the execution result from the agent runtime.

fn wait<'life0, 'async_trait>( &'life0 self, id: AgentId, ) -> Pin<Box<dyn Future<Output = Result<AgentStatus>> + Send + 'async_trait>>

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

Wait for an agent to complete and return its final status.

fn kill<'life0, 'async_trait>( &'life0 self, id: AgentId, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Terminate an agent.

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

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

List all known agents.