Struct BaseQueue 

pub struct BaseQueue {
    pub name: String,
    pub prefix: String,
    pub task_config: TaskConfig,
    pub queue: Arc<Queue>,
    pub worker: Option<Worker>,
}

队列基类

封装 Queue 和 Worker，提供更贴近 TS BaseCoolQueue 的使用体验。

Fields

name: String

队列名称

prefix: String

队列前缀

task_config: TaskConfig

任务配置

queue: Arc<Queue>

底层队列

worker: Option<Worker>

可选 Worker

Implementations

impl BaseQueue

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

创建新的队列基类实例，并根据配置自动创建 Queue/Worker

pub async fn producer_only(name: &str, config: TaskConfig) -> JobResult<Self>

只创建生产者（无 Worker）

pub async fn start_worker(&self)

启动 Worker（如果存在）

pub fn stop_worker(&self)

停止 Worker（如果存在）

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 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<()>

清空队列（包括任务数据）