Update dogstatsd to use retry pushed to client (#617)

* feat: use dsdrs retry strategy

* feat: bump

* fix: update statsd

* ff libdatadog main

* feat: use updated statsd with faster tag parser

* fix: fmt

* fix: pass retry strategy to test

Author: astuyve

bottlecap/Cargo.lock

@@ -15,7 +15,7 @@ datadog-trace-utils = { git = "https://github.com/DataDog/libdatadog", rev = "4b
 datadog-trace-mini-agent = { git = "https://github.com/DataDog/libdatadog", rev = "4ba2f3a7b6bc298035bad8721134a4c34fdd2f1a" }
 datadog-trace-normalization = { git = "https://github.com/DataDog/libdatadog", rev = "4ba2f3a7b6bc298035bad8721134a4c34fdd2f1a" }
 datadog-trace-obfuscation = { git = "https://github.com/DataDog/libdatadog", rev = "4ba2f3a7b6bc298035bad8721134a4c34fdd2f1a" }
-dogstatsd = { git = "https://github.com/DataDog/libdatadog", rev = "89754a92d3725c10b6e6e14202efd541a9fdc5a7" }
+dogstatsd = { git = "https://github.com/DataDog/libdatadog", rev = "7982adc0c6966925f66625ca57759c0d7089a54d" }
 figment = { version = "0.10", default-features = false, features = ["yaml", "env"] }
 hyper = { version = "0.14", default-features = false, features = ["server"] }
 lazy_static = { version = "1.5", default-features = false }

bottlecap/Cargo.toml

@@ -48,7 +48,8 @@ use dogstatsd::{
     aggregator::Aggregator as MetricsAggregator,
     constants::CONTEXTS,
     datadog::{
-        DdDdUrl, DdUrl, MetricsIntakeUrlPrefix, MetricsIntakeUrlPrefixOverride, Site as MetricsSite,
+        DdDdUrl, DdUrl, MetricsIntakeUrlPrefix, MetricsIntakeUrlPrefixOverride,
+        RetryStrategy as DsdRetryStrategy, Site as MetricsSite,
     },
     dogstatsd::{DogStatsD, DogStatsDConfig},
     flusher::{Flusher as MetricsFlusher, FlusherConfig as MetricsFlusherConfig},
@@ -678,6 +679,7 @@ fn start_metrics_flusher(
         metrics_intake_url_prefix: metrics_intake_url.expect("can't parse site or override"),
         https_proxy: config.https_proxy.clone(),
         timeout: Duration::from_secs(config.flush_timeout),
+        retry_strategy: DsdRetryStrategy::Immediate(3),
     };
     MetricsFlusher::new(flusher_config)
 }

bottlecap/src/bin/bottlecap/main.rs

@@ -50,6 +50,7 @@ async fn test_enhanced_metrics() {
             .expect("can't parse metrics intake URL from site"),
         https_proxy: None,
         timeout: std::time::Duration::from_secs(5),
+        retry_strategy: dogstatsd::datadog::RetryStrategy::Immediate(1),
     };
     let mut metrics_flusher = MetricsFlusher::new(flusher_config);
     let lambda_enhanced_metrics =