Struct InvalidationEngine 

pub struct InvalidationEngine { /* private fields */ }

Core invalidation engine

Implementations

impl InvalidationEngine

pub fn new(strategy: InvalidationStrategy) -> Self

Create new invalidation engine

pub fn with_config( strategy: InvalidationStrategy, config: InvalidationConfig, ) -> Self

Create with configuration

pub fn register_dependencies( &self, cache_key: CacheKey, patterns: Vec<TriplePattern>, ) -> Result<()>

Register dependencies for a cache entry with default TTL

pub fn register_dependencies_with_ttl( &self, cache_key: CacheKey, patterns: Vec<TriplePattern>, ttl: Option<Duration>, ) -> Result<()>

Register dependencies for a cache entry with custom TTL

pub fn cleanup_expired<F>(&self, invalidate_fn: F) -> Result<usize>

where F: FnMut(&CacheKey) -> Result<()>,

Clean up expired cache entries based on TTL

pub fn start_ttl_cleanup_task<F>(&self, invalidate_fn: F)

where F: Fn(&CacheKey) -> Result<()> + Send + Sync + 'static,

Start background TTL cleanup task

pub fn remove_entry(&self, cache_key: &CacheKey) -> Result<()>

Remove cache entry and its dependencies

pub fn find_affected_entries( &self, triple: &TriplePattern, ) -> Result<HashSet<CacheKey>>

Find entries that should be invalidated due to a triple update

pub fn invalidate<F>( &self, triple: &TriplePattern, invalidate_fn: F, ) -> Result<()>

where F: FnMut(&CacheKey) -> Result<()>,

Invalidate cache entries (strategy-dependent)

pub fn flush_pending<F>(&self, invalidate_fn: F) -> Result<()>

where F: FnMut(&CacheKey) -> Result<()>,

Force flush all pending invalidations

pub fn statistics(&self) -> InvalidationStatistics

Get invalidation statistics

pub fn clear(&self) -> Result<()>

Clear all state

Trait Implementations

impl Clone for InvalidationEngine

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.