Struct Scheduler 

pub struct Scheduler { /* private fields */ }

Implementations

impl Scheduler

pub async fn new() -> Result<Self>

pub async fn schedule_daemon<F, Fut>( &mut self, name: &str, cron_expr: &str, callback: F, ) -> Result<()>

where F: Fn(String) -> Fut + Send + Sync + Clone + 'static, Fut: Future<Output = ()> + Send,

Schedule a daemon to be triggered on a cron expression. The callback receives the daemon name and should start the daemon.

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

Start the scheduler so jobs begin firing.

pub async fn shutdown(&mut self) -> Result<()>

Shut down the scheduler, stopping all jobs.