Struct RedisPool 

pub struct RedisPool { /* private fields */ }

Shared Redis handle filled during on_startup (mirrors [sova_db::DbPool]).

Implementations

impl RedisPool

pub async fn publish( &self, channel: impl AsRef<str>, message: impl AsRef<[u8]>, ) -> Result<i64, RedisError>

PUBLISH channel message — returns subscriber count that received it.

pub async fn subscribe( &self, channels: impl IntoIterator<Item = impl AsRef<str>>, ) -> Result<RedisSubscriber, RedisError>

Open a dedicated Pub/Sub connection and subscribe to channels.

Requires the pool URL (set by the crate::Redis plugin). Do not reuse the shared command connection for subscribe.

pub async fn psubscribe( &self, patterns: impl IntoIterator<Item = impl AsRef<str>>, ) -> Result<RedisSubscriber, RedisError>

Pattern subscribe (PSUBSCRIBE), e.g. events:*.

pub async fn enqueue( &self, queue: impl AsRef<str>, message: impl AsRef<[u8]>, ) -> Result<i64, RedisError>

Push onto a list queue (LPUSH). Returns new list length.

pub async fn dequeue( &self, queue: impl AsRef<str>, ) -> Result<Option<Vec<u8>>, RedisError>

Non-blocking pop (RPOP). None if empty.

pub async fn dequeue_wait( &self, queue: impl AsRef<str>, timeout: Duration, ) -> Result<Option<(String, Vec<u8>)>, RedisError>

Blocking pop (BRPOP). timeout = 0 waits forever.

Returns (queue_name, payload) or None on timeout.

impl RedisPool

pub fn new() -> Self

pub fn is_fake(&self) -> bool

pub fn fake(&self) -> Option<Arc<FakeRedis>>

pub fn set_fake(&self, fake: FakeRedis)

pub fn set_url(&self, url: impl Into<String>)

Remember REDIS_URL so Pub/Sub can open a dedicated connection.

pub fn url(&self) -> Result<String, RedisError>

pub fn set(&self, conn: ConnectionManager)

pub fn get(&self) -> Result<ConnectionManager, RedisError>

pub fn clear(&self)

pub async fn connect(url: &str) -> Result<ConnectionManager, RedisError>

Connect and ping; used by the plugin and tests.

pub async fn subscribe_fake( &self, channel: impl AsRef<str>, ) -> Result<FakeSubscriber, RedisError>

Trait Implementations

impl Clone for RedisPool

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for RedisPool

fn default() -> Self

Returns the “default value” for a type.