Struct SnerdQueue 

pub struct SnerdQueue {
    pub name: String,
    pub file_store: FileStore,
    /* private fields */
}

Fields

name: String

file_store: FileStore

Implementations

impl SnerdQueue

pub fn new(name: &str, file_store: FileStore) -> Self

pub async fn register_task_handler<F>(&self, task_type: &str, handler: F)

where F: Fn(String) -> Result<(), String> + Send + Sync + 'static,

pub async fn register_max_retry_handler<F>(&self, task_type: &str, handler: F)

where F: Fn(String) -> Result<(), String> + Send + Sync + 'static,

pub fn enqueue(&self, task: RetryableTask) -> Result<()>

pub async fn start_processor(&self, interval: Duration)

pub async fn process_due_tasks(&self)

Trait Implementations

impl Clone for SnerdQueue

fn clone(&self) -> SnerdQueue

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.