Struct SchedulerJobRecord 

pub struct SchedulerJobRecord {
    pub id: QName,
    pub status: SchedulerJobStatus,
    pub next_fire_at: Option<SystemTime>,
    pub last_started_at: Option<SystemTime>,
    pub last_finished_at: Option<SystemTime>,
    pub consecutive_failures: u32,
    pub schedule: Schedule,
    pub cancel: CancellationToken,
}

Persistable record of a scheduled job’s state.

Round-trips through uni_system.background_jobs in M11 cutover.

Fields

id: QName

Job id.

status: SchedulerJobStatus

Lifecycle status.

next_fire_at: Option<SystemTime>

When the next fire of this job is due. None for Manual schedules until Scheduler::add_job marks the job Pending, at which point it is eligible immediately.

last_started_at: Option<SystemTime>

When the most-recent run started.

last_finished_at: Option<SystemTime>

When the most-recent run finished.

consecutive_failures: u32

Number of consecutive failures since the last success.

schedule: Schedule

Schedule describing when fires are eligible.

cancel: CancellationToken

Cancellation token; flipped on cancel() or shutdown.

Implementations

impl SchedulerJobRecord

pub fn pending(id: QName) -> Self

Construct a pending record with the legacy Manual schedule.

Equivalent to pending_with_schedule(id, Schedule::Manual, SystemTime::now()).

pub fn pending_with_schedule( id: QName, schedule: Schedule, now: SystemTime, ) -> Self

Construct a pending record with an explicit schedule.

now is used both as the initial registration instant and as the reference point for the first next_fire_at computation.

Trait Implementations

impl Clone for SchedulerJobRecord

fn clone(&self) -> SchedulerJobRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SchedulerJobRecord

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

Formats the value using the given formatter.

impl PartialEq for SchedulerJobRecord

fn eq(&self, other: &Self) -> bool

Two records are equal iff all their persisted state matches.

Previously this compared only id and status, so two records that differed in schedule, next_fire_at, or consecutive_failures (i.e. genuinely-different job states) would still compare equal. The cancel field is intentionally excluded because it is per-process identity (an Arc<AtomicBool>) and is not part of the persisted record.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.