queue_workers 0.5.1

A Redis-backed job queue system for Rust applications
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

use async_trait::async_trait;

use crate::{error, job::Job};

#[derive(Clone, Copy, Debug)]
pub enum QueueType {
    FIFO, // First In, First Out (using LPUSH/RPOP)
    LIFO, // Last In, First Out (using LPUSH/LPOP)
}

impl Default for QueueType {
    fn default() -> Self {
        Self::FIFO
    }
}

#[async_trait]
pub trait Queue: Send + Sync {
    type JobType: Job;

    async fn push(&self, job: Self::JobType) -> Result<(), error::QueueWorkerError>;

    async fn pop(&self) -> Result<Self::JobType, error::QueueWorkerError>;
}