HTTP.WebTransport.Telemetry (http_web_transport v0.10.0)

View Source

Telemetry helpers for WebTransport lifecycle, datagram, and stream events.

Summary

Functions

connect_exception(url, error, duration)
connect_start(url)
connect_stop(url, protocol, reliability, duration)
datagram_received(url, bytes, queue_length)
datagram_sent(url, bytes, queue_length)
session_closed(url, close_code, reason)
session_draining(url)
session_exception(url, error)
stream_closed(url, stream_id)
stream_opened(url, stream_id, direction)
stream_received(url, stream_id, bytes)
stream_sent(url, stream_id, bytes)

Functions

connect_exception(url, error, duration)

@spec connect_exception(URI.t(), term(), non_neg_integer()) :: :ok

connect_start(url)

@spec connect_start(URI.t()) :: :ok

connect_stop(url, protocol, reliability, duration)

@spec connect_stop(URI.t(), String.t(), String.t(), non_neg_integer()) :: :ok

datagram_received(url, bytes, queue_length)

@spec datagram_received(URI.t(), non_neg_integer(), non_neg_integer()) :: :ok

datagram_sent(url, bytes, queue_length)

@spec datagram_sent(URI.t(), non_neg_integer(), non_neg_integer()) :: :ok

session_closed(url, close_code, reason)

@spec session_closed(URI.t(), non_neg_integer(), String.t()) :: :ok

session_draining(url)

@spec session_draining(URI.t()) :: :ok

session_exception(url, error)

@spec session_exception(URI.t(), term()) :: :ok

stream_closed(url, stream_id)

@spec stream_closed(URI.t(), term()) :: :ok

stream_opened(url, stream_id, direction)

@spec stream_opened(URI.t(), term(), atom()) :: :ok

stream_received(url, stream_id, bytes)

@spec stream_received(URI.t(), term(), non_neg_integer()) :: :ok

stream_sent(url, stream_id, bytes)

@spec stream_sent(URI.t(), term(), non_neg_integer()) :: :ok