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

use deadpool_redis::Pool;

use crate::PreparedFlowJob;

/// Not implemented yet
#[derive(Clone)]
pub(crate) struct FlowProducer {
    pool: Pool,
}

pub struct FlowJob {
    job: PreparedFlowJob,
    children: Vec<FlowJob>,
}

impl FlowProducer {
    pub fn new(pool: Pool) -> Self {
        Self { pool }
    }

    pub async fn add(&self, fj: &[FlowJob]) -> Result<(), ()> {
        let mut flatten = Vec::new();
        fj.iter()
            .for_each(|j| j.collect_children_first(&mut flatten));
        let _con = self.pool.get().await.map_err(|_| ())?;
        Ok(())
    }
}

impl FlowJob {
    pub fn new(job: PreparedFlowJob) -> Self {
        Self {
            job,
            children: Vec::new(),
        }
    }
    pub fn add(&mut self, child: FlowJob) {
        self.children.push(child);
    }
    pub fn with(mut self, child: FlowJob) -> FlowJob {
        self.children.push(child);
        self
    }

    fn collect_children_first<'a>(&'a self, v: &mut Vec<&'a PreparedFlowJob>) {
        for child in &self.children {
            child.collect_children_first(v);
        }
        v.push(&self.job);
    }
}