Struct QueueingScheduler 

pub struct QueueingScheduler { /* private fields */ }

Queueing theory scheduler with fair SRPT.

Implementations

impl QueueingScheduler

pub fn new(config: SchedulerConfig) -> Self

Create a new scheduler with given configuration.

pub fn submit(&mut self, weight: f64, estimated_time: f64) -> Option<u64>

Submit a new job to the scheduler.

Returns the job ID if accepted, None if rejected (queue full).

pub fn submit_named( &mut self, weight: f64, estimated_time: f64, name: Option<impl Into<String>>, ) -> Option<u64>

Submit a named job.

pub fn submit_with_sources( &mut self, weight: f64, estimated_time: f64, weight_source: WeightSource, estimate_source: EstimateSource, name: Option<impl Into<String>>, ) -> Option<u64>

Submit a job with explicit estimate/weight sources for evidence logging.

pub fn tick(&mut self, delta_time: f64) -> Vec<u64>

Advance time by the given amount and process jobs.

Returns a list of completed job IDs.

pub fn peek_next(&self) -> Option<&Job>

Select the next job to run without advancing time.

pub fn evidence(&self) -> SchedulingEvidence

Get scheduling evidence for the current state.

pub fn stats(&self) -> SchedulerStats

Get current statistics.

pub fn cancel(&mut self, job_id: u64) -> bool

Cancel a job by ID.

pub fn clear(&mut self)

Clear all jobs.

pub fn reset(&mut self)

Reset scheduler state.

Trait Implementations

impl Debug for QueueingScheduler

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

Formats the value using the given formatter.