Struct SqliteCache 

pub struct SqliteCache { /* private fields */ }

The SQLite cache. Cheap to clone (clones share one connection).

Implementations

impl SqliteCache

pub fn index_restaurants_at( &self, rows: &[RestaurantRow], seen_from: Option<(f64, f64)>, now: i64, ) -> Result<(), DbError>

Upsert restaurants seen in a list response. seen_from is the delivery location of the request; when given, each row’s distance / ETA / fee are also recorded for that location.

pub fn index_items_at(&self, items: &[ItemRow], now: i64) -> Result<(), DbError>

Upsert individual items (e.g. dish hits in search results), keeping any category already known.

pub fn index_menu_at( &self, restaurant: &RestaurantRow, categories: &[CategoryRow], items: &[ItemRow], seen_from: Option<(f64, f64)>, now: i64, ) -> Result<(), DbError>

Store a full menu: the restaurant, its categories (replacing the old ones) and items; items no longer on the menu are removed.

pub fn search_restaurants( &self, q: &RestaurantQuery, ) -> Result<Vec<RestaurantHit>, DbError>

Query restaurants in the catalog.

pub fn search_items(&self, q: &ItemQuery) -> Result<Vec<ItemHit>, DbError>

Query menu items in the catalog.

pub fn restaurant(&self, id: &str) -> Result<Option<RestaurantHit>, DbError>

One restaurant by id.

impl SqliteCache

pub fn cached_image_at(&self, url: &str, now: i64) -> Option<CachedImage>

The cached file for url, if present (and still on disk). Marks it recently used.

pub fn store_image_at( &self, url: &str, bytes: &[u8], content_type: &str, now: i64, ) -> Result<CachedImage, DbError>

Store downloaded image bytes for url (dedupes by content hash), then evict over the size cap.

impl SqliteCache

pub fn new(root: impl Into<PathBuf>, config: CacheConfig) -> Self

A cache rooted at root (the database is root/cache.sqlite). config supplies the image cap, the catalog max age and the TTLs used by stats and prune.

pub fn root(&self) -> &Path

The cache directory.

pub fn db_path(&self) -> PathBuf

pub fn config(&self) -> &CacheConfig

pub fn ttl(&self, kind: CacheKind) -> u64

pub fn stats(&self) -> Result<CacheStats>

pub fn clear(&self, kind: Option<CacheKind>, expired_only: bool) -> Result<u64>

Remove response entries, optionally only of one kind and/or only expired ones. Returns how many were removed. Catalog rows and images are kept (see clear_all / prune).

pub fn clear_all(&self) -> Result<ClearReport>

Remove everything: responses, catalog rows and image files.

pub fn prune(&self) -> Result<PruneReport>

Housekeeping: drop expired responses, catalog rows older than index_max_age_days, and evict images over image_max_mb (LRU), then compact the database.

Trait Implementations

impl Cache for SqliteCache

fn get_entry<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 CacheKey, ) -> Pin<Box<dyn Future<Output = Result<Option<CacheEntry>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The stored entry for key (expired or not), if any.

fn put_entry<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key: &'life1 CacheKey, entry: &'life2 CacheEntry, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Insert or replace the entry for key.

fn index_restaurants<'life0, 'life1, 'async_trait>( &'life0 self, rows: &'life1 [RestaurantRow], seen_from: Option<(f64, f64)>, now: i64, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Upsert restaurants seen in a list response. seen_from is the delivery location of the request; when given, each row’s distance / ETA / fee are also recorded for that location.

fn index_items<'life0, 'life1, 'async_trait>( &'life0 self, items: &'life1 [ItemRow], now: i64, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Upsert individual items (e.g. dish hits), keeping known categories.

fn index_menu<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, restaurant: &'life1 RestaurantRow, categories: &'life2 [CategoryRow], items: &'life3 [ItemRow], seen_from: Option<(f64, f64)>, now: i64, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Store a full menu: the restaurant, its categories (replacing the old ones) and items; items no longer on the menu are removed.

fn search_restaurants<'life0, 'life1, 'async_trait>( &'life0 self, q: &'life1 RestaurantQuery, ) -> Pin<Box<dyn Future<Output = Result<Vec<RestaurantHit>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Query restaurants in the catalog.

fn search_items<'life0, 'life1, 'async_trait>( &'life0 self, q: &'life1 ItemQuery, ) -> Pin<Box<dyn Future<Output = Result<Vec<ItemHit>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Query menu items in the catalog.

fn restaurant<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<RestaurantHit>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

One restaurant by id.

fn image<'life0, 'life1, 'async_trait>( &'life0 self, url: &'life1 str, now: i64, ) -> Pin<Box<dyn Future<Output = Result<Option<CachedImage>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The stored image for url, marking it recently used.

fn put_image<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, url: &'life1 str, bytes: &'life2 [u8], content_type: &'life3 str, now: i64, ) -> Pin<Box<dyn Future<Output = Result<CachedImage>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Store downloaded image bytes for url.

impl Clone for SqliteCache

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SqliteCache

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.