Struct CatalogJobScheduleSpec 

pub struct CatalogJobScheduleSpec<'a> {
    pub name: &'a str,
    pub job_type: &'a str,
    pub cron_expr: &'a str,
    pub payload_template: &'a Value,
    pub is_active: bool,
    pub organization_id: Option<Uuid>,
    pub max_jitter_seconds: i32,
    pub next_fire_at: Option<DateTime<Utc>>,
}

Catalog-owned cron schedule definition synced to job_schedules at startup.

Specs are validated before database writes. Names and cron expressions must be non-empty without surrounding whitespace, cron expressions must parse as UTC cron schedules, and max_jitter_seconds must be in the inclusive range 0..=JOB_SCHEDULE_MAX_JITTER_SECONDS.

Example

use runledger_runtime::catalog::CatalogJobScheduleSpec;

let payload = serde_json::json!({ "kind": "refresh" });
let spec = CatalogJobScheduleSpec {
    name: "profiles.refresh.hourly",
    job_type: "profiles.refresh",
    cron_expr: "0 0 * * * *",
    payload_template: &payload,
    is_active: true,
    organization_id: None,
    max_jitter_seconds: 0,
    next_fire_at: None,
};

assert_eq!(spec.name, "profiles.refresh.hourly");

Fields

name: &'a str

Unique schedule name. This is the global job_schedules.name key and must be non-empty without surrounding whitespace.

job_type: &'a str

Catalog job type enqueued when the schedule fires. The job type must be registered and effectively enabled in the super::JobCatalog used for schedule registration or sync.

cron_expr: &'a str

UTC cron expression without surrounding whitespace.

On conflict, catalog sync preserves the existing next_fire_at cursor when this expression is unchanged. When this expression changes, the synced next_fire_at value becomes the stored cursor.

payload_template: &'a Value

JSON payload template copied into scheduled jobs.

is_active: bool

Desired active state after sync. Applications can map feature flags to this value before calling catalog schedule sync.

organization_id: Option<Uuid>

Optional organization scope copied into jobs for a new schedule.

max_jitter_seconds: i32

Maximum deterministic jitter, in seconds, applied to future fire times. Must be between 0 and JOB_SCHEDULE_MAX_JITTER_SECONDS, inclusive.

next_fire_at: Option<DateTime<Utc>>

Next UTC instant at which the schedule is due. Defaults to Utc::now() when unset at sync time.

This value is used for new rows and for existing rows whose cron expression changed. Existing rows with the same cron expression keep their stored cursor.

Trait Implementations

impl<'a> Clone for CatalogJobScheduleSpec<'a>

fn clone(&self) -> CatalogJobScheduleSpec<'a>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Debug for CatalogJobScheduleSpec<'a>

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

Formats the value using the given formatter.

impl<'a> Eq for CatalogJobScheduleSpec<'a>

impl<'a> PartialEq for CatalogJobScheduleSpec<'a>

fn eq(&self, other: &CatalogJobScheduleSpec<'a>) -> 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<'a> StructuralPartialEq for CatalogJobScheduleSpec<'a>