Add total L2 packet length of a session to connection log

CHANGELOG.md

@@ -5,6 +5,12 @@ file is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/), and
 this project adheres to [Semantic
 Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [Unreleased]
+
+### Changed
+
+- Modified connection log structure to include total L2 frame length of a session.
+
 ## [0.17.0] - 2024-05-16
 
 ### Added

src/ingest.rs

@@ -168,6 +168,8 @@ mod tests {
             resp_bytes: 295,
             orig_pkts: 397,
             resp_pkts: 511,
+            orig_l2_bytes: 21515,
+            resp_l2_bytes: 27889,
         };
         super::send_event(&mut channel.client.send, 9999, conn.clone())
             .await

src/ingest/network.rs

@@ -24,13 +24,15 @@ pub struct Conn {
     pub resp_bytes: u64,
     pub orig_pkts: u64,
     pub resp_pkts: u64,
+    pub orig_l2_bytes: u64,
+    pub resp_l2_bytes: u64,
 }
 
 impl Display for Conn {
     fn fmt(&self, f: &mut Formatter) -> std::fmt::Result {
         write!(
             f,
-            "{}\t{}\t{}\t{}\t{}\t{}\t{}\t{}\t{}\t{}\t{}\t{}",
+            "{}\t{}\t{}\t{}\t{}\t{}\t{}\t{}\t{}\t{}\t{}\t{}\t{}\t{}",
             self.orig_addr,
             self.orig_port,
             self.resp_addr,
@@ -42,7 +44,9 @@ impl Display for Conn {
             self.orig_bytes,
             self.resp_bytes,
             self.orig_pkts,
-            self.resp_pkts
+            self.resp_pkts,
+            self.orig_l2_bytes,
+            self.resp_l2_bytes
         )
     }
 }

src/publish.rs

@@ -550,6 +550,8 @@ mod tests {
             resp_bytes: 295,
             orig_pkts: 397,
             resp_pkts: 511,
+            orig_l2_bytes: 21515,
+            resp_l2_bytes: 27889,
         };
         let raw_event = bincode::serialize(&conn).unwrap();
         let source = bincode::serialize(&"hello").unwrap();
@@ -706,6 +708,8 @@ mod tests {
             resp_bytes: 295,
             orig_pkts: 397,
             resp_pkts: 511,
+            orig_l2_bytes: 21515,
+            resp_l2_bytes: 27889,
         };
         let raw_event = bincode::serialize(&conn).unwrap();