Struct RedisCache 

pub struct RedisCache { /* private fields */ }

Redis cache client with connection management

Implementations

impl RedisCache

pub async fn new(config: CacheConfig) -> Result<Self>

Create a new Redis cache connection

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

Get a value from cache

pub async fn set<T: Serialize>( &self, key: &str, value: &T, ttl_secs: u64, ) -> Result<()>

Set a value in cache with TTL

pub async fn set_default<T: Serialize>( &self, key: &str, value: &T, ) -> Result<()>

Set a value with default TTL

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

Delete a key from cache

pub async fn delete_pattern(&self, pattern: &str) -> Result<u64>

Delete multiple keys matching a pattern

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

Check if a key exists

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

Increment a counter (for rate limiting)

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

Increment with expiry (for rate limiting windows)

pub async fn expire(&self, key: &str, ttl_secs: u64) -> Result<bool>

Set TTL on existing key

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

Get remaining TTL for a key

pub async fn try_lock( &self, resource: &str, ttl_secs: u64, ) -> Result<Option<String>>

Try to acquire a distributed lock

pub async fn release_lock(&self, resource: &str, lock_id: &str) -> Result<bool>

Release a distributed lock

pub async fn health_check(&self) -> Result<bool>

Health check

impl RedisCache

User session cache operations

pub async fn set_session(&self, session_id: &str, user_id: Uuid) -> Result<()>

Cache a user session

pub async fn get_session(&self, session_id: &str) -> Result<Option<Uuid>>

Get user ID from session

pub async fn invalidate_session(&self, session_id: &str) -> Result<bool>

Invalidate a session

pub async fn invalidate_user_sessions(&self, user_id: Uuid) -> Result<u64>

Invalidate all sessions for a user

impl RedisCache

User profile cache operations

pub async fn set_user_profile<T: Serialize>( &self, user_id: Uuid, profile: &T, ) -> Result<()>

Cache user profile

pub async fn get_user_profile<T: DeserializeOwned>( &self, user_id: Uuid, ) -> Result<Option<T>>

Get cached user profile

pub async fn invalidate_user_profile(&self, user_id: Uuid) -> Result<bool>

Invalidate user profile cache

impl RedisCache

Token price cache operations

pub async fn set_token_price( &self, token_id: Uuid, price_btc: f64, ) -> Result<()>

Cache token price

pub async fn get_token_price(&self, token_id: Uuid) -> Result<Option<f64>>

Get cached token price

pub async fn set_token_prices(&self, prices: &[(Uuid, f64)]) -> Result<()>

Cache multiple token prices

impl RedisCache

Token metadata cache operations

pub async fn set_token_meta<T: Serialize>( &self, token_id: Uuid, meta: &T, ) -> Result<()>

Cache token metadata

pub async fn get_token_meta<T: DeserializeOwned>( &self, token_id: Uuid, ) -> Result<Option<T>>

Get cached token metadata

pub async fn invalidate_token_meta(&self, token_id: Uuid) -> Result<bool>

Invalidate token metadata cache

impl RedisCache

User balance cache operations

pub async fn set_balance( &self, user_id: Uuid, token_id: Uuid, balance: f64, ) -> Result<()>

Cache user balance for a token

pub async fn get_balance( &self, user_id: Uuid, token_id: Uuid, ) -> Result<Option<f64>>

Get cached balance

pub async fn invalidate_user_balances(&self, user_id: Uuid) -> Result<u64>

Invalidate all balances for a user

pub async fn invalidate_token_balances(&self, token_id: Uuid) -> Result<u64>

Invalidate all balances for a token

impl RedisCache

Rate limiting operations

pub async fn check_rate_limit( &self, identifier: &str, limit: u64, window_secs: u64, ) -> Result<(u64, bool)>

Check and increment rate limit Returns (current_count, is_allowed)

pub async fn get_rate_limit_count(&self, identifier: &str) -> Result<u64>

Get current rate limit count

pub async fn reset_rate_limit(&self, identifier: &str) -> Result<bool>

Reset rate limit for identifier

Trait Implementations

impl Clone for RedisCache

fn clone(&self) -> RedisCache

Returns a duplicate of the value.

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

Performs copy-assignment from source.