ref: Add event size metrics

Author: untitaker

common/src/metrics.rs

@@ -168,4 +168,15 @@ macro_rules! metric {
         });
         rv
     }};
+
+    // we use statsd timers to send things such as filesizes as well.
+    (time_raw($id:expr) = $value:expr $(, $k:expr => $v:expr)* $(,)?) => {{
+        use $crate::metrics::_pred::*;
+        $crate::metrics::with_client(|client| {
+            client.time_with_tags($id, $value)
+                $(.with_tag($k, $v))*
+                .send();
+        })
+    }};
+
 }

server/src/body/store_body.rs

@@ -12,6 +12,8 @@ use flate2::read::ZlibDecoder;
 use futures::prelude::*;
 use url::form_urlencoded;
 
+use semaphore_common::metric;
+
 use crate::actors::outcome::DiscardReason;
 
 /// A set of errors that can occur during parsing json payloads
@@ -159,7 +161,12 @@ impl Future for StoreBody {
                     Ok(body)
                 }
             })
-            .and_then(|body| decode_bytes(body.freeze()));
+            .and_then(|body| {
+                metric!(time_raw("event.size_bytes.raw") = body.len() as u64);
+                let decoded = decode_bytes(body.freeze())?;
+                metric!(time_raw("event.size_bytes.uncompressed") = decoded.len() as u64);
+                Ok(decoded)
+            });
 
         self.fut = Some(Box::new(future));