Struct CoreResultCache 

pub struct CoreResultCache { /* private fields */ }

Thread-safe core-level SPARQL query result cache.

Construct with CoreResultCache::new and use put / get for caching.

Example

use oxirs_core::cache::result_cache::{CoreResultCache, CoreCacheKey};
use std::time::Duration;

let cache = CoreResultCache::new(1000, Duration::from_secs(300));
let key   = CoreCacheKey::new("my_dataset", "SELECT * WHERE { ?s ?p ?o }");
cache.put(key.clone(), vec![], vec!["http://p/name".to_string()]);
assert!(cache.get(&key).is_some());

Implementations

impl CoreResultCache

pub fn new(capacity: usize, ttl: Duration) -> Self

Create a new cache with capacity entries and a default TTL.

pub fn get(&self, key: &CoreCacheKey) -> Option<Vec<HashMap<String, String>>>

Retrieve a cached result.

Returns None on a miss (including expired entries, which are then removed). On a hit, last_accessed and hit_count are updated and the entry is moved to the MRU position.

pub fn put( &self, key: CoreCacheKey, rows: Vec<HashMap<String, String>>, predicates: Vec<String>, )

Store a query result in the cache.

If the cache is at capacity, the least-recently-used entry is evicted first. Expired entries are also purged opportunistically on every put.

pub fn put_with_ttl( &self, key: CoreCacheKey, rows: Vec<HashMap<String, String>>, predicates: Vec<String>, ttl: Duration, )

Like CoreResultCache::put but with a custom TTL for this entry.

pub fn invalidate_dataset(&self, dataset_id: &str) -> usize

Invalidate all entries for a given dataset.

Returns the number of entries removed.

pub fn invalidate_predicate(&self, dataset_id: &str, predicate: &str) -> usize

Invalidate all entries for a dataset that accessed a specific predicate.

Returns the number of entries removed.

pub fn invalidate_on_delta( &self, dataset_id: &str, deltas: &[TripleDelta], ) -> usize

Invalidate cache entries affected by the given triple deltas.

An entry is considered affected if:

• Its accessed_predicates list is empty (wildcard), or
• Any of the delta predicates appears in the entry’s accessed_predicates.

Returns the number of entries removed.

pub fn hit_rate(&self) -> f64

Return the cache hit rate in [0, 1].

Returns 0.0 if no requests have been made yet.

pub fn size(&self) -> usize

Return the number of entries currently in the cache (including potentially expired ones that have not yet been purged).

pub fn clear(&self)

Forcibly remove all entries from the cache.

pub fn hit_count(&self) -> u64

Return the raw hit count.

pub fn miss_count(&self) -> u64

Return the raw miss count.