Struct RedisPool 

#[non_exhaustive]
pub struct RedisPool { /* private fields */ }

Shared Redis connection pool.

Wraps a MultiplexedConnection which internally multiplexes multiple concurrent requests over a single TCP connection.

Data is isolated by app_id: every Redis key is prefixed with rustvello:{app_id}:, so two pools created with different app_id values against the same Redis server will not see each other’s data.

Implementations

impl RedisPool

pub fn new(uri: &str, app_id: &str) -> RustvelloResult<Self>

Create a new pool from a Redis URI (e.g. redis://127.0.0.1/).

The app_id is used to namespace every key as rustvello:{app_id}:….

pub fn prefix(&self) -> &str

Key prefix including the trailing colon: "rustvello:{app_id}:".

pub async fn conn(&self) -> RustvelloResult<MultiplexedConnection>

Get or create a multiplexed connection.

Trait Implementations

impl Reconnectable for RedisPool

fn health_check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns true if the pool has at least one usable connection.

fn reconnect<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = RustvelloResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Attempt to re-establish connectivity.