Struct SubscriptionDispatcher 

pub struct SubscriptionDispatcher { /* private fields */ }

Ring 1 dispatcher that routes notifications to subscriber channels.

The dispatcher drains NotificationRings from Ring 0, resolves NotificationRef values to ChangeEvent instances, and broadcasts them to active subscriber channels via SubscriptionRegistry.

Usage

let (shutdown_tx, shutdown_rx) = tokio::sync::watch::channel(false);
let dispatcher = SubscriptionDispatcher::new(
    rings, registry, data_source, config, shutdown_rx,
);
let handle = tokio::spawn(dispatcher.run());

// ... later ...
shutdown_tx.send(true).unwrap();
handle.await.unwrap();

Implementations

impl SubscriptionDispatcher

pub fn new( notification_rings: Vec<Arc<NotificationRing>>, registry: Arc<SubscriptionRegistry>, data_source: Arc<dyn NotificationDataSource>, config: DispatcherConfig, shutdown: Receiver<bool>, ) -> Self

Creates a new dispatcher.

pub async fn run(self)

Runs the dispatcher loop until shutdown.

Should be spawned as a tokio task.

pub fn drain_and_dispatch( &self, batch_buffer: &mut Vec<(u32, Vec<NotificationRef>)>, ) -> usize

Drains all notification rings and dispatches events.

Returns the total number of notifications drained.

pub fn metrics(&self) -> &Arc<DispatcherMetrics>

Returns the dispatcher metrics.