Struct CronRunner 

pub struct CronRunner { /* private fields */ }

Implementations

impl CronRunner

pub fn new( store: Arc<dyn CronStore>, dispatcher: Arc<dyn CronDispatcher>, ) -> Self

pub fn with_tick_interval(self, interval: Duration) -> Self

pub fn with_one_shot_retry_policy(self, policy: OneShotRetryPolicy) -> Self

pub fn with_jitter_pct(self, pct: u32) -> Self

Backward-compat shim — pct (0..=100) maps to a fresh CronJitterConfig with recurring_frac = pct / 100.0. New callers should pass a hot-reloaded Arc<ArcSwap<CronJitterConfig>> via Self::with_jitter_cfg.

pub fn with_jitter_cfg(self, cfg: Arc<ArcSwap<CronJitterConfig>>) -> Self

Wire a hot-reloaded jitter config.

pub async fn tick_once(&self, now_unix: i64) -> Vec<FireOutcome>

Run a single tick at now_unix and advance state. Returns one outcome per entry that was due. Test-friendly.

pub async fn run(self: Arc<Self>, cancel: CancellationToken)

Run forever (until cancel fires). Production wiring spawns this on a tokio task.