Struct Dispatcher 

pub struct Dispatcher { /* private fields */ }

Routes notifications to registered senders by channel name.

Implementations

impl Dispatcher

pub fn new() -> Self

A dispatcher with no senders registered.

pub fn register(&mut self, sender: Arc<dyn Sender>) -> &mut Self

Register a sender for its channel; a later registration for the same channel replaces the earlier one.

pub fn channels(&self) -> impl Iterator<Item = &str>

Channels with a registered sender.

pub async fn dispatch( &self, channel: &str, recipient: &str, notif: &Notification, ) -> Result<(), NotifyError>

Dispatch to the sender registered under channel.

pub async fn drain( &self, outbox: &dyn DurableOutbox, worker_id: &str, lease_secs: i64, batch: usize, retry_delay_secs: i64, ) -> Result<usize, String>

Claim due outbox items and deliver each through its channel sender, recording success or scheduling a retry.

Trait Implementations

impl Clone for Dispatcher

fn clone(&self) -> Dispatcher

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for Dispatcher

fn default() -> Dispatcher

Returns the “default value” for a type.