Enum SchedulerEvent

Source

pub enum SchedulerEvent {
Show 15 variants    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,
    },
    RunSkipped {
        job_id: String,
        scheduled_at: DateTime<Utc>,
        catch_up: bool,
        trigger_count: u32,
        reason: RunSkipReason,
    },
    RunCompleted {
        job_id: String,
        scheduled_at: DateTime<Utc>,
        catch_up: bool,
        trigger_count: u32,
        status: RunStatus,
        error: Option<String>,
    },
    ExecutionGuardAcquired {
        job_id: String,
        resource_id: String,
        scope: ExecutionGuardScope,
        lease_key: String,
        scheduled_at: Option<DateTime<Utc>>,
        catch_up: bool,
        trigger_count: u32,
    },
    ExecutionGuardContended {
        job_id: String,
        resource_id: String,
        scope: ExecutionGuardScope,
        scheduled_at: Option<DateTime<Utc>>,
        catch_up: bool,
        trigger_count: u32,
    },
    ExecutionGuardRenewed {
        job_id: String,
        resource_id: String,
        scope: ExecutionGuardScope,
        lease_key: String,
        scheduled_at: Option<DateTime<Utc>>,
        catch_up: bool,
        trigger_count: u32,
        renewal_count: u32,
    },
    ExecutionGuardRenewFailed {
        job_id: String,
        resource_id: String,
        scope: ExecutionGuardScope,
        lease_key: String,
        scheduled_at: Option<DateTime<Utc>>,
        catch_up: bool,
        trigger_count: u32,
        renewal_count: u32,
        failed_renewal_count: u32,
        error: String,
    },
    ExecutionGuardLost {
        job_id: String,
        resource_id: String,
        scope: ExecutionGuardScope,
        lease_key: String,
        scheduled_at: Option<DateTime<Utc>>,
        catch_up: bool,
        trigger_count: u32,
        renewal_count: u32,
        failed_renewal_count: u32,
    },
    ExecutionGuardReleased {
        job_id: String,
        resource_id: String,
        scope: ExecutionGuardScope,
        lease_key: String,
        scheduled_at: Option<DateTime<Utc>>,
        catch_up: bool,
        trigger_count: u32,
    },
    ExecutionGuardReleaseFailed {
        job_id: String,
        resource_id: String,
        scope: ExecutionGuardScope,
        lease_key: String,
        scheduled_at: Option<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,
    },
}