Struct CountingObserver 

pub struct CountingObserver { /* private fields */ }

An Observer that counts the events it sees. Cheap to clone (shared counters) so a copy can be handed to the engine and another kept for asserts.

Implementations

impl CountingObserver

pub fn new() -> Self

A new observer with all counters at zero.

pub fn frames(&self) -> u64

Total frames observed via Observer::on_frame.

pub fn publish_started(&self) -> u64

Count of Observer::on_publish_started calls.

pub fn publish_ended(&self) -> u64

Count of Observer::on_publish_ended calls.

pub fn events(&self) -> u64

Count of Observer::on_event calls.

pub fn lagged(&self) -> u64

Total frames reported dropped via Observer::on_subscriber_lagged.

Trait Implementations

impl Clone for CountingObserver

fn clone(&self) -> CountingObserver

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for CountingObserver

fn default() -> CountingObserver

Returns the “default value” for a type.

impl Observer for CountingObserver

fn on_event(&self, _event: &StreamEvent)

A stream lifecycle event was emitted.

fn on_publish_started(&self, _app: &str)

A publish session started in application app.

fn on_publish_ended(&self, _app: &str)

A publish session ended in application app.

fn on_frame(&self, _key: &StreamKey, _frame: &MediaFrame)

A frame was published. Hot-path hook — keep it cheap. The default is a no-op so the branch is trivially predicted away when no observer is installed.

fn on_subscriber_lagged(&self, _key: &StreamKey, skipped: u64)

A subscriber fell behind the broadcast buffer and skipped frames were dropped from its view before it could read them. This is the canonical slow-consumer signal: alert on it. Fired by StreamHandle::subscribe_resilient.

fn on_subscriber_evicted(&self, _key: &StreamKey)

A chronically slow subscriber crossed its max_lag budget and was shed. Fired by Subscription::recv.

fn on_rate_limited(&self, _key: &StreamKey)

An ingress rate limit was exceeded for key; the protocol handler should drop or backpressure the connection. Handlers call this from their ingest loop (e.g. when IngestRateLimit returns false).

fn on_stream_reaped(&self, _key: &StreamKey)

A publish session was reaped for exceeding the engine’s idle timeout.