chainmq 1.2.1

A Redis-backed, type-safe job queue for Rust. Provides job registration and execution, delayed jobs, retries with backoff, and scalable workers.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

// src/lua.rs - Lua scripts for atomic operations
use redis::Script;

pub struct LuaScripts {
    pub move_delayed: Script,
    pub claim_job: Script,
}

impl LuaScripts {
    pub fn new() -> Self {
        let move_delayed = Script::new(include_str!("./lua/move_delayed.lua"));
        let claim_job = Script::new(include_str!("./lua/claim_job.lua"));

        move_delayed.prepare_invoke();
        claim_job.prepare_invoke();

        Self {
            move_delayed,
            claim_job,
        }
    }
}