Struct RtcMetricsRecorder

Source

pub struct RtcMetricsRecorder {Show 20 fields
    datagram_routes: PaddedCounterFamily<RtcDatagramRoutePath>,
    datagram_drops: PaddedCounterFamily<RtcDatagramDropReason>,
    datagram_fallback_scans: PaddedCounter,
    datagram_scan_users: PaddedCounter,
    nacks: PaddedCounterFamily<RtcNackDirection>,
    rtx_packets_received_from_publisher: PaddedCounter,
    rtx_payload_bytes_received_from_publisher: PaddedCounter,
    rtcp_ingress_budget_drops: PaddedCounter,
    output_budget_exhaustions: PaddedCounterFamily<RtcOutputBudgetLimit>,
    output_budget_session_closes: PaddedCounter,
    route_control: PaddedCounterFamily<RtcRouteControlOutcome>,
    keyframe_requests: PaddedCounterFamily<RtcKeyframeRequestOutcome>,
    relay_enqueues: PaddedCounterFamily<RtcRelayEnqueueResult>,
    relay_mailbox_depth_samples: PaddedCounter,
    relay_mailbox_depth_total: PaddedCounter,
    relay_drain_batches: PaddedCounter,
    relay_drained_packets: PaddedCounter,
    relay_drain_cap_hits: PaddedCounter,
    remote_control_drops: PaddedCounterFamily<RtcRemoteControlDropKind>,
    remote_packet_gate_convergence: PaddedCounterFamily<RtcRemotePacketGateConvergence>,
}

Expand description

Worker-local RTC packet-loop metric recorder.

Packet loops keep one recorder for their full worker lifetime. Datagram and route-control updates touch only this worker’s padded atomics while RuntimeMetrics aggregates all registered recorders during scrape capture.

Fields§

§datagram_routes: PaddedCounterFamily<RtcDatagramRoutePath>§datagram_drops: PaddedCounterFamily<RtcDatagramDropReason>§datagram_fallback_scans: PaddedCounter§datagram_scan_users: PaddedCounter§nacks: PaddedCounterFamily<RtcNackDirection>§rtx_packets_received_from_publisher: PaddedCounter§rtx_payload_bytes_received_from_publisher: PaddedCounter§rtcp_ingress_budget_drops: PaddedCounter§output_budget_exhaustions: PaddedCounterFamily<RtcOutputBudgetLimit>§output_budget_session_closes: PaddedCounter§route_control: PaddedCounterFamily<RtcRouteControlOutcome>§keyframe_requests: PaddedCounterFamily<RtcKeyframeRequestOutcome>§relay_enqueues: PaddedCounterFamily<RtcRelayEnqueueResult>§relay_mailbox_depth_samples: PaddedCounter§relay_mailbox_depth_total: PaddedCounter§relay_drain_batches: PaddedCounter§relay_drained_packets: PaddedCounter§relay_drain_cap_hits: PaddedCounter§remote_control_drops: PaddedCounterFamily<RtcRemoteControlDropKind>§remote_packet_gate_convergence: PaddedCounterFamily<RtcRemotePacketGateConvergence>

Struct RtcMetricsRecorder Copy item path

Fields§

Implementations§

impl RtcMetricsRecorder

pub fn record_rtc_datagram_route(&self, path: RtcDatagramRoutePath)

pub fn record_rtc_datagram_drop(&self, reason: RtcDatagramDropReason)

pub fn record_rtc_datagram_fallback_scan(&self, examined_sessions: usize)

pub fn record_rtc_nacks(&self, direction: RtcNackDirection, count: u64)

pub fn record_rtc_rtx_received_from_publisher(&self, payload_bytes: usize)

pub fn record_rtc_rtcp_ingress_budget_drop(&self)

pub fn record_rtc_output_budget_exhaustion(&self, limit: RtcOutputBudgetLimit)

pub fn record_rtc_output_budget_session_close(&self)

pub fn record_rtc_route_control(&self, outcome: RtcRouteControlOutcome)

pub fn record_rtc_keyframe_request(&self, outcome: RtcKeyframeRequestOutcome)

pub fn record_rtc_relay_enqueue(&self, result: RtcRelayEnqueueResult)

pub fn record_rtc_relay_mailbox_depth(&self, depth: usize)

pub fn record_rtc_relay_drain_batch( &self, drained_packets: usize, cap_hit: bool, )

pub fn record_rtc_remote_control_drop(&self, kind: RtcRemoteControlDropKind)

pub fn record_rtc_remote_packet_gate_convergence( &self, outcome: RtcRemotePacketGateConvergence, )

Trait Implementations§

impl Debug for RtcMetricsRecorder

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

impl Default for RtcMetricsRecorder

fn default() -> RtcMetricsRecorder

Auto Trait Implementations§

impl !Freeze for RtcMetricsRecorder

impl RefUnwindSafe for RtcMetricsRecorder

impl Send for RtcMetricsRecorder

impl Sync for RtcMetricsRecorder

impl Unpin for RtcMetricsRecorder

impl UnsafeUnpin for RtcMetricsRecorder

impl UnwindSafe for RtcMetricsRecorder

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FutureExt for T

fn with_context(self, otel_cx: Context) -> WithContext<Self>

fn with_current_context(self) -> WithContext<Self>

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> PolicyExt for Twhere T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>where T: Policy<B, E>, P: Policy<B, E>,

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DTwhere ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DTwhere ST: ?Sized, DT: ?Sized,

impl<A, B, T> HttpServerConnExec<A, B> for Twhere B: Body,

impl<T> Read<Exclusive, BecauseExclusive> for Twhere T: ?Sized,

Struct RtcMetricsRecorder

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

impl<A, B, T> HttpServerConnExec<A, B> for T
where B: Body,

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,