Struct ScheduledIndex 

pub struct ScheduledIndex { /* private fields */ }

A view of all runs in the Scheduled state.

This structure provides filtering and traversal over runs that are waiting to become ready. Runs transition from Scheduled to Ready when the scheduled_at timestamp has passed according to the scheduler clock.

Implementations

impl ScheduledIndex

pub fn new() -> Self

Creates a new empty scheduled index.

pub fn from_runs(runs: Vec<RunInstance>) -> Self

Creates a scheduled index from a vector of runs.

All runs must be in the Scheduled state.

pub fn runs(&self) -> &[RunInstance]

Returns all runs in the scheduled index.

pub fn len(&self) -> usize

Returns the number of runs in the scheduled index.

pub fn is_empty(&self) -> bool

Returns true if the index contains no runs.

pub fn ready_for_promotion(&self, current_time: u64) -> Vec<&RunInstance>

Filters runs that are ready to transition to the Ready state.

A run is ready for promotion if its scheduled_at time has passed.

pub fn waiting(&self, current_time: u64) -> Vec<&RunInstance>

Filters runs that are still waiting to become ready.

A run is still waiting if its scheduled_at time is in the future.

Trait Implementations

impl Clone for ScheduledIndex

fn clone(&self) -> ScheduledIndex

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ScheduledIndex

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

Formats the value using the given formatter.

impl Default for ScheduledIndex

fn default() -> ScheduledIndex

Returns the “default value” for a type.

impl From<&[RunInstance]> for ScheduledIndex

fn from(runs: &[RunInstance]) -> Self

Converts to this type from the input type.

impl PartialEq for ScheduledIndex

fn eq(&self, other: &ScheduledIndex) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for ScheduledIndex

impl StructuralPartialEq for ScheduledIndex