Struct RedisBackend 

pub struct RedisBackend<C>
where
    C: RedisConn,
{ /* private fields */ }

L1 hot cache: content-addressed key → value, sub-ms hits, TTL/eviction-aware.

Generic over the RedisConn seam so it is fully testable against a mock.

Implementations

impl<C> RedisBackend<C>

where C: RedisConn,

pub fn new(conn: C) -> RedisBackend<C>

Wrap a RedisConn with no per-write TTL (entries are LRU-evicted by the maxmemory band).

pub fn with_ttl(conn: C, ttl_secs: u64) -> RedisBackend<C>

Wrap a RedisConn, stamping every write with a ttl_secs expiry.

pub fn ttl_secs(&self) -> Option<u64>

The per-write TTL, if any.

pub fn conn(&self) -> &C

Borrow the underlying connection (for composition / diagnostics).

Trait Implementations

impl<C> StorageBackend for RedisBackend<C>

where C: RedisConn,

fn wipe_all<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<usize, StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, RedisBackend<C>: 'async_trait,

Complete L1 wipe: DEL every key under BOTH the narinfo and NAR prefixes (a scoped clear — never FLUSHDB, which would blow away an unrelated co-tenant of the same Redis db). Returns the narinfo key count removed.

fn get_narinfo<'life0, 'life1, 'async_trait>( &'life0 self, hash: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, RedisBackend<C>: 'async_trait,

Retrieve narinfo text by store path hash.

fn put_narinfo<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, hash: &'life1 str, content: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, RedisBackend<C>: 'async_trait,

Store narinfo text keyed by store path hash.

fn get_nar<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>, StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, RedisBackend<C>: 'async_trait,

Retrieve a NAR blob by its relative path.

fn put_nar<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, path: &'life1 str, data: &'life2 [u8], ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, RedisBackend<C>: 'async_trait,

Store a NAR blob at the given relative path.

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, hash: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, RedisBackend<C>: 'async_trait,

Delete a store path’s narinfo and associated NAR blob.

fn list_narinfos<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, RedisBackend<C>: 'async_trait,

List all stored narinfo hashes.