Struct SnerdQueue 

pub struct SnerdQueue {
    pub name: String,
    pub file_store: FileStore,
    pub rate_limiter: RateLimiter,
    pub progress_tx: Sender<ProgressMessage>,
    /* private fields */
}

Fields

name: String

file_store: FileStore

rate_limiter: RateLimiter

progress_tx: Sender<ProgressMessage>

Implementations

impl SnerdQueue

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

pub fn subscribe_progress(&self) -> Receiver<ProgressMessage>

pub fn yield_progress(&self, task_id: &str, data: &str)

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.