rename to InternalFailure

Author: cijothomas

examples/metrics-basic/src/main.rs

@@ -147,7 +147,7 @@ async fn main() {
         Ok(_) => println!("MeterProvider shutdown successfully"),
         Err(e) => {
             match e {
-                opentelemetry_sdk::error::ShutdownError::Failed(e) => {
+                opentelemetry_sdk::error::ShutdownError::InternalFailure(e) => {
                     // This indicates some failure during shutdown.
                     // Not much to do here, but log the error.
                     // So users at least know something went wrong,

opentelemetry-otlp/src/exporter/http/metrics.rs

@@ -48,7 +48,7 @@ impl MetricsClient for OtlpHttpClient {
         self.client
             .lock()
             .map_err(|e| {
-                ShutdownError::Failed(format!("Internal Error. Failed to acquire lock: {}", e))
+                ShutdownError::InternalFailure(format!("Internal Error. Failed to acquire lock: {}", e))
             })?
             .take();
 

opentelemetry-otlp/src/exporter/tonic/metrics.rs

@@ -94,7 +94,7 @@ impl MetricsClient for TonicMetricsClient {
         self.inner
             .lock()
             .map_err(|e| {
-                ShutdownError::Failed(format!("Internal Error. Failed to acquire lock: {}", e))
+                ShutdownError::InternalFailure(format!("Internal Error. Failed to acquire lock: {}", e))
             })?
             .take();
 

opentelemetry-sdk/src/error.rs

@@ -24,7 +24,7 @@ pub enum ShutdownError {
     /// Shutdown failed with an error.
     /// This error is returned when the shutdown process failed with an error.
     #[error("Shutdown failed: {0}")]
-    Failed(String),
+    InternalFailure(String),
 }
 
 /// A specialized `Result` type for Shutdown operations.

opentelemetry-sdk/src/metrics/manual_reader.rs

@@ -112,7 +112,7 @@ impl MetricReader for ManualReader {
     /// Closes any connections and frees any resources used by the reader.
     fn shutdown(&self) -> ShutdownResult {
         let mut inner = self.inner.lock().map_err(|e| {
-            ShutdownError::Failed(format!("Internal Error. Failed to acquire lock: {}", e))
+            ShutdownError::InternalFailure(format!("Internal Error. Failed to acquire lock: {}", e))
         })?;
 
         // Any future call to collect will now return an error.

opentelemetry-sdk/src/metrics/periodic_reader.rs

@@ -405,22 +405,22 @@ impl PeriodicReaderInner {
         let (response_tx, response_rx) = mpsc::channel();
         self.message_sender
             .send(Message::Shutdown(response_tx))
-            .map_err(|e| ShutdownError::Failed(e.to_string()))?;
+            .map_err(|e| ShutdownError::InternalFailure(e.to_string()))?;
 
         // TODO: Make this timeout configurable.
         match response_rx.recv_timeout(Duration::from_secs(5)) {
             Ok(response) => {
                 if response {
                     Ok(())
                 } else {
-                    Err(ShutdownError::Failed("Failed to shutdown".into()))
+                    Err(ShutdownError::InternalFailure("Failed to shutdown".into()))
                 }
             }
             Err(mpsc::RecvTimeoutError::Timeout) => {
                 Err(ShutdownError::Timeout(Duration::from_secs(5)))
             }
             Err(mpsc::RecvTimeoutError::Disconnected) => {
-                Err(ShutdownError::Failed("Failed to shutdown".into()))
+                Err(ShutdownError::InternalFailure("Failed to shutdown".into()))
             }
         }
     }

opentelemetry-sdk/src/metrics/pipeline.rs

@@ -661,7 +661,7 @@ impl Pipelines {
         if errs.is_empty() {
             Ok(())
         } else {
-            Err(crate::error::ShutdownError::Failed(format!("{errs:?}")))
+            Err(crate::error::ShutdownError::InternalFailure(format!("{errs:?}")))
         }
     }
 }

opentelemetry-sdk/src/testing/metrics/metric_reader.rs

@@ -48,7 +48,7 @@ impl MetricReader for TestMetricReader {
             let mut is_shutdown = self.is_shutdown.lock().unwrap();
             *is_shutdown = true;
         }
-        result.map_err(|e| crate::error::ShutdownError::Failed(e.to_string()))
+        result.map_err(|e| crate::error::ShutdownError::InternalFailure(e.to_string()))
     }
 
     fn temporality(&self, _kind: InstrumentKind) -> Temporality {