simple-queue 0.1.0

A simple persistent queue implementation in Rust backed by PostgreSQL and tokio
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

#[cfg(feature = "janitor")]
use crate::janitor;
use crate::reaper;
use crate::*;

// Main loop
impl SimpleQueue {
    /// Return a [`reaper::Reaper`] instance that fixes stale jobs
    ///
    /// Useful when you want to control [`reaper::Reaper`] thread yourself.
    pub async fn reaper(&self) -> reaper::Reaper {
        let pool = self.pool.clone();
        let heartbeat_interval = tokio::time::interval(self.heartbeat_interval);
        reaper::Reaper {
            pool,
            heartbeat_interval,
        }
    }
    #[cfg(feature = "janitor")]
    pub async fn janitor(&self) -> janitor::Janitor {
        let pool = self.pool.clone();
        let interval = tokio::time::interval(self.janitor_interval);
        janitor::Janitor { pool, interval }
    }
}