asynq-rs 0.2.0

Asynq by redis client library. This library provides a set of tools for asynchronous task processing using Redis as a backend.
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
26
27
28
29
30
31
32
33
34

use crate::common::queue::QUEUED;
use crate::controller::redis::GLOBAL_REDIS_SCRIPT;

pub fn make_task_key(queue: &str, typ: &str, task_id: &str) -> String {
    //ZQL:{<qname>}:t:<task_id>
    format!("{}:{{{}}}:{{{}}}:{}", QUEUED, queue, typ, task_id)
}

pub fn make_queue(queue: &str, state: &str) -> String {
    //ZQL:{<qname>}:pending
    format!("{}:{{{}}}:{}", QUEUED, queue, state)
}

pub async fn get_sha(cmd: &str) -> Option<String> {
    GLOBAL_REDIS_SCRIPT
        .read()
        .await
        .get(cmd)
        .map(|res| res.to_string())
}

#[cfg(test)]
mod tests {
    use crate::common::func::{make_queue, make_task_key};

    #[test]
    fn test_make_task_key() {
        let res = make_queue("abc", "abc");
        println!("{}", res);

        let res = make_task_key("aa", "aa", "aa");
        println!("{}", res);
    }
}