Crate celers_broker_sql 

MySQL broker implementation for CeleRS

This broker uses MySQL with FOR UPDATE SKIP LOCKED for reliable, distributed task queue processing. It supports:

• Priority queues
• Dead Letter Queue (DLQ) for permanently failed tasks
• Delayed task execution (enqueue_at, enqueue_after)
• Prometheus metrics (optional metrics feature)
• Batch enqueue/dequeue/ack operations
• Transaction safety
• Distributed workers without contention
• Queue pause/resume functionality
• DLQ inspection and requeue
• Task status inspection
• Database health checks
• Automatic task archiving

Re-exports

pub use broker_core::MysqlBroker;

pub use types::*;

pub use circuit_breaker::*;

pub use workflow::*;

pub use tracing::*;

pub use stats_types::*;

pub use broker_batch::*;

Modules

broker_batch

Batch operations, worker management, and task groups

broker_core

Core MysqlBroker struct and primary implementation

circuit_breaker

Circuit breaker and idempotency types for the MySQL broker

monitoring

MySQL broker monitoring utilities

stats_types

Statistics and diagnostics type definitions

tracing

W3C Trace Context for distributed tracing

types

Core type definitions for the MySQL broker

utilities

MySQL broker utility functions

workflow

Workflow types, task hooks, and builder patterns