Struct Schedule 

pub struct Schedule {

    pub id: String,
    pub kind: String,
    pub payload: Vec<u8>,
    pub queue: String,
    pub partition_key: String,
    pub rate_class: String,
    pub priority: i32,
    pub max_attempts: u32,
    pub retention_ms: i64,
    pub spec: String,
    pub next_run_ms: i64,
    pub last_enqueued_ms: Option<i64>,
    pub on_missed: MissedPolicy,
    pub backfill_limit: u32,
    pub paused: bool,
}

A periodic entry. Durable in the store (surveyed policy behavior), never in a leader’s memory. The store treats spec as opaque; tick computation lives caller-side so every backend stays spec-agnostic.

Fields

id: String

kind: String

payload: Vec<u8>

queue: String

partition_key: String

rate_class: String

priority: i32

max_attempts: u32

retention_ms: i64

spec: String

“@every:” (epoch-aligned) or a UTC cron expression.

next_run_ms: i64

The next UNFIRED tick. Advancing past it is a compare-and-set, so racing scheduler nodes cannot double-advance.

last_enqueued_ms: Option<i64>

on_missed: MissedPolicy

backfill_limit: u32

paused: bool

Trait Implementations

impl Clone for Schedule

fn clone(&self) -> Schedule

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Schedule

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

Formats the value using the given formatter.