Enum Schedule 

pub enum Schedule {
    Interval(Duration),
    StaggeredInterval(StaggeredIntervalSchedule),
    GroupedInterval(GroupedIntervalSchedule),
    GroupedCron(GroupedCronSchedule),
    WindowedInterval(WindowedIntervalSchedule),
    AtTimes(Vec<DateTime<Tz>>),
    Cron(CronSchedule),
}

Variants

Interval(Duration)

Trigger repeatedly after the given interval.

StaggeredInterval(StaggeredIntervalSchedule)

Trigger repeatedly after the given interval with a stable phase.

The first run is aligned to a deterministic phase derived from the seed. If no seed is provided, the job id is used.

GroupedInterval(GroupedIntervalSchedule)

Trigger repeatedly after the given interval with evenly spaced group members.

The first run is aligned to a stable slot determined by the member index. An optional group seed can rotate the entire group without changing the spacing between members.

GroupedCron(GroupedCronSchedule)

Trigger using a cron anchor and spread members inside each anchor window.

Each 5-field cron match becomes an anchor. The scheduler assigns each member a stable slot inside spread, then repeats that slot on every subsequent anchor.

WindowedInterval(WindowedIntervalSchedule)

Trigger repeatedly with frequencies selected by local time windows.

AtTimes(Vec<DateTime<Tz>>)

Trigger at the listed wall-clock times.

The list is sorted before execution starts. An empty list is treated as a no-op schedule and exits without running.

Cron(CronSchedule)

Trigger using a standard 5-field cron expression.

The scheduler timezone is used to calculate the next matching wall-clock time. The expression itself does not carry timezone information.

Implementations

impl Schedule

pub fn staggered_interval(every: Duration) -> Self

Create a staggered interval schedule that defaults to the job id as the phase seed.

pub fn staggered_interval_with_seed( every: Duration, seed: impl Into<String>, ) -> Self

Create a staggered interval schedule with an explicit phase seed.

pub fn grouped_interval( every: Duration, group_size: u32, member_index: u32, ) -> Self

Create a grouped interval schedule with evenly spaced members.

pub fn grouped_interval_with_seed( every: Duration, group_size: u32, member_index: u32, group_seed: impl Into<String>, ) -> Self

Create a grouped interval schedule and rotate the whole group with an explicit seed.

pub fn grouped_cron( cron: CronSchedule, spread: Duration, group_size: u32, member_index: u32, ) -> Self

Create a grouped cron schedule with evenly spaced members.

pub fn grouped_cron_with_seed( cron: CronSchedule, spread: Duration, group_size: u32, member_index: u32, group_seed: impl Into<String>, ) -> Self

Create a grouped cron schedule and rotate the whole group with an explicit seed.

pub fn windowed_interval(default_every: Option<Duration>) -> Self

Create a windowed interval schedule.

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.

impl Eq for Schedule

impl PartialEq for Schedule

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