Struct ReliableStreamSubscriber 

pub struct ReliableStreamSubscriber { /* private fields */ }

Reliable subscriber using Redis Streams and Consumer Groups

Implementations

impl ReliableStreamSubscriber

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

Create a new ReliableStreamSubscriber

Errors

Returns an error if the Redis client fails to open.

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

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

pub fn shutdown(&self)

Signal the subscriber to shutdown