sova-redis 0.1.4

Shared Redis/Valkey pool plugin for Sova
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

//! Shared Redis / Valkey pool for Sova (`KvStore`, tasks, cache, pub/sub, list queues).
//!
//! ```ignore
//! app.install(Redis::from_env());
//! let pool = app.try_state::<RedisPool>().unwrap().as_ref().clone();
//! pool.publish("events", b"hello").await?;
//! let mut sub = pool.subscribe(["events"]).await?;
//! while let Some(msg) = sub.next().await {
//!     println!("{}: {:?}", msg.channel, msg.payload_str());
//! }
//! pool.enqueue("jobs", b"payload").await?;
//! let item = pool.dequeue("jobs").await?;
//! ```

mod error;
mod fake;
mod messaging;
mod plugin;
mod pool;

pub use error::RedisError;
pub use fake::{FakeRedis, FakeSubscriber};
pub use messaging::{RedisMessage, RedisSubscriber};
pub use plugin::Redis;
pub use pool::{RedisExt, RedisPool};