Add experimental metrics implementation

sentry-core/Cargo.toml

@@ -26,8 +26,10 @@ client = ["rand"]
 # and macros actually expand features (and extern crate) where they are used!
 debug-logs = ["dep:log"]
 test = ["client"]
+UNSTABLE_metrics = ["dep:cadence", "sentry-types/UNSTABLE_metrics"]
 
 [dependencies]
+cadence = { version = "0.29.0", optional = true }
 log = { version = "0.4.8", optional = true, features = ["std"] }
 once_cell = "1"
 rand = { version = "0.8.1", optional = true }

sentry-core/src/client.rs

@@ -11,6 +11,8 @@ use sentry_types::protocol::v7::SessionUpdate;
 use sentry_types::random_uuid;
 
 use crate::constants::SDK_INFO;
+#[cfg(feature = "UNSTABLE_metrics")]
+use crate::metrics::MetricFlusher;
 use crate::protocol::{ClientSdkInfo, Event};
 use crate::session::SessionFlusher;
 use crate::types::{Dsn, Uuid};
@@ -45,6 +47,8 @@ pub struct Client {
     options: ClientOptions,
     transport: TransportArc,
     session_flusher: RwLock<Option<SessionFlusher>>,
+    #[cfg(feature = "UNSTABLE_metrics")]
+    metrics_flusher: RwLock<Option<MetricFlusher>>,
     integrations: Vec<(TypeId, Arc<dyn Integration>)>,
     pub(crate) sdk_info: ClientSdkInfo,
 }
@@ -65,10 +69,14 @@ impl Clone for Client {
             transport.clone(),
             self.options.session_mode,
         )));
+        #[cfg(feature = "UNSTABLE_metrics")]
+        let metrics_flusher = RwLock::new(Some(MetricFlusher::new(transport.clone())));
         Client {
             options: self.options.clone(),
             transport,
             session_flusher,
+            #[cfg(feature = "UNSTABLE_metrics")]
+            metrics_flusher,
             integrations: self.integrations.clone(),
             sdk_info: self.sdk_info.clone(),
         }
@@ -136,10 +144,16 @@ impl Client {
             transport.clone(),
             options.session_mode,
         )));
+
+        #[cfg(feature = "UNSTABLE_metrics")]
+        let metrics_flusher = RwLock::new(Some(MetricFlusher::new(transport.clone())));
+
         Client {
             options,
             transport,
             session_flusher,
+            #[cfg(feature = "UNSTABLE_metrics")]
+            metrics_flusher,
             integrations,
             sdk_info,
         }
@@ -308,11 +322,22 @@ impl Client {
         }
     }
 
+    #[cfg(feature = "UNSTABLE_metrics")]
+    pub(crate) fn send_metric(&self, metric: &str) {
+        if let Some(ref flusher) = *self.metrics_flusher.read().unwrap() {
+            flusher.send_metric(metric)
+        }
+    }
+
     /// Drains all pending events without shutting down.
     pub fn flush(&self, timeout: Option<Duration>) -> bool {
         if let Some(ref flusher) = *self.session_flusher.read().unwrap() {
             flusher.flush();
         }
+        #[cfg(feature = "UNSTABLE_metrics")]
+        if let Some(ref flusher) = *self.metrics_flusher.read().unwrap() {
+            flusher.flush();
+        }
         if let Some(ref transport) = *self.transport.read().unwrap() {
             transport.flush(timeout.unwrap_or(self.options.shutdown_timeout))
         } else {
@@ -329,6 +354,8 @@ impl Client {
     /// `shutdown_timeout` in the client options.
     pub fn close(&self, timeout: Option<Duration>) -> bool {
         drop(self.session_flusher.write().unwrap().take());
+        #[cfg(feature = "UNSTABLE_metrics")]
+        drop(self.metrics_flusher.write().unwrap().take());
         let transport_opt = self.transport.write().unwrap().take();
         if let Some(transport) = transport_opt {
             sentry_debug!("client close; request transport to shut down");

sentry-core/src/lib.rs

@@ -141,10 +141,14 @@ pub use crate::transport::{Transport, TransportFactory};
 mod client;
 #[cfg(feature = "client")]
 mod hub_impl;
+#[cfg(all(feature = "client", feature = "UNSTABLE_metrics"))]
+mod metrics;
 #[cfg(feature = "client")]
 mod session;
 #[cfg(feature = "client")]
 pub use crate::client::Client;
+#[cfg(all(feature = "client", feature = "UNSTABLE_metrics"))]
+pub use crate::metrics::SentryMetricSink;
 
 // test utilities
 #[cfg(feature = "test")]