Struct Cron 

pub struct Cron<'a, D>
where
    D: Driver + Send + Sync,
{ /* private fields */ }

The Cron struct is the main entry point for the library, providing the ability to add and remove jobs.

Implementations

impl<'a, D> Cron<'a, D>

where D: Driver + Send + Sync + 'static,

pub async fn new(np: NodePool<D>) -> Arc<Self>

Create a new cron with the given node pool.

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

Start the cron, blocking the current thread.

pub async fn add_job<F>( &self, job_name: &str, schedule: Schedule, run: F, ) -> Result<(), Error<D>>

where F: 'static + Sync + Send + Fn(),

Add a job to the cron

Arguments

• job_name - The unique name of the job
• schedule - The schedule of the job
• run - The function to run

pub async fn add_async_job<F, Fut>( &self, job_name: &str, schedule: Schedule, run: F, ) -> Result<(), Error<D>>

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

Add an async job to the cron

Arguments

• job_name - The unique name of the job
• schedule - The schedule of the job
• run - The async function to run

pub async fn remove_job(&self, job_name: &str) -> Result<(), Error<D>>

Remove a job from the cron

Arguments

• job_name - The unique name of the job

Trait Implementations

impl<D> Drop for Cron<'_, D>

where D: Driver + Send + Sync,

fn drop(&mut self)

Executes the destructor for this type.