nest-rs-queue 0.3.0

Backend-agnostic queue contract for nestrs: traits and the link-time #[process] registry that any backend (Redis via nest-rs-redis, SQS, NATS, in-memory) plugs into.
Documentation 
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

[package]
name = "nest-rs-queue"
version.workspace = true
edition.workspace = true
license.workspace = true
rust-version.workspace = true
repository.workspace = true
homepage.workspace = true
description = "Backend-agnostic queue contract for nestrs: traits and the link-time #[process] registry that any backend (Redis via nest-rs-redis, SQS, NATS, in-memory) plugs into."


[dependencies]
nest-rs-core.workspace = true
# Re-exported so call sites write `nest_rs_queue::processor` for the macro
# even though it physically lives in the macros crate; the macro emits paths
# rooted at `::nest_rs_queue::*`, so the macro and the abstractions ship from
# the same import root.
nest-rs-queue-macros.workspace = true
async-trait.workspace = true
anyhow.workspace = true
# Typed producer errors (`QueueError`) — the framework owns queue plumbing
# errors so features never redefine them.
thiserror.workspace = true
serde.workspace = true
serde_json.workspace = true
tokio-util.workspace = true
# Re-exported for the `#[processor]` macro emission so the call site doesn't
# need a direct `tracing` dependency for the unversioned-payload warning.
tracing.workspace = true

[dev-dependencies]
# The `#[processor]` macro emits absolute `::nest_rs_worker::*` paths, so the
# integration test that exercises a typed `#[process]` handler needs the worker
# crate in scope.
nest-rs-worker = { path = "../nest-rs-worker" }
tokio.workspace = true
serde.workspace = true

[lints]
workspace = true