bullrs 0.0.3

A BullMQ compatible Job Queue based on Redis
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
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75

use std::error::Error;

use lazy_static::lazy_static;
use redis::{FromRedisValue, RedisError, Script, ScriptInvocation, aio::ConnectionLike};

mod add_delayed_job;
mod add_log;
mod add_prioritized_job;
mod add_standard_job;
mod extend_locks;
mod is_finished;
mod move_stalled_jobs_to_wait;
mod move_to_active;
mod move_to_finished;
mod obliterate;
mod pause;
mod update_progress;

pub use add_delayed_job::AddDelayedJob;
pub use add_log::AddLog;
pub use add_prioritized_job::AddPrioritizedJob;
pub use add_standard_job::AddStandardJob;
pub use extend_locks::ExtendLocks;
pub use is_finished::{IsFinished, IsFinishedOk};
pub use move_stalled_jobs_to_wait::MoveStalledJobsToWait;
pub use move_to_active::{MoveToActive, MoveToActiveOk, RateLimiter};
pub use move_to_finished::{KeepJobsConfig, MoveToFinished, MoveToFinishedOptions};
pub use obliterate::{Obliterate, ObliterateOk};
pub use pause::{Pause, PauseAction};
pub use update_progress::UpdateProgess;

macro_rules! load_script {
    ($filename:expr) => {
        Script::new(include_str!(concat!(env!("OUT_DIR"), "/lua/", $filename)))
    };
}

lazy_static! {
    static ref ADD_DELAYED_JOB: Script = load_script!("addDelayedJob-6.lua");
    static ref ADD_LOG: Script = load_script!("addLog-2.lua");
    static ref ADD_PRIORITIZED_JOB: Script = load_script!("addPrioritizedJob-9.lua");
    static ref ADD_STANDARD_JOB: Script = load_script!("addStandardJob-9.lua");
    static ref EXTEND_LOCKS: Script = load_script!("extendLocks-1.lua");
    static ref IS_FINISHED: Script = load_script!("isFinished-3.lua");
    static ref MOVE_STALLED_JOBS_TO_WAIT: Script = load_script!("moveStalledJobsToWait-8.lua");
    static ref MOVE_TO_ACTIVE: Script = load_script!("moveToActive-11.lua");
    static ref MOVE_TO_FINISHED: Script = load_script!("moveToFinished-14.lua");
    static ref OBLITERATE: Script = load_script!("obliterate-2.lua");
    static ref PAUSE: Script = load_script!("pause-7.lua");
    static ref UPDATE_DATA: Script = load_script!("updateData-1.lua");
    static ref UPDATE_PROGRESS: Script = load_script!("updateProgress-3.lua");
}

pub trait InvokeLuaScript {
    type RedisOutput: FromRedisValue;
    type DomainOk;
    type DomainErr: Error + From<RedisError>;

    fn generate_invocation(&self) -> Result<ScriptInvocation<'static>, Self::DomainErr>;

    fn map_redis_error(&self, error: RedisError) -> Self::DomainErr {
        error.into()
    }

    fn map_value(&self, value: Self::RedisOutput) -> Result<Self::DomainOk, Self::DomainErr>;

    async fn call(&self, con: &mut impl ConnectionLike) -> Result<Self::DomainOk, Self::DomainErr> {
        let invocation = self.generate_invocation()?;
        let redis_res: Self::RedisOutput = invocation
            .invoke_async(con)
            .await
            .map_err(|e| self.map_redis_error(e))?;
        self.map_value(redis_res)
    }
}