Skip to content

Commit

Permalink
test(s2n-quic-core): add metric snapshot registry (#2371)
Browse files Browse the repository at this point in the history
  • Loading branch information
camshaft authored Nov 8, 2024
1 parent ef18f1c commit 56ce95a
Show file tree
Hide file tree
Showing 16 changed files with 7,191 additions and 703 deletions.
11 changes: 11 additions & 0 deletions quic/s2n-quic-core/events/connection.rs
Original file line number Diff line number Diff line change
Expand Up @@ -28,6 +28,7 @@ struct PacketSkipped {
//= https://tools.ietf.org/id/draft-marx-qlog-event-definitions-quic-h3-02#5.3.5
/// Packet was sent by a connection
struct PacketSent {
#[nominal_counter("kind")]
packet_header: PacketHeader,
#[measure("bytes", Bytes)]
#[counter("bytes.total", Bytes)]
Expand All @@ -38,6 +39,7 @@ struct PacketSent {
//= https://tools.ietf.org/id/draft-marx-qlog-event-definitions-quic-h3-02#5.3.6
/// Packet was received by a connection
struct PacketReceived {
#[nominal_counter("kind")]
packet_header: PacketHeader,
}

Expand Down Expand Up @@ -65,6 +67,7 @@ struct PathCreated<'a> {
// packet events.
/// Frame was sent
struct FrameSent {
#[nominal_counter("packet")]
packet_header: PacketHeader,
path_id: u64,
#[nominal_counter("frame")]
Expand All @@ -77,6 +80,7 @@ struct FrameSent {
// packet events.
/// Frame was received
struct FrameReceived<'a> {
#[nominal_counter("packet")]
packet_header: PacketHeader,
path: Path<'a>,
#[nominal_counter("frame")]
Expand All @@ -87,6 +91,7 @@ struct FrameReceived<'a> {
//= https://tools.ietf.org/id/draft-marx-qlog-event-definitions-quic-h3-02#5.4.5
/// Packet was lost
struct PacketLost<'a> {
#[nominal_counter("kind")]
packet_header: PacketHeader,
path: Path<'a>,
#[measure("bytes", Bytes)]
Expand Down Expand Up @@ -160,6 +165,7 @@ struct RxAckRangeDropped<'a> {
#[event("recovery:ack_range_received")]
/// ACK range was received
struct AckRangeReceived<'a> {
#[nominal_counter("packet")]
packet_header: PacketHeader,
path: Path<'a>,
ack_range: RangeInclusive<u64>,
Expand All @@ -168,6 +174,7 @@ struct AckRangeReceived<'a> {
#[event("recovery:ack_range_sent")]
/// ACK range was sent
struct AckRangeSent {
#[nominal_counter("packet")]
packet_header: PacketHeader,
path_id: u64,
ack_range: RangeInclusive<u64>,
Expand All @@ -184,7 +191,9 @@ struct PacketDropped<'a> {
//= https://tools.ietf.org/id/draft-marx-qlog-event-definitions-quic-h3-02#5.2.1
/// Crypto key updated
struct KeyUpdate {
#[nominal_counter("key_type")]
key_type: KeyType,
#[nominal_counter("cipher_suite")]
cipher_suite: CipherSuite,
}

Expand Down Expand Up @@ -216,6 +225,7 @@ struct ConnectionClosed {
#[event("transport:duplicate_packet")]
/// Duplicate packet received
struct DuplicatePacket<'a> {
#[nominal_counter("kind")]
packet_header: PacketHeader,
path: Path<'a>,
#[nominal_counter("error")]
Expand Down Expand Up @@ -308,6 +318,7 @@ struct TlsExporterReady<'a> {
#[event("connectivity:path_challenge_updated")]
/// Path challenge updated
struct PathChallengeUpdated<'a> {
#[nominal_counter("status")]
path_challenge_status: PathChallengeStatus,
path: Path<'a>,
challenge_data: &'a [u8],
Expand Down
Loading

0 comments on commit 56ce95a

Please sign in to comment.