Struct Cache 

pub struct Cache { /* private fields */ }

Cache wrapper for Redis operations

Implementations

impl Cache

pub fn new(redis: RedisPool) -> Self

Create a new cache instance

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

where T: for<'de> Deserialize<'de>,

Get a cached value as JSON

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

where T: Serialize,

Set a cached value as JSON

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

Delete a cached value

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

Delete multiple keys matching a glob pattern using Redis SCAN

pub async fn invalidate_org(&self, org_id: &Uuid) -> Result<()>

Invalidate organization-related caches

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

Invalidate user-related caches

pub async fn invalidate_subscription(&self, org_id: &Uuid) -> Result<()>

Invalidate subscription cache

pub async fn invalidate_marketplace( &self, content_type: &str, content_id: &Uuid, ) -> Result<()>

Invalidate marketplace content cache

pub async fn get_or_set<F, Fut, T>( &self, key: &str, ttl: u64, f: F, ) -> Result<T>

where F: FnOnce() -> Fut, Fut: Future<Output = Result<T>>, T: Serialize + for<'de> Deserialize<'de>,

Get or set pattern: Try cache first, fallback to database query