- Initial release of BullMQ for Rust
- Queue: add, addBulk, pause, resume, drain, obliterate, clean, retryJobs, promoteJobs
- Worker: concurrent processing, stalled job detection, lock renewal, pause/resume
- Job: progress tracking, logging, retry, state queries, manual move operations
- Backoff strategies: fixed, exponential, custom (async callback)
- Dynamic concurrency control
- CancellationToken for cooperative job cancellation
- Full compatibility with Node.js/Python BullMQ queues (same Lua scripts)
- Queue: rate_limit, set_global_rate_limit, remove_global_rate_limit
- Queue: set_global_concurrency, remove_global_concurrency
- Queue: upsert_job_scheduler, get_job_scheduler(s), remove_job_scheduler
- Job deduplication support and remove_deduplication_key
- Worker handling for RateLimited/NextTimestamp fetch results
- Cron scheduler support via croner and chrono-tz
- FlowProducer: add, add_bulk, add_with_opts (per-queue default job options), get_flow
- Flows: failParentOnFailure, removeDependencyOnFailure, ignoreDependencyOnFailure, continueParentOnFailure
- Queue getters: get_jobs, get_ranges, get_waiting/active/delayed/completed/failed/prioritized/waiting_children
- Queue counts: count, get_job_counts_by_types, get_job_count_by_types, get_counts_per_priority, per-state count getters
- Queue: get_rate_limit_ttl, get_global_concurrency, get_global_rate_limit, get_deduplication_job_id
- Queue: get_metrics (time-series), get_dependencies_count, get_children_values
- Job: clear_logs, discard, is_waiting_children, get_ignored_children_failures, get_dependencies, move_to_waiting_children
- Worker: metrics option (time-series collection), rate limiting
- Connections: typed options (host/port/username/password/db) and TLS (
rediss://) support