Struct InvalidationManager 

pub struct InvalidationManager { /* private fields */ }

Cache invalidation manager

Tracks table -> cache key mappings and handles invalidation events.

Implementations

impl InvalidationManager

pub fn new(config: InvalidationConfig) -> Self

Create a new invalidation manager

pub fn register(&self, key: &CacheKey, table: &str)

Register a cache key for table-based invalidation

pub fn unregister(&self, key: &CacheKey)

Unregister a cache key

pub fn get_keys_for_table(&self, table: &str) -> Vec<CacheKey>

Get all cache keys associated with a table

pub fn get_tables_for_key(&self, key: &CacheKey) -> Vec<String>

Get all tables associated with a cache key

pub fn invalidate_table(&self, table: &str)

Invalidate all cache entries for a table

pub fn invalidate_tables(&self, tables: &[String])

Invalidate multiple tables

pub fn queue_invalidation(&self, table: &str)

Queue a table for batched invalidation

pub fn flush_pending(&self)

Flush pending invalidations

pub fn on_wal_event(&self, table: &str, operation: WalOperation, lsn: u64)

Handle a WAL event

pub fn subscribe(&self) -> Receiver<InvalidationEvent>

Subscribe to invalidation events

pub fn is_wal_connected(&self) -> bool

Check if WAL is connected

pub fn set_wal_connected(&self, connected: bool)

Set WAL connection status

pub fn mode(&self) -> InvalidationMode

Get invalidation mode

pub fn last_invalidation_time(&self, table: &str) -> Option<Instant>

Get last invalidation time for a table

pub fn stats(&self) -> InvalidationStats

Get statistics

pub fn clear(&self)

Clear all tracking data

Trait Implementations

impl Debug for InvalidationManager

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

Formats the value using the given formatter.