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

use redis::RedisError;

use crate::{
    error::ObliterateError,
    luacommands::{InvokeLuaScript, OBLITERATE},
    queue::QueueName,
};

pub struct Obliterate<'a> {
    pub queue: &'a QueueName,
    pub batch_size: usize,
    pub force: bool,
}

pub enum ObliterateOk {
    /// A batch of jobs have been purged
    Progress,
    /// The last batch has been purged, the queue is obliterated
    Obliterated,
}

impl<'a> InvokeLuaScript for Obliterate<'a> {
    type DomainOk = ObliterateOk;
    type DomainErr = ObliterateError;
    type RedisOutput = i32;

    fn generate_invocation(&self) -> Result<redis::ScriptInvocation<'static>, Self::DomainErr> {
        let mut invoc = OBLITERATE.prepare_invoke();
        invoc
            .key(self.queue.meta())
            .key(self.queue.base())
            .arg(self.batch_size)
            .arg(if self.force { "force" } else { "" });
        Ok(invoc)
    }

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

    fn map_value(&self, value: Self::RedisOutput) -> Result<Self::DomainOk, Self::DomainErr> {
        match value {
            0 => Ok(ObliterateOk::Obliterated),
            1 => Ok(ObliterateOk::Progress),
            -1 => Err(ObliterateError::NotPaused),
            -2 => Err(ObliterateError::ActiveJobs),
            x => panic!("Lua script should never return: {x:#?}"),
        }
    }
}