Struct RedisPool 

pub struct RedisPool { /* private fields */ }

Redis connection wrapper

Implementations

impl RedisPool

pub async fn connect(redis_url: &str) -> Result<Self>

Create a new Redis connection pool

pub fn get_connection(&self) -> Arc<ConnectionManager>

Get a connection for async operations Note: ConnectionManager is already cloneable, so we can use it directly

pub async fn increment_with_expiry( &self, key: &str, expiry_seconds: u64, ) -> Result<i64>

Increment a counter with expiration Returns the new count after increment

pub async fn get_counter(&self, key: &str) -> Result<i64>

Get a counter value

pub async fn set_with_expiry( &self, key: &str, value: &str, expiry_seconds: u64, ) -> Result<()>

Set a key with expiration

pub async fn get(&self, key: &str) -> Result<Option<String>>

Get a key value

pub async fn delete(&self, key: &str) -> Result<()>

Delete a key

pub async fn scan_keys(&self, pattern: &str) -> Result<Vec<String>>

Scan for keys matching a glob pattern using Redis SCAN

pub async fn ping(&self) -> Result<()>

Health check - verify Redis connectivity

Trait Implementations

impl Clone for RedisPool

fn clone(&self) -> RedisPool

Returns a duplicate of the value.

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

Performs copy-assignment from source.