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
21
22
23
24
25

use serde::{Serialize, de::DeserializeOwned};
use crate::job::Job;
use crate::registry::JOB_REGISTRY;


pub trait JobMetadata: Serialize + DeserializeOwned {
    fn queue() -> &'static str;
    fn name() -> &'static str;
    fn max_retries() -> usize {
        0
    }
}




pub async fn parse_dynamic_job(json_str: &str) -> Option<Box<dyn Job>> {
    let val: serde_json::Value = serde_json::from_str(json_str).ok()?;
    let job_type = val.get("type")?.as_str()?;

    let registry = JOB_REGISTRY.lock().unwrap();
    let handler = registry.get(job_type)?;

    handler(json_str.to_string()).await.ok()
}