Struct JobQueue 

pub struct JobQueue { /* private fields */ }

Persistent job queue

Implementations

impl JobQueue

pub fn new(storage_path: String) -> Result<Self>

pub async fn enqueue(&self, job: Job) -> Result<String>

Enqueue a new job

pub async fn dequeue(&self) -> Result<Option<Job>>

Dequeue next job (highest priority, oldest first)

pub async fn update_job(&self, job_id: &str, job: Job) -> Result<()>

Update job status

pub async fn get(&self, job_id: &str) -> Result<Option<Job>>

Get job by ID

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

Get job status

pub async fn cleanup_completed(&self) -> Result<usize>

Remove completed jobs (cleanup)

pub async fn stats(&self) -> Result<QueueStats>

Get queue statistics