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 start_dashboard(&self, port: u16)

Starts the built-in dashboard UI on the given port.

The dashboard is a single-page React app (served from ./static/index.html relative to the process working directory) that shows live queue stats, a Recent Jobs table, and a real-time Progress Stream fed by yield_progress. Updates are delivered via HTTP polling of the JSON API (/api/stats, /api/tasks, /api/progress).

The dashboard only serves the UI — jobs keep running whether or not it is open.

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.