Struct FeedHandle 

pub struct FeedHandle { /* private fields */ }

Handle to a running feed.

Provides per-feed monitoring and control: health events, metrics, queue telemetry, uptime, pause/resume, and stop.

Backed by Arc<FeedSharedState> — cloning is cheap (Arc bump). Metrics are read from the same atomic counters that the feed worker thread writes.

Implementations

impl FeedHandle

pub fn id(&self) -> FeedId

The feed’s unique identifier.

pub fn is_paused(&self) -> bool

Whether the feed is currently paused.

pub fn is_alive(&self) -> bool

Whether the worker thread is still alive.

pub fn metrics(&self) -> FeedMetrics

Get a snapshot of the feed’s current metrics.

Reads live atomic counters maintained by the feed worker thread.

pub fn queue_telemetry(&self) -> QueueTelemetry

Get a snapshot of the feed’s source and sink queue depths/capacities.

Source queue depth reads the frame queue’s internal lock briefly. Sink queue depth reads an atomic counter with no locking.

If no processing session is active (between restarts or after shutdown), both depths return 0.

pub fn uptime(&self) -> Duration

Elapsed time since the feed’s current processing session started.

Semantics: session-scoped uptime. The clock resets on each successful start or restart. If the feed has not started yet or is between restart attempts, the value reflects the time since the last session began.

Useful for monitoring feed stability: a feed that restarts frequently will show low uptime values.

pub fn decode_status(&self) -> Option<DecodeStatus>

The decode method confirmed by the media backend for this feed.

Returns None if no decode decision has been made yet (the stream has not started, the backend has not negotiated a decoder, or the feed is between restarts).

pub fn diagnostics(&self) -> FeedDiagnostics

Get a consolidated diagnostics snapshot of this feed.

Composes lifecycle state, metrics, queue depths, decode status, and view-system health into a single read. All data comes from the same atomic counters the individual accessors use — this is a convenience composite, not a new data source.

Suitable for periodic polling (1–5 s) by dashboards and health probes.

pub fn pause(&self) -> Result<(), NvError>

Pause the feed (stop pulling frames from source; stages idle).

Uses a condvar to wake the worker without spin-sleeping.

Errors

Returns an error if the feed is already paused.

pub fn resume(&self) -> Result<(), NvError>

Resume a paused feed.

Notifies the worker thread via condvar so it wakes immediately.

Errors

Returns an error if the feed is not paused.

Trait Implementations

impl Clone for FeedHandle

fn clone(&self) -> FeedHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.