Struct FleetPool 

pub struct FleetPool { /* private fields */ }

A WorktreeAgent that spreads subtasks over a set of workers.

Implementations

impl FleetPool

pub fn new(workers: Vec<FleetWorker>) -> Self

Build a pool. Workers are tried in the order given when equally loaded, so put the preferred one first.

A pool with no workers is accepted and fails every subtask with a clear message — a caller that filtered its fleet down to nothing gets told so rather than getting a silent no-op run.

pub fn capacity(&self) -> usize

Total subtasks this pool can run at once.

pub fn worker_ids(&self) -> Vec<&str>

pub fn placements(&self) -> Vec<Placement>

Where each subtask ran, in completion order.

pub fn quarantined(&self) -> Vec<&str>

Workers removed from the pool mid-run, in declaration order.

Reported next to the pool’s build-time exclusions so a degraded run says so. A worker lands here only via ForemanError::Worker — see Self::run_in.

Trait Implementations

impl WorktreeAgent for FleetPool

fn run_in<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, req: &'life1 WorktreeAgentRequest<'life2>, ) -> Pin<Box<dyn Future<Output = Result<AgentRunSummary, ForemanError>> + Send + 'async_trait>>

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