Struct RedisNotifier 

pub struct RedisNotifier { /* private fields */ }

Redis pub/sub-backed Notifier using the queue:notify channel.

Implementations

impl RedisNotifier

pub fn new(url: impl Into<String>) -> Self

Build a notifier from a connection URL (e.g. redis://127.0.0.1:6379). Subscribers run on a background tokio task that this struct spawns when wait is first called.

Trait Implementations

impl Clone for RedisNotifier

fn clone(&self) -> RedisNotifier

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RedisNotifier

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

Formats the value using the given formatter.

impl Notifier for RedisNotifier

fn notify<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Signal that new work was added.

fn wait<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Block until a notification arrives. Spurious wake-ups are allowed.