Struct CacheRepository 

pub struct CacheRepository { /* private fields */ }

Cache repository using PostgreSQL UNLOGGED table with per-query TTL check

Implementations

impl CacheRepository

pub fn new(pool: PgPool) -> Self

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

Get a cached value, returning None if not found or expired

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

Set a cached value with TTL in seconds

pub async fn set_with_expiry<T: Serialize>( &self, key: &str, value: &T, expires_at: DateTime<Utc>, ) -> Result<()>

Set a cached value with explicit expiration time

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

Delete a cached entry

pub async fn cleanup_expired(&self) -> Result<u64>

Delete all expired entries (cleanup)

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

where T: Serialize + DeserializeOwned, F: FnOnce() -> Fut, Fut: Future<Output = Result<T>>,

Get or set a cached value using a fallback function

Trait Implementations

impl Clone for CacheRepository

fn clone(&self) -> CacheRepository

Returns a duplicate of the value.

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

Performs copy-assignment from source.