Revert "feat: implement retries (#103)"

This reverts commit 68348f9.

Author: frigus02

Cargo.toml

@@ -47,7 +47,6 @@ reqwest-client-rustls = ["opentelemetry-http/reqwest", "reqwest/rustls-tls"]
 
 [dependencies]
 async-trait = "0.1"
-backon = { version = "1.5", default-features = false, features = ["futures-timer-sleep"] }
 bytes = "1"
 chrono = "0.4"
 flate2 = "1"

src/lib.rs

@@ -372,13 +372,7 @@ use opentelemetry_sdk::ExportError;
 use opentelemetry_sdk::Resource;
 #[cfg(feature = "live-metrics")]
 pub use quick_pulse::LiveMetricsSpanProcessor;
-use std::{
-    convert::TryInto,
-    error::Error as StdError,
-    fmt::Debug,
-    sync::{Arc, Mutex},
-    time::Duration,
-};
+use std::{convert::TryInto, error::Error as StdError, fmt::Debug, sync::Arc};
 #[cfg(feature = "live-metrics")]
 use uploader_quick_pulse::PostOrPing;
 
@@ -392,7 +386,6 @@ pub struct Exporter<C> {
     #[cfg(feature = "live-metrics")]
     live_ping_endpoint: http::Uri,
     instrumentation_key: String,
-    retry_notify: Option<Arc<Mutex<dyn FnMut(&Error, Duration) + Send + 'static>>>,
     #[cfg(feature = "trace")]
     sample_rate: f64,
     #[cfg(any(feature = "trace", feature = "logs"))]
@@ -443,7 +436,6 @@ impl<C> Exporter<C> {
                 &instrumentation_key,
             ),
             instrumentation_key,
-            retry_notify: None,
             #[cfg(feature = "trace")]
             sample_rate: 100.0,
             #[cfg(any(feature = "trace", feature = "logs"))]
@@ -483,7 +475,6 @@ impl<C> Exporter<C> {
                 &connection_string.instrumentation_key,
             ),
             instrumentation_key: connection_string.instrumentation_key,
-            retry_notify: None,
             #[cfg(feature = "trace")]
             sample_rate: 100.0,
             #[cfg(any(feature = "trace", feature = "logs"))]
@@ -493,16 +484,6 @@ impl<C> Exporter<C> {
         })
     }
 
-    /// Set a retry notification function that is called when a request to upload telemetry to
-    /// Application Insights failed and will be retried.
-    pub fn with_retry_notify<N>(mut self, retry_notify: N) -> Self
-    where
-        N: FnMut(&Error, Duration) + Send + 'static,
-    {
-        self.retry_notify = Some(Arc::new(Mutex::new(retry_notify)));
-        self
-    }
-
     /// Set endpoint used to ingest telemetry. This should consist of scheme and authrity. The
     /// exporter will call `/v2/track` on the specified endpoint.
     ///

src/logs.rs

@@ -83,14 +83,9 @@ where
             .collect();
 
         async move {
-            crate::uploader::send(
-                client.as_ref(),
-                endpoint.as_ref(),
-                envelopes,
-                self.retry_notify.clone(),
-            )
-            .await
-            .map_err(Into::into)
+            crate::uploader::send(client.as_ref(), endpoint.as_ref(), envelopes)
+                .await
+                .map_err(Into::into)
         }
     }
 

src/metrics.rs

@@ -70,14 +70,9 @@ where
         }
 
         async move {
-            crate::uploader::send(
-                client.as_ref(),
-                endpoint.as_ref(),
-                envelopes,
-                self.retry_notify.clone(),
-            )
-            .await
-            .map_err(Into::into)
+            crate::uploader::send(client.as_ref(), endpoint.as_ref(), envelopes)
+                .await
+                .map_err(Into::into)
         }
     }
 

src/trace.rs

@@ -145,14 +145,9 @@ where
             .flat_map(|span| self.create_envelopes_for_span(span, &self.resource))
             .collect();
 
-        crate::uploader::send(
-            client.as_ref(),
-            endpoint.as_ref(),
-            envelopes,
-            self.retry_notify.clone(),
-        )
-        .await
-        .map_err(Into::into)
+        crate::uploader::send(client.as_ref(), endpoint.as_ref(), envelopes)
+            .await
+            .map_err(Into::into)
     }
 
     fn set_resource(&mut self, resource: &Resource) {