Crate chainmq 

ChainMQ: A Redis-backed job queue for Rust

This crate provides type-safe job queues with Redis persistence, delayed execution, retries, and monitoring.

Re-exports

pub use backoff::Backoff;

pub use backoff::BackoffStrategy;

pub use context::AppContext;

pub use context::JobContext;

pub use error::ChainMQError;

pub use error::Result;

pub use job::JobMetadata;

pub use job::Job;

pub use job::JobId;

pub use job::JobLogLine;

pub use job::JobOptions;

pub use job::JobState;

pub use job::Priority;

pub use job_log_layer::JobLogLayer;

pub use job_log_layer::job_logs_layer;

pub use queue::Queue;

pub use queue::QueueOptions;

pub use redis::RedisClient;

pub use registry::JobRegistry;

pub use repeat::RepeatCatchUp;

pub use repeat::RepeatScheduleInfo;

pub use worker::Worker;

pub use worker::WorkerBuilder;

pub use web_ui::WebUIAuth;

pub use web_ui::WebUIMountConfig;

pub use web_ui::WebUiState;

pub use web_ui::chainmq_dashboard_router;

pub use serde_json;

Modules

backoff

context

error

job

job_log_layer

tracing layer that appends events under the job_execution span to Redis (see crate::Queue::append_job_log_line).

lua

queue

redis

registry

repeat

Repeatable job schedule metadata (Redis-backed; see docs/repeatables-cron-design.md).

web_ui

ChainMQ dashboard: mount routes on your Axum or Actix server (no HTTP server inside this crate).

worker

Structs

CancellationToken

A token which can be used to signal a cancellation request to one or more tasks.

Traits

Deserialize

A data structure that can be deserialized from any data format supported by Serde.

Serialize

A data structure that can be serialized into any data format supported by Serde.

Attribute Macros

async_trait

Derive Macros

Deserialize

Serialize