Struct PoolSection 

pub struct PoolSection {

    pub name: String,
    pub min: u32,
    pub max: u32,
    pub autoscale: bool,
    pub scaler: ScalerSection,
    pub lease_ttl_s: f64,
    pub max_pending: Option<usize>,
    pub overflow: Overflow,
    pub retry: Option<RetrySection>,
    pub default_duration_s: Option<f64>,
    pub reservable_fraction: Option<f64>,
    pub await_unknown_dependencies_s: Option<f64>,
    pub target_utilization: Option<f64>,
    pub drain_time_s: Option<f64>,
    pub cooldown_s: Option<f64>,
    pub cost_per_worker_second: Option<f64>,
    pub max_slots_per_worker: Option<u32>,
    pub fair_share: bool,
    pub tenant_weights: BTreeMap<String, f64>,
}

One pool served by remote workers.

Fields

name: String

Pool name (1-64 characters from [A-Za-z0-9_.:-]).

min: u32

Autoscaler lower bound.

max: u32

Autoscaler upper bound, reservation capacity basis, and per-worker slot cap.

autoscale: bool

Compute a desired capacity from queue pressure.

scaler: ScalerSection

How the desired capacity is communicated.

lease_ttl_s: f64

Remote workers must heartbeat each lease within this many seconds.

max_pending: Option<usize>

Pending-task bound (default limits.max_pending_per_pool).

overflow: Overflow

Behaviour when the bound is reached.

retry: Option<RetrySection>

Default retry policy.

default_duration_s: Option<f64>

Duration estimate when nothing is known.

reservable_fraction: Option<f64>

Share of max that fixed-start reservations may occupy, in (0, 1].

await_unknown_dependencies_s: Option<f64>

Allow dependencies on keys that do not exist yet (wait up to this many seconds).

target_utilization: Option<f64>

Autoscaler utilization target, in (0, 1].

drain_time_s: Option<f64>

Autoscaler backlog drain target.

cooldown_s: Option<f64>

Autoscaler scale-down cooldown.

cost_per_worker_second: Option<f64>

Cost per worker-second, for the cost metric.

max_slots_per_worker: Option<u32>

Slots a single worker may register in this pool (default limits.max_slots_per_worker, never above max).

fair_share: bool

Share the pool fairly between tenants (implied by tenant_weights).

tenant_weights: BTreeMap<String, f64>

Weight of each tenant in the fair share (others weigh 1).

Implementations

impl PoolSection

pub fn named(name: &str) -> Self

A pool with default settings.

pub fn slot_cap(&self, limits: &LimitsConfig) -> u32

Slots one worker may register in this pool.

pub fn to_pool_config(&self, limits: &LimitsConfig) -> PoolConfig

Engine configuration. Assumes Config::validate passed.

Trait Implementations

impl Clone for PoolSection

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PoolSection

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for PoolSection

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.