Struct RealtimeBroadcastObserver 

pub struct RealtimeBroadcastObserver { /* private fields */ }

Observer that forwards entity change events to the realtime delivery pipeline.

Create with RealtimeBroadcastObserver::new, wire the returned receiver into an super::delivery::EventDeliveryPipeline, then call on_mutation_complete from the mutation path.

Implementations

impl RealtimeBroadcastObserver

pub fn new(capacity: usize) -> (Self, Receiver<EntityEvent>)

Create a new observer and its corresponding event receiver.

The capacity controls how many events can be buffered before backpressure causes events to be dropped. Pass the receiver to an super::delivery::EventDeliveryPipeline.

pub fn on_mutation_complete(&self, event: EntityEvent)

Called when a mutation completes. Non-blocking.

Tries to enqueue the event on the delivery-pipeline channel. If the channel is full (pipeline under backpressure), the event is dropped and realtime_events_dropped_backpressure_total is incremented. This keeps the mutation response path free from realtime delivery latency.

pub fn events_dropped_total(&self) -> u64

Total number of events dropped due to delivery-pipeline backpressure.

Used by metrics exporters and health checks.