Struct NotificationBatcher 

pub struct NotificationBatcher { /* private fields */ }

Accumulates events per source and flushes as batches.

Used by the Ring 1 dispatcher to reduce per-event overhead when delivering to subscribers. Each source has its own buffer, so events from different sources are never mixed.

Implementations

impl NotificationBatcher

pub fn new(config: BatchConfig) -> Self

Creates a new batcher with the given configuration.

pub fn add( &mut self, source_id: u32, source_name: &str, event: ChangeEvent, ) -> Option<ChangeEventBatch>

Adds an event to the batcher.

Returns Some(ChangeEventBatch) if the batch is ready to deliver (size or time trigger), or None if the event was buffered.

When batching is disabled, always returns a single-event batch.

pub fn flush_all(&mut self) -> Vec<(u32, ChangeEventBatch)>

Forces flush of all pending batches.

Returns a vec of (source_id, batch) for all non-empty buffers.

pub fn flush_expired(&mut self) -> Vec<(u32, ChangeEventBatch)>

Flushes batches that have exceeded the max_batch_delay.

Returns a vec of (source_id, batch) for expired buffers.

pub fn buffered_count(&self) -> usize

Returns the number of buffered events across all sources.

pub fn config(&self) -> &BatchConfig

Returns the configuration.