Struct RecurringJob 

pub struct RecurringJob {
    pub id: String,
    pub cron: String,
    pub method: String,
    pub payload: Value,
    pub queue: String,
    pub next_run_at: DateTime<Utc>,
    pub last_run_at: Option<DateTime<Utc>>,
    pub created_at: DateTime<Utc>,
    pub updated_at: DateTime<Utc>,
    pub enabled: bool,
}

A cron-scheduled job template.

Fields

id: String

Stable recurring-job id (caller-chosen, e.g. "daily-report").

cron: String

Cron expression in the cron crate’s 6/7-field format (sec min hour day month dow [year]).

method: String

Method name registered with the worker registry.

payload: Value

JSON payload passed to the worker on each firing.

queue: String

Queue the materialized jobs land in.

next_run_at: DateTime<Utc>

Next firing time (computed from cron).

last_run_at: Option<DateTime<Utc>>

When the template last produced a job, or None if never fired.

created_at: DateTime<Utc>

When the template was first created.

updated_at: DateTime<Utc>

When the template was last mutated.

enabled: bool

Disabled templates are ignored by the poller.

Implementations

impl RecurringJob

pub fn new( id: impl Into<String>, cron: impl Into<String>, method: impl Into<String>, payload: JsonValue, queue: impl Into<String>, ) -> Result<Self>

Creates a new recurring-job template. Parses cron and computes next_run_at from now. Returns a validation error if the expression is invalid or has no future occurrences.

pub fn advance(&mut self, from: DateTime<Utc>) -> Result<()>

Recomputes next_run_at to the next occurrence strictly after from, updating updated_at in the process. Returns an error if the stored cron expression is no longer parseable or has no future occurrence (the latter shouldn’t happen for sane expressions).

pub fn schedule(&self) -> Result<Schedule>

Parses the stored cron expression. Useful when a caller needs more than just “next firing” (e.g. listing upcoming runs).

Trait Implementations

impl Clone for RecurringJob

fn clone(&self) -> RecurringJob

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RecurringJob

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RecurringJob

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for RecurringJob

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

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for RecurringJob