remove sample rate

Author: lcian

rust_snuba/src/config.rs

@@ -108,7 +108,6 @@ pub struct EnvConfig {
     pub lower_retention_days: u16,
     pub valid_retention_days: HashSet<u16>,
     pub record_cogs: bool,
-    pub ddm_metrics_sample_rate: f64,
     pub project_stacktrace_blacklist: Vec<u64>,
 }
 
@@ -122,7 +121,6 @@ impl Default for EnvConfig {
             lower_retention_days: 30,
             valid_retention_days: [30, 60, 90].iter().cloned().collect(),
             record_cogs: false,
-            ddm_metrics_sample_rate: 0.0,
             project_stacktrace_blacklist: Vec::new(),
         }
     }

rust_snuba/src/consumer.rs

@@ -179,13 +179,7 @@ pub fn consumer_v2_impl(
         set_global_tag("storage".to_owned(), storage_name);
         set_global_tag("consumer_group".to_owned(), consumer_group.to_owned());
 
-        metrics::init(StatsDBackend::new(
-            &host,
-            port,
-            "snuba.consumer",
-            env_config.ddm_metrics_sample_rate,
-        ))
-        .unwrap();
+        metrics::init(StatsDBackend::new(&host, port, "snuba.consumer")).unwrap();
     }
 
     if !use_rust_processor {
@@ -414,13 +408,7 @@ pub fn consumer_impl(
         set_global_tag("storage".to_owned(), storage_name);
         set_global_tag("consumer_group".to_owned(), consumer_group.to_owned());
 
-        metrics::init(StatsDBackend::new(
-            &host,
-            port,
-            "snuba.consumer",
-            env_config.ddm_metrics_sample_rate,
-        ))
-        .unwrap();
+        metrics::init(StatsDBackend::new(&host, port, "snuba.consumer")).unwrap();
     }
 
     if !use_rust_processor {

rust_snuba/src/metrics/statsd.rs

@@ -28,7 +28,7 @@ impl MetricSink for Wrapper {
 }
 
 impl StatsDBackend {
-    pub fn new(host: &str, port: u16, prefix: &str, _ddm_metrics_sample_rate: f64) -> Self {
+    pub fn new(host: &str, port: u16, prefix: &str) -> Self {
         let upstream_addr = format!("{}:{}", host, port);
         let aggregator_sink = StatsdProxyMetricSink::new(move || {
             let upstream = Upstream::new(upstream_addr.clone()).unwrap();