Trait JobOps 

pub trait JobOps: Send + Sync {
    // Required methods
    fn enqueue(
        &self,
        name: &str,
        payload: Value,
        priority: &str,
        delay_secs: u64,
        max_retries: u32,
        queue: &str,
    ) -> String;
    fn stats(&self) -> Value;
    fn dead_letters(&self) -> Value;
    fn retry_dead(&self, id: &str) -> bool;
    fn list_jobs(
        &self,
        status: Option<&str>,
        queue: Option<&str>,
        limit: usize,
    ) -> Value;
    fn get_job(&self, id: &str) -> Option<Value>;
}

Job queue operations used by the router.

Required Methods

fn enqueue( &self, name: &str, payload: Value, priority: &str, delay_secs: u64, max_retries: u32, queue: &str, ) -> String

fn stats(&self) -> Value

fn dead_letters(&self) -> Value

fn retry_dead(&self, id: &str) -> bool

fn list_jobs( &self, status: Option<&str>, queue: Option<&str>, limit: usize, ) -> Value

fn get_job(&self, id: &str) -> Option<Value>

Implementors