Struct NotificationBus 

pub struct NotificationBus { /* private fields */ }

Publish/subscribe bus for JobEvents.

Built on a tokio::sync::broadcast channel; all subscribers receive every event. Lagged subscribers (that fall more than capacity events behind) will receive a broadcast::error::RecvError::Lagged error and must re-subscribe if they need to continue receiving.

Implementations

impl NotificationBus

pub fn new(capacity: usize) -> Self

Create a new bus with the given ring-buffer capacity.

A reasonable default is 64–256 events. When the buffer fills, the oldest events are dropped and late subscribers receive a Lagged error.

pub fn send(&self, event: JobEvent) -> usize

Publish an event to all current subscribers.

Returns the number of active receivers that received the event. Returns 0 if no subscribers are active (not an error).

pub fn subscribe(&self) -> Receiver<JobEvent>

Subscribe to future events.

The returned receiver will receive all events published after this call. Clone the receiver to fan it out to multiple async tasks.

pub fn subscriber_count(&self) -> usize

Returns the number of active subscribers.

pub fn notify(&self, job_id: Uuid, event_type: JobEventType) -> usize

Create a convenience event and send it in one call.

Trait Implementations

impl Debug for NotificationBus

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

Formats the value using the given formatter.

impl Default for NotificationBus

fn default() -> Self

Returns the “default value” for a type.