Struct JobQueue 

pub struct JobQueue { /* private fields */ }

可靠任务队列

基于 sz-orm Pool 实现，不绑定具体数据库后端（MySQL/PostgreSQL 均可， 领取用单条 UPDATE 原子抢占，不依赖 FOR UPDATE SKIP LOCKED 方言）。

Implementations

impl JobQueue

pub fn new(pool: Arc<Pool>) -> Self

创建任务队列

pub fn pool(&self) -> &Arc<Pool>

底层连接池引用（观测/测试用）

pub async fn init_schema(&self) -> Result<(), JobQueueError>

幂等建表（可安全重复调用）

pub async fn enqueue( &self, kind: &str, payload: Value, dedupe_key: Option<&str>, ) -> Result<u64, JobQueueError>

入队任务（立即执行）。dedupe_key 同 kind 下重复时返回已存在任务 ID，不重复入队。

pub async fn enqueue_delayed( &self, kind: &str, payload: Value, dedupe_key: Option<&str>, delay: Duration, ) -> Result<u64, JobQueueError>

入队延迟任务（delay 后执行）——退避/定时不靠 worker sleep，靠 run_after

pub async fn retry_dead(&self, job_id: u64) -> Result<(), JobQueueError>

死信重放：将 dead 任务重新置为 pending（保留 attempts 与错误历史）

pub async fn queue_snapshot(&self) -> Result<QueueSnapshot, JobQueueError>

队列健康快照（pending/running/dead/最老等待/累计完成）

pub async fn run_worker( &self, handlers: HashMap<String, Arc<dyn TaskHandler>>, config: JobQueueConfig, shutdown: Receiver<bool>, ) -> Result<(), JobQueueError>

启动 worker：轮询领取 → 分发 handler → 成功/退避重试/死信。 shutdown 为 true 时退出（优雅关闭）。

Trait Implementations

impl Clone for JobQueue

fn clone(&self) -> JobQueue

Returns a duplicate of the value.

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

Performs copy-assignment from source.