Struct SchedulingQueue 

pub struct SchedulingQueue { /* private fields */ }

Scheduling queue

Implementations

impl SchedulingQueue

pub fn new() -> Self

Create new scheduling queue

pub fn enqueue(&self, workload: Workload)

Add workload to queue

pub fn dequeue(&self) -> Option<Workload>

Get next workload to schedule

pub fn peek(&self) -> Option<String>

Peek at next workload without removing

pub fn len(&self) -> usize

Get queue length

pub fn is_empty(&self) -> bool

Check if queue is empty

pub fn remove(&self, workload_id: &str) -> bool

Remove workload from queue

pub fn requeue_with_backoff(&self, queued: QueuedWorkload)

Re-queue a workload with backoff

Trait Implementations

impl Default for SchedulingQueue

fn default() -> Self

Returns the “default value” for a type.