Enum Mutation 

pub enum Mutation<P> {
    Submitted {
        id: TaskId,
        seq: u64,
        arrival: Time,
        spec: TaskSpec<P>,
    },
    Status {
        id: TaskId,
        status: TaskStatus,
        attempt: u32,
        at: Time,
        message: Option<Arc<str>>,
    },
    RecurringUpsert {
        spec: RecurringSpec<P>,
    },
    RecurringRemove {
        name: Arc<str>,
    },
    RecurringNext {
        name: Arc<str>,
        next: Option<Time>,
        last: Option<TaskId>,
    },
}

Durable state change (emitted only with CoreConfig::persist).

Variants

Submitted

A task was accepted.

Fields

id: TaskId

Task id.

seq: u64

Submission sequence number (FIFO tie-break).

arrival: Time

Submission time.

spec: TaskSpec<P>

The task spec.

Status

A task changed status.

Fields

id: TaskId

Task id.

status: TaskStatus

New status.

attempt: u32

Attempts made so far.

at: Time

Time of the transition.

message: Option<Arc<str>>

Error or reason, if any.

RecurringUpsert

A recurring schedule was added or replaced.

Fields

spec: RecurringSpec<P>

The schedule.

RecurringRemove

A recurring schedule was removed.

Fields

name: Arc<str>

Schedule name.

RecurringNext

Next occurrence time of a recurring schedule.

Fields

name: Arc<str>

Schedule name.

next: Option<Time>

Next occurrence (None = the schedule has ended).

last: Option<TaskId>

Task of the latest occurrence a queued schedule chains to (None = no chain yet).

Trait Implementations

impl<P> Clone for Mutation<P>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<P: Debug> Debug for Mutation<P>

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

Formats the value using the given formatter.