Struct NotificationRegistry 

pub struct NotificationRegistry { /* private fields */ }

In-memory registry of ephemeral notification channels.

The registry is Send + Sync and intended to live behind an Arc on the runtime — typically one per server process. It owns no on-disk state, no WAL entries, and no audit-event tail: a process restart drops every channel and every connected listener, which is the intended ephemeral contract.

Implementations

impl NotificationRegistry

pub fn new() -> NotificationRegistry

pub fn subscribe( &self, scope: NotificationScope, channel: impl Into<String>, ) -> Receiver<NotificationEvent>

Subscribe to (scope, channel).

The returned receiver only observes notifications published AFTER subscribe returns. Drop the receiver to unsubscribe; the underlying channel is reaped from the registry when its last receiver is dropped and no senders remain outstanding.

pub fn publish( &self, scope: NotificationScope, channel: impl Into<String>, payload: impl Into<String>, now_ms: u128, ) -> usize

Publish a payload on (scope, channel) and return the number of currently connected listeners that received the event. Returns 0 if no listeners are connected — the notification is dropped (no buffering, no replay).

pub fn publish_authorized( &self, principal_tenant: Option<&str>, target: NotificationScope, channel: impl Into<String>, payload: impl Into<String>, has_cross_tenant_cap: bool, now_ms: u128, ) -> Result<usize, NotificationError>

Authorization-gated publish.

principal_tenant is the publisher’s tenant binding (None = platform/global). target is the channel scope the publisher asked for. has_cross_tenant_cap must be true if the calling transport’s policy evaluator previously granted the principal the notify:cross-tenant action; the registry does not consult policies directly, keeping the authorization boundary on the transport side (mirrors the AiProviderGate pattern from #711).

pub fn subscribe_authorized( &self, principal_tenant: Option<&str>, target: NotificationScope, channel: impl Into<String>, has_cross_tenant_cap: bool, ) -> Result<Receiver<NotificationEvent>, NotificationError>

Authorization-gated subscribe — mirror of Self::publish_authorized for the read side.

pub fn channel_count(&self) -> usize

Number of channels currently registered. Test/diagnostic helper — operators should not depend on this value.

Trait Implementations

impl Clone for NotificationRegistry

fn clone(&self) -> NotificationRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for NotificationRegistry

fn default() -> NotificationRegistry

Returns the “default value” for a type.