Struct BeePool 

pub struct BeePool { /* private fields */ }

Pool of bees that routes tasks to idle workers.

Implementations

impl BeePool

pub fn new(config: &NodeConfig) -> Self

Create a new BeePool with N bees (N = config.cores), each with memory_per_bee budget.

pub fn bee_count(&self) -> usize

Return the number of bees in the pool.

pub async fn status(&self) -> Vec<BeeStatus>

Return the status of each bee.

pub async fn queue_size(&self) -> usize

Return the current number of queued tasks.

pub async fn busy_count(&self) -> usize

Return the current number of busy bees.

pub fn avg_memory_utilisation(&self) -> f64

Return the average memory utilization across all bees.

pub async fn submit<F>( &self, func: F, ) -> JoinHandle<Result<Vec<RecordBatch>, ApiaryError>>

where F: FnOnce() -> Result<Vec<RecordBatch>, ApiaryError> + Send + 'static,

Submit a task to the pool. If all bees are busy the task is queued. Returns the task result via the returned JoinHandle.

When colony temperature indicates Critical state (> 0.95), tasks are rejected immediately to protect the system from overload.