Struct Notifiers 

pub struct Notifiers(/* private fields */);

The profile name -> dispatcher map, as a handle that survives a configuration reload.

The map itself is rebuilt whole on every generation, but two of its readers outlive a generation: a signer backend captures it at construction (and signer backends are carried across reloads rather than rebuilt), and NotifyJob captures it at registration. Handing those two a plain Arc pinned them to generation zero, which is worse than stale — a request served by a new router writes a notify_deliver row naming a slot id from the new configuration, and a NotifyJob still holding the old map would answer JobOutcome::Failed for it. Permanently: an unknown backend id is retired rather than retried, by design.

tokio::sync::watch::Receiver::borrow takes &self and does not mark the value seen, so this stays Clone + Send + Sync and get is callable from any task. A generation is published with a single synchronous tokio::sync::watch::Sender::send_replace, so no reader can observe a half-built map.

Implementations

impl Notifiers

pub fn get(&self, profile: &str) -> Option<Arc<NotifyDispatcher>>

The dispatcher for profile in the current generation, if it is mounted.

Trait Implementations

impl Clone for Notifiers

fn clone(&self) -> Notifiers

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl From<Arc<HashMap<String, Arc<NotifyDispatcher>>>> for Notifiers

A fixed map, for every caller that has no reload to serve — the tests, and any construction that predates the first generation being published.

Dropping the sender leaves borrow working for ever (only changed() ever errors on a closed channel), so this is a genuine constant, not a channel that will go quiet. It is also what lets every existing call site pass an Arc<HashMap<..>> unchanged.

fn from(map: Arc<DispatcherMap>) -> Self

Converts to this type from the input type.

impl From<HashMap<String, Arc<NotifyDispatcher>>> for Notifiers

fn from(map: DispatcherMap) -> Self

Converts to this type from the input type.