qrush 0.6.0

Lightweight Job Queue and Task Scheduler for Rust (Actix + Redis + Cron)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

// src/job.rs
use async_trait::async_trait;

#[async_trait]
pub trait Job: Send + Sync {
    async fn before(&self) -> anyhow::Result<()> {
        Ok(())
    }

    async fn perform(&self) -> anyhow::Result<()> {
        Ok(())
    }

    async fn after(&self) {}
    async fn on_error(&self, _err: &anyhow::Error) {}
    async fn always(&self) {}

    fn name(&self) -> &'static str;
    fn queue(&self) -> &'static str;
}