Struct JobItem 

pub struct JobItem { /* private fields */ }

An internal wrapper around a JobContract that caches the parsed schedule and exposes helper methods used by the scheduler.

Constructed once per registered job via JobItem::new, ensuring the schedule is valid at registration time rather than at execution time.

Implementations

impl JobItem

pub fn new( job: Arc<dyn JobContract>, listeners: Vec<Arc<dyn JobEventListener>>, metrics_exporter: Option<Arc<dyn MetricsExporter>>, job_store: Option<Arc<dyn JobStore>>, ) -> CronResult<Self>

Wrap a JobContract implementor.

The schedule is validated via JobContract::schedule at this point. Returns an error if the job’s schedule is invalid.

pub fn id(&self) -> Cow<'_, str>

The job’s stable unique identifier.

pub fn name(&self) -> Cow<'_, str>

The job’s human-readable name.

pub fn job_type(&self) -> JobType

The type of job.

pub fn next_run_time(&self) -> Option<DateTime<Utc>>

Computes the next scheduled execution time from now.

pub fn next_run_after(&self, after: DateTime<Utc>) -> Option<DateTime<Utc>>

Computes the next scheduled execution time after a specific time.

pub fn priority(&self) -> i32

Returns the job’s priority.

pub fn concurrency_limit(&self) -> Option<usize>

Returns the job’s concurrency limit.

pub fn misfire_policy(&self) -> MisfirePolicy

Returns the job’s misfire policy.

pub async fn run(&self) -> CronResult<()>

Runs the lifecycle sequence: on_start → run → on_complete / on_error. Handles timeouts and retries internally.

Trait Implementations

impl Clone for JobItem

fn clone(&self) -> JobItem

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for JobItem

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

Formats the value using the given formatter.