Struct JobQueue 

pub struct JobQueue { /* private fields */ }

Redis-backed job queue.

Enqueues jobs into priority-separated Redis lists. Job metadata is stored in Redis hashes for status queries.

Implementations

impl JobQueue

pub fn new(pool: Arc<Pool>) -> Self

Creates a new job queue backed by the given Redis pool.

pub async fn enqueue( &self, name: &str, payload: Value, priority: JobPriority, ) -> Result<String, ShaperailError>

Enqueues a job with the given name, payload, and priority.

Returns the generated job ID.

pub async fn enqueue_with_options( &self, name: &str, payload: Value, priority: JobPriority, max_retries: u32, timeout_secs: u64, ) -> Result<String, ShaperailError>

Enqueues a job with full configuration.

max_retries — how many times to retry on failure (default 3). timeout_secs — auto-fail after this duration (default 300s).

pub async fn get_status(&self, job_id: &str) -> Result<JobInfo, ShaperailError>

Retrieves the status/info of a job by ID.

pub async fn total_depth(&self) -> Result<i64, ShaperailError>

Returns the total number of queued jobs across all priority levels.

Trait Implementations

impl Clone for JobQueue

fn clone(&self) -> JobQueue

Returns a duplicate of the value.

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

Performs copy-assignment from source.