chore: modify LogExporter and TraceExporter interfaces to support returning failure

opentelemetry-sdk/src/export/trace.rs

@@ -110,10 +110,6 @@ pub struct SpanData {
 #[derive(Error, Debug)]
 #[non_exhaustive]
 pub enum ShutdownError {
-    /// The exporter has already been shut down.
-    #[error("Shutdown already performed")]
-    AlreadyShutdown,
-
     /// Shutdown timed out before completing.
     #[error("Shutdown timed out after {0:?}")]
     Timeout(Duration),

opentelemetry-sdk/src/logs/error.rs

@@ -54,12 +54,6 @@ impl From<&'static str> for LogError {
     }
 }
 
-impl<T> From<PoisonError<T>> for LogError {
-    fn from(err: PoisonError<T>) -> Self {
-        LogError::ClientFailed(err.to_string())
-    }
-}
-
 /// Wrap type for string
 #[derive(Error, Debug)]
 #[error("{0}")]

opentelemetry-sdk/src/testing/logs/in_memory_exporter.rs

@@ -148,8 +148,17 @@ impl InMemoryLogExporter {
     /// ```
     ///
     pub fn get_emitted_logs(&self) -> LogResult<Vec<LogDataWithResource>> {
-        let logs_guard = self.logs.lock().map_err(LogError::from)?;
-        let resource_guard = self.resource.lock().map_err(LogError::from)?;
+        let logs_guard = self.logs.lock().map_err(|_| {
+            LogError::from(
+                "InMemoryLogExporter: log buffer mutex poisoned trying to get_emitted_logs",
+            )
+        })?;
+        let resource_guard = self.resource.lock().map_err(|_| {
+            LogError::from(
+                "InMemoryLogExporter: resource mutex poisoned trying to get_emitted_logs",
+            )
+        })?;
+
         let logs: Vec<LogDataWithResource> = logs_guard
             .iter()
             .map(|log_data| LogDataWithResource {
@@ -173,8 +182,12 @@ impl InMemoryLogExporter {
     /// ```
     ///
     pub fn reset(&self) -> Result<(), LogError> {
-        self.logs.lock().map(|mut logs_guard| logs_guard.clear())?;
-
+        self.logs
+            .lock()
+            .map_err(|_| {
+                LogError::from("InMemoryLogExporter: log buffer mutex poisoned trying to reset()")
+            })
+            .map(|mut logs_guard| logs_guard.clear())?;
         Ok(())
     }
 }