yq 0.4.1

Yet another job queue
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

use serde::de::DeserializeOwned;
use serde::Serialize;

mod dequeue;
mod dequeue_at;
mod enqueue;
mod enqueue_at;
pub(crate) mod error;
mod helper;
pub(crate) mod lua;
pub(crate) mod queue;
mod redis_keys;

pub use {
    dequeue::{DequeueAction, DequeueSleep, DequeueStatus, FinishAction, SleepOnAction},
    dequeue_at::{DequeueAtAction, DequeueAtStatus},
    enqueue::{EnqueueAction, EnqueueStatus},
    enqueue_at::{EnqueueAtAction, EnqueueAtStatus},
    error::{YqError, YqResult, YqRunJobError},
    helper::decode_job,
    queue::Queue,
};

pub type JobType = std::borrow::Cow<'static, str>;

pub trait Job: Serialize + DeserializeOwned {
    const JOB_TYPE: JobType;

    type State: Clone + 'static;

    const LOCK_MS: isize = -1;
}

pub(crate) type ArcString = std::sync::Arc<String>;