Struct ExecutorPool 

pub struct ExecutorPool { /* private fields */ }

Pool of executors for a supervisor.

Implementations

impl ExecutorPool

pub fn new( supervisor_id: impl Into<String>, initial_size: usize, ) -> ExecutorPoolBuilder

Create a new pool.

Example

let pool = ExecutorPool::new("sup-001", 4)
    .llm_gemini("gemini-2.0-flash")
    .build();

pub async fn get_idle(&self) -> Option<Arc<Executor>>

Get an idle executor.

pub async fn get_all_idle(&self) -> Vec<Arc<Executor>>

Get all idle executors.

pub async fn get_n_idle(&self, n: usize) -> Vec<Arc<Executor>>

Get N idle executors.

pub async fn get(&self, id: &str) -> Option<Arc<Executor>>

Get executor by ID.

pub async fn size(&self) -> usize

Get pool size.

pub async fn idle_count(&self) -> usize

Get idle count.

pub async fn busy_count(&self) -> usize

Get busy count.

pub async fn utilization(&self) -> f32

Get utilization (0.0-1.0).

pub async fn add_executor(&self) -> Arc<Executor>

Add a new executor to the pool.

pub async fn remove_idle(&self) -> Option<String>

Remove an idle executor.

pub async fn scale_up(&self, n: usize)

Scale up by n executors.

pub async fn scale_down(&self, n: usize)

Scale down by n executors.

pub async fn auto_scale(&self)

Auto-scale based on utilization.

pub async fn executor_ids(&self) -> Vec<String>

Get all executor IDs.

Trait Implementations

impl Debug for ExecutorPool

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.