Struct PeriodicJob 

pub struct PeriodicJob {
    pub name: String,
    pub cron_expr: String,
    pub timezone: String,
    pub kind: String,
    pub queue: String,
    pub args: Value,
    pub priority: i16,
    pub max_attempts: i16,
    pub tags: Vec<String>,
    pub metadata: Value,
}

A periodic job schedule definition.

Created via PeriodicJob::builder(name, cron_expr).build(args).

Fields

name: String

Unique name identifying this schedule (e.g., “daily_report”).

cron_expr: String

Cron expression (e.g., “0 9 * * *”).

timezone: String

IANA timezone (e.g., “Pacific/Auckland”). Defaults to “UTC”.

kind: String

Job kind (derived from JobArgs trait).

queue: String

Target queue. Defaults to “default”.

args: Value

Serialized job arguments.

priority: i16

Job priority (1-4). Defaults to 2.

max_attempts: i16

Max retry attempts. Defaults to 25.

tags: Vec<String>

Tags attached to created jobs.

metadata: Value

Extra metadata merged into created jobs.

Implementations

impl PeriodicJob

pub fn builder( name: impl Into<String>, cron_expr: impl Into<String>, ) -> PeriodicJobBuilder

Start building a periodic job with a name and cron expression.

The cron expression is validated eagerly — invalid expressions cause build() to return an error.

pub fn latest_fire_time( &self, now: DateTime<Utc>, after: Option<DateTime<Utc>>, ) -> Option<DateTime<Utc>>

Compute the latest fire time <= now that is strictly after after.

Returns None if no fire time exists in the range (after, now]. This handles both “first registration” (after=None → find latest past fire) and “regular evaluation” (after=Some(last_enqueued_at)).

Trait Implementations

impl Clone for PeriodicJob

fn clone(&self) -> PeriodicJob

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PeriodicJob

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

Formats the value using the given formatter.