Struct RunningIndex 

pub struct RunningIndex { /* private fields */ }

A view of all active runs (Leased and Running).

This structure provides filtering and traversal over runs that are currently in-flight. Active runs transition from Running to either:

• RetryWait (on failure, if retries remain)
• Completed (on success)
• Failed (on failure, no retries remaining)
• Canceled

Implementations

impl RunningIndex

pub fn new() -> Self

Creates a new empty running index.

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

Creates a running index from a vector of runs.

All runs must be in the Leased or Running state.

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

Returns all runs in the running index.

pub fn len(&self) -> usize

Returns the number of runs in the running index.

pub fn is_empty(&self) -> bool

Returns true if the index contains no runs.

pub fn leased(&self) -> Vec<&RunInstance>

Returns only leased runs.

pub fn executing(&self) -> Vec<&RunInstance>

Returns only currently executing runs.

Trait Implementations

impl Clone for RunningIndex

fn clone(&self) -> RunningIndex

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RunningIndex

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

Formats the value using the given formatter.

impl Default for RunningIndex

fn default() -> RunningIndex

Returns the “default value” for a type.

impl From<&[RunInstance]> for RunningIndex

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

Converts to this type from the input type.

impl PartialEq for RunningIndex

fn eq(&self, other: &RunningIndex) -> 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 RunningIndex

impl StructuralPartialEq for RunningIndex