Struct Recovered 

pub struct Recovered<P> {
    pub tasks: Vec<RecoveredTask<P>>,
    pub terminal: Vec<RecoveredTerminal>,
    pub recurring: Vec<RecoveredRecurring<P>>,
    pub next_id: u64,
}

Engine state restored from durable storage, passed to Core::recover.

Fields

tasks: Vec<RecoveredTask<P>>

Live (non-terminal) tasks.

terminal: Vec<RecoveredTerminal>

Recently finished tasks.

recurring: Vec<RecoveredRecurring<P>>

Recurring schedules.

next_id: u64

Lowest task id the engine may hand out next.

Implementations

impl<P> Recovered<P>

pub fn outside_shard(&self, shard: u8) -> Option<TaskId>

The first recovered task id that does not belong to shard, if any: the store holds tasks of another shard. Ids of an unsharded server are caught only when their top byte differs from shard (early epochs look like shard 0’s), so give shards new stores.

Trait Implementations

impl<P: Debug> Debug for Recovered<P>

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

Formats the value using the given formatter.

impl<P> Default for Recovered<P>

fn default() -> Self

Returns the “default value” for a type.