feat(s2n-quic-dc): emit basic stream events

dc/s2n-quic-dc/events/connection.rs

@@ -1,8 +1,8 @@
 // Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
 // SPDX-License-Identifier: Apache-2.0
 
-#[event("application:write")]
-pub struct ApplicationWrite {
+#[event("stream:write")]
+pub struct StreamWrite {
     /// The number of bytes that the application tried to write
     #[measure("provided", Bytes)]
     total_len: usize,
@@ -11,10 +11,34 @@ pub struct ApplicationWrite {
     #[measure("committed", Bytes)]
     #[counter("committed.total", Bytes)]
     write_len: usize,
+
+    #[bool_counter("is_fin")]
+    is_fin: bool,
+
+    /// The operation was ready to be performed
+    #[bool_counter("ready")]
+    is_ready: bool,
+
+    /// The amount of time it took to process the write request
+    ///
+    /// Note that this includes both any syscall and encryption overhead
+    #[measure("processing_duration", Duration)]
+    processing_duration: core::time::Duration,
+}
+
+#[event("stream:write_shutdown")]
+pub struct StreamWriteShutdown {
+    /// The number of bytes in the send buffer at the time of shutdown
+    #[measure("buffer_len", Bytes)]
+    buffer_len: usize,
+
+    /// If the stream required a background task to drive the stream shutdown
+    #[bool_counter("background")]
+    background: bool,
 }
 
-#[event("application:read")]
-pub struct ApplicationRead {
+#[event("stream:read")]
+pub struct StreamRead {
     /// The number of bytes that the application tried to read
     #[measure("capacity", Bytes)]
     capacity: usize,
@@ -23,4 +47,21 @@ pub struct ApplicationRead {
     #[measure("committed", Bytes)]
     #[counter("committed.total", Bytes)]
     read_len: usize,
+
+    /// The operation was ready to be performed
+    #[bool_counter("ready")]
+    is_ready: bool,
+
+    /// The amount of time it took to process the read request
+    ///
+    /// Note that this includes both any syscall and decryption overhead
+    #[measure("processing_duration", Duration)]
+    processing_duration: core::time::Duration,
+}
+
+#[event("stream:read_shutdown")]
+pub struct StreamReadShutdown {
+    /// If the stream required a background task to drive the stream shutdown
+    #[bool_counter("background")]
+    background: bool,
 }