ruststream-fred 0.7.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

#![doc = include_str!("README.md")]
#![forbid(unsafe_code)]

mod address;
#[cfg(feature = "asyncapi")]
mod asyncapi;
mod broker;
mod claim;
mod connection;
mod convert;
mod delay;
mod envelope;
mod error;
#[cfg(feature = "testing")]
mod in_process;
mod loopback;
mod message;
mod partition;
mod publisher;
mod recovery;
mod route;
mod seek;
mod settings;
mod subscriber;

// These modules carry their own `//!` summaries. A second doc fragment here would be written in
// the crate root's scope, and rustdoc would then resolve the module's intra-doc links there too.
pub mod context;
pub mod prelude;

// The three transport forms. Each is public for its own `prelude` and its `Publish` alias, so a
// mount site names the policy by the same word whichever form it is on; the types they hold stay
// re-exported at the crate root as well, for a file that mixes forms.
pub mod list;
pub mod pipeline;
pub mod pubsub;
pub mod stream;

pub use broker::{ClosedRedisBroker, ConnectedRedisBroker, RedisBroker};
pub use delay::DelayedRetry;
pub use error::RedisError;
pub use list::{
    RedisList, RedisListMessage, RedisListPublish, RedisListPublisher, RedisListSubscriber,
};
pub use message::{DELIVERY_COUNT_HEADER, IDLE_MS_HEADER, PARTITION_KEY_HEADER, RedisMessage};
pub use partition::{RedisPublishOptions, RedisPublishSteps};
pub use pipeline::{
    RedisListAtomic, RedisListPipeline, RedisPubSubAtomic, RedisPubSubPatternAtomic,
    RedisPubSubPatternPipeline, RedisPubSubPipeline, RedisStreamAtomic, RedisStreamPipeline,
};
pub use publisher::{
    RedisDefaultPublish, RedisDefaultPublisher, RedisPublish, RedisPublisher, RedisTransaction,
    RedisTransactionalPublish,
};
pub use pubsub::{
    PubSubMode, RedisPubSub, RedisPubSubMessage, RedisPubSubPattern, RedisPubSubPublish,
    RedisPubSubPublisher, RedisPubSubSubscriber,
};
pub use seek::{EntryId, RedisGroupPosition, RedisGroupSeeker};
pub use settings::RedisSubscribeExt;
pub use stream::{RedisStream, StreamStart};
pub use subscriber::RedisSubscriber;

// fred auth/TLS types re-exported for the `RedisBroker::tls` / `::credential_provider` builders, so
// callers need not depend on `fred` directly to name them.
#[cfg(feature = "credential-provider")]
pub use fred::types::config::CredentialProvider;
#[cfg(any(
    feature = "tls-rustls",
    feature = "tls-rustls-ring",
    feature = "tls-native-tls"
))]
pub use fred::types::config::{TlsConfig, TlsConnector};