rust-job-queue-api-worker-system 0.1.0

A production-shaped Rust job queue: Axum API + async workers + Postgres SKIP LOCKED dequeue, retries with decorrelated jitter, idempotency, cooperative cancellation, OpenAPI, Prometheus metrics.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113

[package]
name = "rust-job-queue-api-worker-system"
version = "0.1.0"
edition = "2021"
license = "Apache-2.0"
description = "A production-shaped Rust job queue: Axum API + async workers + Postgres SKIP LOCKED dequeue, retries with decorrelated jitter, idempotency, cooperative cancellation, OpenAPI, Prometheus metrics."
keywords = ["job-queue", "background-jobs", "postgresql", "axum", "skip-locked"]
categories = ["asynchronous", "database", "web-programming::http-server"]
repository = "https://github.com/infinityabundance/Rust-Job-Queue-API-Worker-System"
homepage = "https://github.com/infinityabundance/Rust-Job-Queue-API-Worker-System"
documentation = "https://docs.rs/rust-job-queue-api-worker-system"
readme = "README.md"
authors = ["infinityabundance"]
rust-version = "1.88"
publish = true
autobenches = false
exclude = [
    "Rust_Job_Queue_API_Worker_System.txt",
    "target/",
    ".github/",
    "docker-compose.yml",
    "Dockerfile",
    ".env.example",
    "bench/*.log",
    "bench/COMPARISON.md",
    "bench/run-comparison.sh",
    "benches/comparison.rs",
    "benches/sqlxmq-migrations/",
]

[[bin]]
name = "job-queue-api"
path = "src/bin/job-queue-api.rs"
required-features = ["api"]

[[bin]]
name = "job-queue-worker"
path = "src/bin/job-queue-worker.rs"
required-features = ["worker"]

[[bin]]
name = "job-queue-migrate"
path = "src/bin/job-queue-migrate.rs"

[[example]]
name = "embed_worker"
path = "examples/embed_worker.rs"
required-features = ["worker"]

[[bench]]
name = "dequeue"
path = "benches/dequeue.rs"
harness = false
required-features = ["worker"]

[[bench]]
name = "throughput"
path = "benches/throughput.rs"
harness = false
required-features = ["worker"]

[features]
default = ["api", "worker"]
api = [
    "dep:axum",
    "dep:tower",
    "dep:tower-http",
    "dep:utoipa-swagger-ui",
    "dep:metrics-exporter-prometheus",
]
worker = ["dep:tokio-util", "dep:metrics-exporter-prometheus"]

[dependencies]
# Core (always on)
tokio = { version = "1", features = ["macros", "rt-multi-thread", "signal", "time", "sync"] }
sqlx = { package = "sqlx-core", version = "0.8", default-features = false, features = ["_rt-tokio", "uuid", "chrono", "json"] }
sqlx-postgres = { version = "0.8", default-features = false, features = ["uuid", "chrono", "json"] }
serde = { version = "1", features = ["derive"] }
serde_json = "1"
uuid = { version = "1", features = ["v7", "serde"] }
chrono = { version = "0.4", features = ["serde"] }
tracing = "0.1"
tracing-subscriber = { version = "0.3", features = ["env-filter", "json"] }
thiserror = "2"
anyhow = "1"
rand = "0.9"
utoipa = { version = "5", features = ["axum_extras", "chrono", "uuid"] }
metrics = "0.24"
async-trait = "0.1"

# API (optional, enabled by "api" feature)
axum = { version = "0.8", optional = true }
tower = { version = "0.5", optional = true }
tower-http = { version = "0.6", features = ["trace", "request-id", "timeout", "cors", "util"], optional = true }
utoipa-swagger-ui = { version = "9", features = ["axum"], optional = true }
metrics-exporter-prometheus = { version = "0.18", default-features = false, features = ["http-listener"], optional = true }

# Worker (optional, enabled by "worker" feature)
tokio-util = { version = "0.7", features = ["rt"], optional = true }

[dev-dependencies]
testcontainers = "0.27"
testcontainers-modules = { version = "0.15", features = ["postgres"] }
reqwest = { version = "0.12", default-features = false, features = ["json", "rustls-tls"] }
criterion = { version = "0.5", features = ["async_tokio"] }

[profile.release]
lto = "thin"
codegen-units = 1
strip = "symbols"

[package.metadata.docs.rs]
all-features = true