Redis Job Queue
Simple redis job queue
Documentation
Enqueue jobs
extern crate rjq;
use Duration;
use sleep;
use ;
Queue worker
extern crate rjq;
use Duration;
use sleep;
use Error;
use Queue;
Job status
QUEUED - job queued for further processing
RUNNING - job is running by worker
LOST - job has not been finished in time
FINISHED - job has been successfully finished
FAILED - job has been failed due to some errors
Queue methods
Init queue
;
url - redis URL
name - queue name
Returns queue
Drop queue jobs
;
Enqueue job
;
args - job arguments
expire - if job has not been started by worker in this time (in seconds), it will expire
Returns job UUID
Get job status
;
uuid - job unique identifier
Returns job status
Work on queue
;
wait - time to wait until next job will pop
fun - worker function
timeout - worker function should finish in timeout (in seconds)
freq - job status check frequency (times per second)
expire - job result will expire in this time (in seconds)
fall - panics to terminate process if the job has been lost
infinite - process jobs infinitely one after another, otherwise only one job will be processed
Get job result
;
uuid - job unique identifier
Returns job result
Run tests