Struct TranscodeRunnerHandle 

pub struct TranscodeRunnerHandle { /* private fields */ }

Cheaply-cloneable handle returned by TranscodeRunner::install.

Holds the spawned per-transcoder drain tasks alive for the server lifetime; tests and admin consumers read per- (transcoder, rendition, broadcast, track) counters off this handle. Dropping it aborts every spawned task; mid-stride aborts do NOT call Transcoder::on_stop, matching the [lvqr_agent::AgentRunnerHandle] shutdown shape.

Implementations

impl TranscodeRunnerHandle

pub fn fragments_seen( &self, transcoder: &str, rendition: &str, broadcast: &str, track: &str, ) -> u64

Total fragments observed by transcoder producing rendition from (broadcast, track). Returns 0 if no transcoder under that key has fired yet.

pub fn panics( &self, transcoder: &str, rendition: &str, broadcast: &str, track: &str, ) -> u64

Caught-panic count for transcoder producing rendition from (broadcast, track). Aggregates on_start, on_fragment, and on_stop panics under one counter.

pub fn tracked(&self) -> Vec<(String, String, String, String)>

Snapshot of every (transcoder, rendition, broadcast, track) quadruple the runner has spawned a drain task for.

Trait Implementations

impl Clone for TranscodeRunnerHandle

fn clone(&self) -> TranscodeRunnerHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TranscodeRunnerHandle

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.