ruststream-fred 0.4.1

Redis / Valkey broker implementation (Streams) for the RustStream messaging framework, backed by fred.
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
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

[package]
name = "ruststream-fred"
description = "Redis / Valkey broker implementation (Streams) for the RustStream messaging framework, backed by fred."
version.workspace = true
edition.workspace = true
rust-version.workspace = true
license.workspace = true
repository.workspace = true
authors.workspace = true
readme = "README.md"
keywords = ["redis", "streams", "messaging", "broker", "faststream"]
categories = ["asynchronous", "network-programming"]

[lints]
workspace = true

[features]
default = []
testing = ["ruststream/conformance"]

# TLS, mapped onto fred's TLS backends. The rustls and native-tls backends are additive in fred
# (not mutually exclusive); `tls-rustls` uses the aws-lc-rs crypto provider, `tls-rustls-ring` the
# ring provider. The TLS surface is gated on any of these being on.
tls-rustls = ["fred/enable-rustls"]
tls-rustls-ring = ["fred/enable-rustls-ring"]
tls-native-tls = ["fred/enable-native-tls"]

# Distinct credentials for authenticating to the sentinels (vs the data nodes).
sentinel-auth = ["fred/sentinel-auth"]

# Dynamic/rotating credentials (IAM-style auth) via a CredentialProvider callback.
credential-provider = ["fred/credential-provider"]

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

[dev-dependencies]
# The conformance harness drives the testing-feature broker; macros + json power the runnable
# fred_* examples (the docs site embeds their snippets), and serde decodes their message types.
ruststream = { workspace = true, features = ["conformance", "macros", "json"] }
serde = { version = "1", features = ["derive"] }
tokio = { workspace = true, features = ["rt-multi-thread", "macros", "sync", "time"] }
# Only the credential-provider unit test implements fred's async CredentialProvider trait.
async-trait = "0.1"

[dependencies]
ruststream = { workspace = true, default-features = false }
fred.workspace = true
bytes.workspace = true
futures.workspace = true
serde = { version = "1", features = ["derive"] }
thiserror.workspace = true
tokio.workspace = true
tracing.workspace = true

# The fred_* examples are the docs-site snippet sources; keep them runnable and snippet-checked here.
[[example]]
name = "fred_streams"

[[example]]
name = "fred_reclaim"

[[example]]
name = "fred_dead_letter"

[[example]]
name = "fred_delayed_retry"

[[example]]
name = "fred_pubsub"

[[example]]
name = "fred_list"

[[example]]
name = "fred_auth"

[[example]]
name = "fred_tls"

[[example]]
name = "fred_transaction"