Struct PoolConfig 

pub struct PoolConfig {

    pub name: Arc<str>,
    pub min_workers: u32,
    pub max_workers: u32,
    pub initial_workers: u32,
    pub autoscale: Option<AutoscaleConfig>,
    pub retry: RetryPolicy,
    pub bounds: Bounds,
    pub overflow: OverflowPolicy,
    pub reservable_fraction: f64,
    pub default_duration: Duration,
    pub max_hold: Duration,
    pub lease_ttl: Option<Duration>,
    pub unknown_dependency: UnknownDependency,
    pub fairness: Option<Fairness>,
}

Engine types re-exported for convenience. A worker pool: capacity limits, scaling, retries, queue bounds and fixed-start behaviour.

Fields

name: Arc<str>

Unique pool name.

min_workers: u32

Lower bound on the autoscaler’s desired capacity. Capacity itself may be lower, for example at start (initial_workers) or when it is reported by remote workers.

max_workers: u32

Upper capacity bound for the autoscaler (also sizes the reservation limit).

initial_workers: u32

Capacity at start (at most max_workers).

autoscale: Option<AutoscaleConfig>

None disables autoscaling (capacity changes only via CapacityChanged).

retry: RetryPolicy

Default retry policy for tasks without their own.

bounds: Bounds

Pool queue bounds.

overflow: OverflowPolicy

What to do when a bound is hit.

reservable_fraction: f64

Fraction of max_workers that fixed-start reservations may occupy at once (at least 1 slot).

default_duration: Duration

Duration estimate when nothing else is known.

max_hold: Duration

Earliest a worker may be held free ahead of a fixed-start task.

lease_ttl: Option<Duration>

Lease time-to-live; Some for remote workers that must heartbeat.

unknown_dependency: UnknownDependency

Handling of dependencies on unknown keys.

fairness: Option<Fairness>

Weighted fair sharing between tenants (None: tasks of a class run in submission order whatever their tenant).

Implementations

impl PoolConfig

pub fn new(name: impl Into<Arc<str>>) -> PoolConfig

Autoscaled pool with defaults: 1..=10 workers, starting at 1.

pub fn fixed(name: impl Into<Arc<str>>, workers: u32) -> PoolConfig

Fixed worker count, no autoscaling.

pub fn workers(self, min: u32, initial: u32, max: u32) -> PoolConfig

Set min, initial and max worker counts.

Trait Implementations

impl Clone for PoolConfig

fn clone(&self) -> PoolConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PoolConfig

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

Formats the value using the given formatter.