Struct SchedulerConfig 

pub struct SchedulerConfig {
    pub shards: usize,
    pub max_global: usize,
    pub max_per_tenant: usize,
    pub quantum: u64,
    pub quantum_by_tenant: HashMap<TenantKey, u64>,
    pub quantum_provider: Option<Arc<dyn Fn(TenantKey) -> u64 + Send + Sync>>,
    pub backpressure: BackpressurePolicy,
    pub backpressure_by_tenant: HashMap<TenantKey, BackpressurePolicy>,
    pub top_tenants_capacity: usize,
}

Scheduler runtime configuration.

Fields

shards: usize

Number of shards used to partition tenant state.

max_global: usize

Global queue capacity across all tenants.

max_per_tenant: usize

Maximum pending live tasks per tenant.

Cancelled/expired entries are compacted lazily and are not intended to consume this limit once reclaimed.

quantum: u64

Base DRR quantum for tenants without overrides.

quantum_by_tenant: HashMap<TenantKey, u64>

Static per-tenant DRR quantum overrides.

quantum_provider: Option<Arc<dyn Fn(TenantKey) -> u64 + Send + Sync>>

Dynamic per-tenant DRR quantum provider.

backpressure: BackpressurePolicy

Default backpressure policy.

backpressure_by_tenant: HashMap<TenantKey, BackpressurePolicy>

Per-tenant backpressure policy overrides.

top_tenants_capacity: usize

Maximum number of tenants tracked in top-talker metrics.

Trait Implementations

impl Clone for SchedulerConfig

fn clone(&self) -> SchedulerConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SchedulerConfig

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

Formats the value using the given formatter.

impl Default for SchedulerConfig

fn default() -> Self

Returns the “default value” for a type.