Struct CacheStore 

pub struct CacheStore {
    config: CacheConfig,
    clock: Arc<dyn Clock>,
    mem: Mutex<HashMap<Vec<u8>, InMemoryEntry>>,
    db: Option<Arc<Database>>,
}

In-memory + disk-backed authoritative cache.

All methods are synchronous (redb is synchronous). Callers that need async can wrap calls in tokio::task::spawn_blocking.

Fields

config: CacheConfig

clock: Arc<dyn Clock>

mem: Mutex<HashMap<Vec<u8>, InMemoryEntry>>

In-memory LRU map. HashMap with a simple insertion-order eviction is sufficient for the v1 max_in_memory_entries budget; a proper LRU is a future optimisation.

db: Option<Arc<Database>>

redb database handle. None in unit tests that skip the disk layer.

Implementations

impl CacheStore

pub fn open(path: &Path, config: CacheConfig) -> Result<CacheHandle, AppError>

Open a redb database at path and return a shared CacheHandle.

pub fn in_memory(config: CacheConfig) -> CacheHandle

In-memory only store — used in tests that do not exercise the disk layer.

pub fn new_with_clock( config: CacheConfig, clock: Arc<dyn Clock>, db: Option<Arc<Database>>, ) -> CacheHandle

Constructor with an injected clock for tests.

pub fn db(&self) -> Option<Arc<Database>>

Return the underlying redb::Database handle, if one was opened.

Used by MultipartTable (task 32) to share the same file handle rather than opening cache.redb a second time.

pub fn get<T: DeserializeOwned>( &self, key: &CacheKey, profile_validation_ts: Option<i64>, ) -> Result<Option<CacheRead<T>>, AppError>

Read a cached value.

Validation gate (AC-8)

If profile_validation_ts is None, the profile has not been validated in the current session and cached data MUST NOT be surfaced. The gate returns Ok(None) without reading from disk.

pub fn put<T: Serialize>( &self, key: &CacheKey, value: T, ttl: Option<Duration>, ) -> Result<(), AppError>

Write a value into both the in-memory and disk layers.

pub fn invalidate(&self, key: &CacheKey)

Remove a single entry from both memory and disk.

pub fn invalidate_profile(&self, profile: &ProfileId)

Remove all entries scoped to profile from both layers.

In-memory: O(n) linear scan — acceptable for max_in_memory_entries. Disk: full table scan, removing matching keys in one transaction.

pub fn clear_all(&self)

Wipe every cached entry from both layers.

fn classify_entry_bytes<T: DeserializeOwned>( raw: &[u8], now: i64, expires_at: i64, swr_deadline: i64, ) -> Result<Option<CacheRead<T>>, AppError>

Deserialise raw bytes and classify freshness based on the current time.