Crate cool_task 

cool-task

cool-admin Rust 任务队列库，基于 Redis 实现分布式任务队列。

功能特性

• 🚀 基于 Redis 的分布式任务队列
• ⏰ 支持定时任务（Cron 表达式）
• 🔄 支持延迟任务
• 📊 任务状态管理
• 🔁 失败重试机制

快速开始

use cool_task::prelude::*;

#[derive(Serialize, Deserialize)]
struct EmailJob {
    to: String,
    subject: String,
    body: String,
}

#[async_trait]
impl JobHandler for EmailJob {
    async fn handle(&self) -> JobResult<()> {
        // 发送邮件逻辑
        Ok(())
    }
}

Modules

prelude

预导入模块

Structs

BaseQueue

队列基类

Job

任务信息

JobOptions

任务选项

Queue

队列

QueueConfig

队列配置，对齐 TS 版本 CoolQueue 装饰器的配置结构

ScheduledJob

定时任务

Scheduler

定时任务调度器

TaskConfig

任务配置

Worker

Worker

WorkerConfig

Worker 配置

Enums

JobError

任务错误

JobStatus

任务状态

QueueType

队列类型，对齐 TS 版本的 type?: 'comm' | 'getter' | 'noworker' | 'single'

Traits

JobHandler

任务处理器 trait

JobHandlerFactory

任务处理器工厂 trait

Type Aliases

JobResult

任务结果