cloudiful-scheduler 0.4.7

Single-job async scheduling library for background work with optional Valkey-backed state.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47

use super::engine::Scheduler;
use super::runtime_events::{state_loaded, state_repaired};
use crate::error::SchedulerError;
use crate::model::{Job, JobState};
use crate::observer::StateLoadSource;

pub(super) fn initial_runtime_state<S, G, C, D>(
    scheduler: &Scheduler<S, G, C>,
    job: &Job<D>,
) -> Result<JobState, SchedulerError>
where
    S: crate::StateStore + Send + Sync + 'static,
    G: crate::ExecutionGuard + Send + Sync + 'static,
    C: crate::CoordinatedStateStore + Send + Sync + 'static,
    D: Send + Sync + 'static,
{
    Ok(JobState::new(
        job.job_id.clone(),
        crate::scheduler::trigger_math::initial_next_run_at(job, scheduler.config.timezone)?,
    ))
}

pub(super) fn emit_state_loaded<S, G, C>(
    scheduler: &Scheduler<S, G, C>,
    job_id: &str,
    state: &JobState,
    source: StateLoadSource,
) where
    S: crate::StateStore + Send + Sync + 'static,
    G: crate::ExecutionGuard + Send + Sync + 'static,
    C: crate::CoordinatedStateStore + Send + Sync + 'static,
{
    scheduler.emit(state_loaded(job_id, state, source));
}

pub(super) fn emit_state_repaired<S, G, C>(
    scheduler: &Scheduler<S, G, C>,
    job_id: &str,
    state: &JobState,
    previous_next_run_at: Option<chrono::DateTime<chrono::Utc>>,
) where
    S: crate::StateStore + Send + Sync + 'static,
    G: crate::ExecutionGuard + Send + Sync + 'static,
    C: crate::CoordinatedStateStore + Send + Sync + 'static,
{
    scheduler.emit(state_repaired(job_id, state, previous_next_run_at));
}