Struct LeanWorkerPoolConfig 

pub struct LeanWorkerPoolConfig { /* private fields */ }

Configuration for a local LeanWorkerPool.

Implementations

impl LeanWorkerPoolConfig

pub fn new(max_workers: usize) -> Self

Create pool configuration with a fixed local worker limit.

pub fn max_workers(&self) -> usize

Return the maximum number of local child workers the pool may own.

pub fn max_total_child_rss_kib(self, limit: u64) -> Self

Reject new distinct workers when known total child RSS reaches limit.

RSS sampling is best effort. On platforms where the pool cannot obtain samples, it records unavailable samples and does not make a false admission claim.

pub fn per_worker_rss_ceiling_kib(self, limit: u64) -> Self

Cycle a worker before assigning work when its sampled RSS reaches limit.

pub fn idle_cycle_after(self, limit: Duration) -> Self

Cycle an idle worker before assigning more work through an old lease.

pub fn queue_wait_timeout(self, timeout: Duration) -> Self

Wait this long for local pool admission before returning a typed error.

The current pool is synchronous. This timeout documents and bounds the admission point without exposing worker ids or queue internals.

pub fn max_total_child_rss_kib_limit(&self) -> Option<u64>

Return the configured total child RSS budget in KiB.

pub fn per_worker_rss_ceiling_kib_limit(&self) -> Option<u64>

Return the configured per-worker RSS ceiling in KiB.

pub fn idle_cycle_after_limit(&self) -> Option<Duration>

Return the configured idle-cycle duration.

pub fn queue_wait_timeout_limit(&self) -> Duration

Return the configured pool admission wait timeout.

Trait Implementations

impl Clone for LeanWorkerPoolConfig

fn clone(&self) -> LeanWorkerPoolConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for LeanWorkerPoolConfig

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

Formats the value using the given formatter.

impl Default for LeanWorkerPoolConfig

fn default() -> Self

Returns the “default value” for a type.

impl PartialEq for LeanWorkerPoolConfig

fn eq(&self, other: &LeanWorkerPoolConfig) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for LeanWorkerPoolConfig

impl StructuralPartialEq for LeanWorkerPoolConfig