Struct Job 

pub struct Job<D = ()> {
    pub job_id: String,
    pub execution_resource_id: String,
    pub guard_scope: ExecutionGuardScope,
    pub schedule: Schedule,
    pub time_window: Option<JobTimeWindow>,
    pub max_runs: Option<u32>,
    pub missed_run_policy: MissedRunPolicy,
    pub overlap_policy: OverlapPolicy,
    /* private fields */
}

Fields

job_id: String

execution_resource_id: String

guard_scope: ExecutionGuardScope

schedule: Schedule

time_window: Option<JobTimeWindow>

max_runs: Option<u32>

missed_run_policy: MissedRunPolicy

overlap_policy: OverlapPolicy

Implementations

impl Job<()>

pub fn without_deps( job_id: impl Into<String>, schedule: Schedule, task: Task<()>, ) -> Self

Create a job that uses no injected dependencies.

impl<D> Job<D>

where D: Send + Sync + 'static,

pub fn new( job_id: impl Into<String>, schedule: Schedule, deps: impl Into<Arc<D>>, task: Task<D>, ) -> Self

Create a job from explicit dependencies and a task handler.

impl<D> Job<D>

pub fn with_max_runs(self, max_runs: u32) -> Self

Limit how many triggers this job can consume before it exits.

This applies to Schedule::Interval, Schedule::AtTimes, and Schedule::Cron. A value of 0 makes the job exit immediately without running.

pub fn with_missed_run_policy(self, policy: MissedRunPolicy) -> Self

pub fn with_overlap_policy(self, policy: OverlapPolicy) -> Self

pub fn with_time_window(self, time_window: JobTimeWindow) -> Self

pub fn with_execution_resource_id(self, resource_id: impl Into<String>) -> Self

pub fn with_guard_scope(self, scope: ExecutionGuardScope) -> Self

Trait Implementations

impl<D: Clone> Clone for Job<D>

fn clone(&self) -> Job<D>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<D> Debug for Job<D>

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

Formats the value using the given formatter.