Enum SchedulerEvent 

pub enum SchedulerEvent {
    StateLoaded {
        job_id: String,
        trigger_count: u32,
        next_run_at: Option<DateTime<Utc>>,
        source: StateLoadSource,
    },
    StateRepaired {
        job_id: String,
        trigger_count: u32,
        previous_next_run_at: Option<DateTime<Utc>>,
        repaired_next_run_at: Option<DateTime<Utc>>,
    },
    TriggerEmitted {
        job_id: String,
        scheduled_at: DateTime<Utc>,
        catch_up: bool,
        trigger_count: u32,
    },
    RunCompleted {
        job_id: String,
        scheduled_at: DateTime<Utc>,
        catch_up: bool,
        trigger_count: u32,
        status: RunStatus,
        error: Option<String>,
    },
    ExecutionGuardContended {
        job_id: String,
        scheduled_at: DateTime<Utc>,
        catch_up: bool,
        trigger_count: u32,
    },
    ExecutionGuardLost {
        job_id: String,
        scheduled_at: DateTime<Utc>,
        catch_up: bool,
        trigger_count: u32,
    },
    ExecutionGuardReleaseFailed {
        job_id: String,
        scheduled_at: DateTime<Utc>,
        catch_up: bool,
        trigger_count: u32,
        error: String,
    },
    StoreDegraded {
        job_id: String,
        operation: StoreOperation,
        error: String,
    },
    TerminalStateDeleted {
        job_id: String,
        trigger_count: u32,
    },
    SchedulerStopped {
        job_id: String,
        trigger_count: u32,
        reason: SchedulerStopReason,
    },
}

Variants

StateLoaded

Fields

job_id: String

trigger_count: u32

next_run_at: Option<DateTime<Utc>>

source: StateLoadSource

StateRepaired

Fields

job_id: String

trigger_count: u32

previous_next_run_at: Option<DateTime<Utc>>

repaired_next_run_at: Option<DateTime<Utc>>

TriggerEmitted

Fields

job_id: String

scheduled_at: DateTime<Utc>

catch_up: bool

trigger_count: u32

RunCompleted

Fields

job_id: String

scheduled_at: DateTime<Utc>

catch_up: bool

trigger_count: u32

status: RunStatus

error: Option<String>

ExecutionGuardContended

Fields

job_id: String

scheduled_at: DateTime<Utc>

catch_up: bool

trigger_count: u32

ExecutionGuardLost

Fields

job_id: String

scheduled_at: DateTime<Utc>

catch_up: bool

trigger_count: u32

ExecutionGuardReleaseFailed

Fields

job_id: String

scheduled_at: DateTime<Utc>

catch_up: bool

trigger_count: u32

error: String

StoreDegraded

Fields

job_id: String

operation: StoreOperation

error: String

TerminalStateDeleted

Fields

job_id: String

trigger_count: u32

SchedulerStopped

Fields

job_id: String

trigger_count: u32

reason: SchedulerStopReason

Trait Implementations

impl Clone for SchedulerEvent

fn clone(&self) -> SchedulerEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SchedulerEvent

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

Formats the value using the given formatter.

impl PartialEq for SchedulerEvent

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

impl StructuralPartialEq for SchedulerEvent