Struct InvalidationSubscriber 

pub struct InvalidationSubscriber { /* private fields */ }

Handle for subscribing to invalidation messages

This spawns a background task that listens to Redis Pub/Sub and processes invalidation messages by calling the provided handler callback.

Implementations

impl InvalidationSubscriber

pub fn new(redis_url: &str, config: InvalidationConfig) -> CacheResult<Self>

Create a new subscriber

Arguments

• redis_url - Redis connection URL
• config - Invalidation configuration

Errors

Returns an error if Redis client creation fails.

pub fn stats(&self) -> InvalidationStats

Get a snapshot of current statistics

pub fn start<F, Fut>(&self, handler: F) -> JoinHandle<()>

where F: Fn(InvalidationMessage) -> Fut + Send + Sync + 'static, Fut: Future<Output = CacheResult<()>> + Send + 'static,

Start the subscriber background task

Arguments

• handler - Async function to handle each invalidation message

Returns

Join handle for the background task

pub fn shutdown(&self)

Signal the subscriber to shutdown