Struct Queue 

pub struct Queue { /* private fields */ }

队列

Implementations

impl Queue

pub async fn new(name: &str, prefix: &str, redis_url: &str) -> JobResult<Self>

创建队列

pub async fn add( &self, name: &str, data: Value, options: JobOptions, ) -> JobResult<Job>

添加任务

pub async fn add_bulk( &self, jobs: Vec<(String, Value, JobOptions)>, ) -> JobResult<Vec<Job>>

批量添加任务

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

获取任务

pub async fn update_job(&self, job: &Job) -> JobResult<()>

更新任务

pub async fn get_next_job(&self) -> JobResult<Option<Job>>

获取下一个待处理任务

pub async fn complete_job( &self, job: &mut Job, result: Option<Value>, ) -> JobResult<()>

完成任务

pub async fn fail_job(&self, job: &mut Job, error: &str) -> JobResult<()>

失败任务

pub async fn pause(&self) -> JobResult<()>

暂停队列

pub async fn resume(&self) -> JobResult<()>

恢复队列

pub async fn is_paused(&self) -> JobResult<bool>

检查队列是否暂停

pub async fn count(&self, status: JobStatus) -> JobResult<u64>

获取队列长度

pub async fn obliterate(&self) -> JobResult<()>

清空队列

Trait Implementations

impl Clone for Queue

fn clone(&self) -> Queue

Returns a duplicate of the value.

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

Performs copy-assignment from source.