Struct WalInvalidator 

pub struct WalInvalidator { /* private fields */ }

WAL-based cache invalidator

Implementations

impl WalInvalidator

pub fn new(config: DistribCacheConfig) -> Self

Create a new invalidator

pub async fn start(&self, wal_endpoint: &str) -> CacheResult<()>

Start the invalidator - connects to WAL endpoint and begins processing

pub fn start_processing(&self) -> JoinHandle<()>

Start the WAL processing loop in a background task

pub async fn process_loop(&self)

Process WAL entries in the current task (blocking)

pub async fn stop(&self)

Stop the invalidator

pub fn is_running(&self) -> bool

Check if running

pub fn register(&self, table: &str, fingerprint: QueryFingerprint)

Register a cache fingerprint for a table

pub fn unregister(&self, table: &str, fingerprint: &QueryFingerprint)

Unregister a fingerprint

pub async fn add_callback(&self, callback: InvalidationCallback)

Add invalidation callback

pub fn add_callback_sync(&self, callback: InvalidationCallback)

Add callback (sync version for compatibility)

pub async fn invalidate_table_manual(&self, table: &str, all_entries: bool)

Manually invalidate a table (public API)

pub fn stats(&self) -> InvalidatorStatsSnapshot

Get invalidator statistics