Struct ClientMetrics 

pub struct ClientMetrics {
    pub average_processing_time_ms: f64,
    pub frames_acknowledged: u32,
    pub last_ack_time: Option<Instant>,
    pub estimated_bandwidth_kbps: Option<f64>,
    pub connection_rtt_ms: Option<u64>,
}

Client performance metrics for adaptive streaming

Fields

average_processing_time_ms: f64

Exponential moving average of client frame-processing time, in milliseconds.

frames_acknowledged: u32

Number of frames the client has acknowledged.

last_ack_time: Option<Instant>

Instant of the most recent acknowledgement, if any.

estimated_bandwidth_kbps: Option<f64>

Estimated downlink bandwidth, in kilobits per second, if measured.

connection_rtt_ms: Option<u64>

Round-trip time of the WebSocket connection, in milliseconds, if measured.

Implementations

impl ClientMetrics

pub fn update_processing_time(&mut self, processing_time_ms: u64)

Fold a new processing-time observation into the moving average.

pub fn is_client_slow(&self) -> bool

Returns true when average client processing time exceeds the slow-client threshold.

pub fn recommended_frame_delay(&self) -> Duration

Recommended delay between frames given the current processing-time average.

Clamped to MAX_ADAPTIVE_FRAME_DELAY: average_processing_time_ms is derived from client-supplied processing_time_ms in Self::update_processing_time, which is unvalidated wire input (see handle_frame_ack). Without a ceiling, a single malicious FrameAck could drive the tokio::time::sleep in AdaptiveStreamController::stream_frames to an arbitrarily long duration and stall that session’s stream.

Trait Implementations

impl Debug for ClientMetrics

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

Formats the value using the given formatter.

impl Default for ClientMetrics

fn default() -> ClientMetrics

Returns the “default value” for a type.