feat: add metric for total bytes inbound received

Author: ogenev

portalnet/src/overlay/service.rs

@@ -1903,6 +1903,10 @@ impl<
         query_trace_events_tx: Option<UnboundedSender<QueryTraceEvent>>,
     ) {
         let mut content = content;
+        // report the total bytes of content received
+        utp_processing
+            .metrics
+            .report_bytes_inbound(content.len() as u64);
         // Operate under assumption that all content in the store is valid
         let local_value = utp_processing.store.read().get(&content_key);
         if let Ok(Some(val)) = local_value {

trin-metrics/src/overlay.rs

@@ -18,6 +18,8 @@ pub struct OverlayMetrics {
     pub message_total: IntCounterVec,
     pub utp_outcome_total: IntCounterVec,
     pub utp_active_gauge: IntGaugeVec,
+    /// Total bytes transferred inbound
+    pub bytes_inbound_total: IntCounterVec,
     pub validation_total: IntCounterVec,
 }
 
@@ -47,6 +49,14 @@ impl OverlayMetrics {
             &["protocol", "direction"],
             registry
         )?;
+        let bytes_inbound_total = register_int_counter_vec_with_registry!(
+            opts!(
+                "trin_bytes_inbound_total",
+                "count all bytes transferred inbound"
+            ),
+            &["protocol"],
+            registry
+        )?;
         let validation_total = register_int_counter_vec_with_registry!(
             opts!(
                 "trin_validation_total",
@@ -59,6 +69,7 @@ impl OverlayMetrics {
             message_total,
             utp_outcome_total,
             utp_active_gauge,
+            bytes_inbound_total,
             validation_total,
         })
     }
@@ -111,6 +122,14 @@ impl OverlayMetricsReporter {
             .with_label_values(&labels)
             .inc();
     }
+    /// Increase the total bytes inbound metric by the given length.
+    pub fn report_bytes_inbound(&self, bytes_len: u64) {
+        let labels: [&str; 1] = [&self.protocol];
+        self.overlay_metrics
+            .bytes_inbound_total
+            .with_label_values(&labels)
+            .inc_by(bytes_len)
+    }
 
     //
     // uTP metrics