Struct ThingsCacheInvalidationHandler 

pub struct ThingsCacheInvalidationHandler { /* private fields */ }

Bridge handler that routes InvalidationEvents into a [ThingsCache]’s dependency-aware invalidation methods.

Register one of these on a CacheInvalidationMiddleware to make process_event(...) actually evict cached entries:

let cache = Arc::new(ThingsCache::new_default());
let handler = ThingsCacheInvalidationHandler::new(Arc::clone(&cache));
middleware.register_handler(Box::new(handler));

Spawns the actual eviction onto the current Tokio runtime so the synchronous trait method can return immediately. Callers that need to observe the post-invalidation state (e.g. tests) should yield once with tokio::task::yield_now().await after process_event returns.

Implementations

impl ThingsCacheInvalidationHandler

pub fn new(cache: Arc<ThingsCache>) -> Self

Construct a handler with the default cache type label "things_cache".

pub fn with_cache_type(cache: Arc<ThingsCache>, cache_type: String) -> Self

Construct a handler with a caller-supplied cache type label.

Trait Implementations

impl CacheInvalidationHandler for ThingsCacheInvalidationHandler

fn invalidate(&self, event: &InvalidationEvent) -> Result<()>

Handle cache invalidation

fn cache_type(&self) -> &str

Get cache type name

fn can_handle(&self, _event: &InvalidationEvent) -> bool

Check if this handler can handle the event