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

use redis::RedisError;

use crate::{
    error::PauseResumeError, luacommands::{InvokeLuaScript, PAUSE}, queue::QueueName
};

pub enum PauseAction {
    Pause,
    Resume,
}

pub struct Pause<'a> {
    pub queue: &'a QueueName,
    pub action: PauseAction,
}

impl<'a> InvokeLuaScript for Pause<'a> {
    type DomainOk = ();
    type DomainErr = PauseResumeError;
    type RedisOutput = ();

    fn generate_invocation(&self) -> Result<redis::ScriptInvocation<'static>, Self::DomainErr> {
        let mut invocation = PAUSE.prepare_invoke();
        invocation
            .key(match self.action {
                PauseAction::Pause => self.queue.wait(),
                PauseAction::Resume => self.queue.paused(),
            })
            // Set to move jobs to
            .key(match self.action {
                PauseAction::Pause => self.queue.paused(),
                PauseAction::Resume => self.queue.wait(),
            })
            .key(self.queue.meta())
            .key(self.queue.prioritized())
            .key(self.queue.events())
            .key(self.queue.delayed())
            .key(self.queue.marker())
            .arg(match self.action {
                PauseAction::Pause => "paused",
                PauseAction::Resume => "resumed",
            });
        Ok(invocation)
    }

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

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