Struct JobScheduler 

pub struct JobScheduler { /* private fields */ }

Job scheduler for managing delayed and recurring jobs

Implementations

impl JobScheduler

pub fn new(storage: Arc<dyn Storage>) -> Self

Create a new job scheduler

pub fn with_poll_interval( storage: Arc<dyn Storage>, poll_interval: Duration, ) -> Self

Create a new job scheduler with custom poll interval

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

Start the scheduler loop. Runs forever; use JobScheduler::run_until_cancelled when you need to observe a shutdown signal.

pub async fn run_until_cancelled(&self, cancel: CancellationToken) -> Result<()>

Start the scheduler loop, exiting cleanly when cancel is cancelled.

pub async fn schedule_job( &self, job: Job, execute_at: DateTime<Utc>, reason: impl Into<String>, ) -> Result<()>

Schedule a job for future execution

pub async fn schedule_job_in( &self, job: Job, delay: Duration, reason: impl Into<String>, ) -> Result<()>

Schedule a job with a delay from now

pub fn poll_interval(&self) -> Duration

Get the current poll interval