Struct JobScheduleUpsert 

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

Input for creating or updating a cron-backed job schedule.

Schedules are keyed by name. Updating an existing schedule refreshes the stored job type, payload template, cron expression, and jitter, while leaving scheduler-managed state intact. organization_id and is_active apply only when a new schedule row is inserted. next_fire_at applies on insert and when the cron expression changes.

Cron expressions are interpreted in UTC and must be accepted by cron::Schedule::from_str, the same parser used by runledger-runtime when materializing due schedules. The upsert validator rejects blank or padded schedule names, blank or padded cron expressions, invalid cron expressions, negative jitter, and jitter above 86,400 seconds.

This input does not encode a compile-time job catalog. The PostgreSQL schema requires a matching job-definition row for job_type, but this API does not prove that a worker process has registered a runtime handler for that job type.

Fields

name: &'a str

Stable unique schedule name without surrounding whitespace.

job_type: JobType<'a>

Job type to enqueue whenever the schedule fires.

organization_id: Option<Uuid>

Optional organization scope for enqueued jobs on first insert.

payload_template: &'a Value

JSON payload copied into each job created by the scheduler.

cron_expr: &'a str

UTC cron expression without surrounding whitespace, validated on upsert and parsed again when the schedule fires.

is_active: bool

Whether the runtime scheduler should claim this schedule on first insert.

next_fire_at: DateTime<Utc>

Initial fire cursor for the scheduler, also used when changing cron syntax.

max_jitter_seconds: i32

Maximum deterministic jitter applied when materializing a due schedule, capped at 86,400 seconds.

Trait Implementations

impl<'a> Clone for JobScheduleUpsert<'a>

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Debug for JobScheduleUpsert<'a>

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

Formats the value using the given formatter.