Struct CachingClient 

pub struct CachingClient {
    inner: Arc<dyn SashikoApi>,
    ttl: Duration,
    lists_cache: Mutex<Option<CacheEntry<Vec<MailingList>>>>,
    patchsets_cache: Mutex<HashMap<String, CacheEntry<Paginated<Patchset>>>>,
    stats_cache: Mutex<Option<CacheEntry<ServerStats>>>,
    detail_cache: Mutex<HashMap<String, CacheEntry<PatchsetDetail>>>,
}

In-memory caching decorator for SashikoApi.

Caches responses from the 4 actively-used endpoints (lists, patchsets, stats, patchset_summary) in typed HashMaps. All other trait methods pass through to the inner client.

Fields

inner: Arc<dyn SashikoApi>

ttl: Duration

lists_cache: Mutex<Option<CacheEntry<Vec<MailingList>>>>

patchsets_cache: Mutex<HashMap<String, CacheEntry<Paginated<Patchset>>>>

stats_cache: Mutex<Option<CacheEntry<ServerStats>>>

detail_cache: Mutex<HashMap<String, CacheEntry<PatchsetDetail>>>

Implementations

impl CachingClient

pub fn new(inner: Arc<dyn SashikoApi>, ttl: Duration) -> Self

Create a new caching decorator wrapping the given client.

A ttl of zero disables caching (always misses).

fn is_enabled(&self) -> bool

Check if the TTL is non-zero (caching enabled).

fn patchsets_key(params: &ListParams) -> String

Build a cache key for patchsets from ListParams.

fn read_single<T: Clone>( cache: &Mutex<Option<CacheEntry<T>>>, ttl: Duration, ) -> Option<T>

Try to read a valid entry from a single-value cache.

fn read_keyed<T: Clone>( cache: &Mutex<HashMap<String, CacheEntry<T>>>, key: &str, ttl: Duration, ) -> Option<T>

Try to read a valid entry from a keyed cache.

fn store_single<T>(cache: &Mutex<Option<CacheEntry<T>>>, value: T)

Store a value in a single-value cache.

fn store_keyed<T>( cache: &Mutex<HashMap<String, CacheEntry<T>>>, key: String, value: T, )

Store a value in a keyed cache.

Trait Implementations

impl SashikoApi for CachingClient

fn lists<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<MailingList>, ApiError>> + Send + 'async_trait>>

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

List tracked mailing lists.

fn patchsets<'life0, 'life1, 'async_trait>( &'life0 self, params: &'life1 ListParams, ) -> Pin<Box<dyn Future<Output = Result<Paginated<Patchset>, ApiError>> + Send + 'async_trait>>

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

Search/list patchsets with pagination.

fn stats<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<ServerStats, ApiError>> + Send + 'async_trait>>

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

Server status and counts.

fn patchset_summary<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 PatchId, ) -> Pin<Box<dyn Future<Output = Result<PatchsetDetail, ApiError>> + Send + 'async_trait>>

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

Patchset summary (lighter than patch_detail).

fn messages<'life0, 'life1, 'async_trait>( &'life0 self, params: &'life1 ListParams, ) -> Pin<Box<dyn Future<Output = Result<Paginated<EmailMessage>, ApiError>> + Send + 'async_trait>>

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

Search/list messages with pagination.

fn patch_detail<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 PatchId, ) -> Pin<Box<dyn Future<Output = Result<PatchsetDetail, ApiError>> + Send + 'async_trait>>

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

Full patchset detail (patches, reviews, thread, baseline).

fn message_detail<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 PatchId, ) -> Pin<Box<dyn Future<Output = Result<EmailMessage, ApiError>> + Send + 'async_trait>>

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

Single message detail with thread.

fn review<'life0, 'life1, 'async_trait>( &'life0 self, params: &'life1 ReviewQuery, ) -> Pin<Box<dyn Future<Output = Result<Value, ApiError>> + Send + 'async_trait>>

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

Review detail. One of id or patchset_id required.

fn review_log<'life0, 'life1, 'async_trait>( &'life0 self, params: &'life1 ReviewQuery, ) -> Pin<Box<dyn Future<Output = Result<Value, ApiError>> + Send + 'async_trait>>

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

Review detail with logs.

fn stats_timeline<'life0, 'async_trait>( &'life0 self, subsystem_id: Option<i64>, ) -> Pin<Box<dyn Future<Output = Result<Value, ApiError>> + Send + 'async_trait>>

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

Timeline data per day, optionally filtered by subsystem.

fn stats_reviews<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Value, ApiError>> + Send + 'async_trait>>

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

Review statistics by provider/model/status.

fn stats_tools<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Value, ApiError>> + Send + 'async_trait>>

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

Tool usage statistics.

fn clear_cache(&self)

Clear any cached responses. Default no-op; overridden by CachingClient.