Struct Fleet 

pub struct Fleet {
    pub agents: Vec<AgentSpec>,
    pub agent_timeout_secs: Option<u64>,
}

Fleet orchestrator — runs independent agents concurrently with shared knowledge.

Each agent gets its own Runtime (via SharedInfra) but they share state, event log, and policies. Agents communicate through the shared state (and optionally via Mailbox for real-time messaging).

Example

let fleet = Fleet::new(vec![
    AgentSpec::new("researcher", "Research competitor pricing"),
    AgentSpec::new("analyst", "Analyze market trends"),
]);
let result = fleet.run(&runner, &infra).await?;

Fields

agents: Vec<AgentSpec>

Agent specifications — each runs independently.

agent_timeout_secs: Option<u64>

Optional timeout per agent (seconds).

Implementations

impl Fleet

pub fn new(agents: Vec<AgentSpec>) -> Self

pub fn with_timeout(self, timeout_secs: u64) -> Self

pub async fn run( &self, runner: &Arc<dyn AgentRunner>, infra: &SharedInfra, ) -> Result<FleetResult, MultiError>

Run all agents concurrently. Returns when all complete (or timeout).