Struct LeanWorkerPool 

pub struct LeanWorkerPool { /* private fields */ }

Local pool for worker-backed capability sessions.

Implementations

impl LeanWorkerPool

pub fn new(config: LeanWorkerPoolConfig) -> Self

Create an empty local worker pool.

pub fn acquire_lease( &mut self, builder: LeanWorkerCapabilityBuilder, ) -> Result<LeanWorkerSessionLease<'_>, LeanWorkerError>

Acquire a lease for the capability described by builder.

The pool reuses a warm compatible worker session when possible. If a matching worker has died, the pool replaces it before returning the lease. If admitting a distinct session key would exceed max_workers, the pool returns LeanWorkerError::WorkerPoolExhausted.

Errors

Returns LeanWorkerError when the capability cannot be built, metadata validation fails, a dead compatible worker cannot be replaced, or the fixed local worker limit is already full of distinct session keys.

pub fn snapshot(&self) -> LeanWorkerPoolSnapshot

Return a public snapshot of pool state.

Trait Implementations

impl Debug for LeanWorkerPool

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

Formats the value using the given formatter.

impl Default for LeanWorkerPool

fn default() -> Self

Returns the “default value” for a type.