fix: Adds shutdown function for spans

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

@@ -61,7 +61,7 @@
         Ok(())
     }
 
-    fn shutdown(&mut self) -> OTelSdkResult {
+    fn shutdown(&self) -> OTelSdkResult {
         let mut client_guard = self.client.lock().map_err(|e| {
             OTelSdkError::InternalFailure(format!("Failed to acquire client lock: {}", e))
         })?;

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

@@ -89,11 +89,17 @@
         Ok(())
     }
 
-    fn shutdown(&mut self) -> OTelSdkResult {
-        match self.inner.take() {
-            Some(_) => Ok(()), // Successfully took `inner`, indicating a successful shutdown.
-            None => Err(OTelSdkError::AlreadyShutdown), // `inner` was already `None`, meaning it's already shut down.
-        }
+    fn shutdown(&self) -> OTelSdkResult {
+        // ToDo: as part of https://github.com/open-telemetry/opentelemetry-rust/pull/2812
+        // self is no longer mutable due to trait change for span exporter
+        // the shutdown for gRPC needs to implemented and tracked in
+        // https://github.com/open-telemetry/opentelemetry-rust/issues/2777
+        //
+        // match self.inner.take() {
+        //     Some(_) => Ok(()), // Successfully took `inner`, indicating a successful shutdown.
+        //     None => Err(OTelSdkError::AlreadyShutdown), // `inner` was already `None`, meaning it's already shut down.
+        // }
+        Ok(())
     }
 
     fn set_resource(&mut self, resource: &opentelemetry_sdk::Resource) {

opentelemetry-otlp/src/span.rs

@@ -159,4 +159,12 @@
             SupportedTransportClient::Http(client) => client.set_resource(resource),
         }
     }
+    fn shutdown(&self) -> OTelSdkResult {
+        match &self.client {
+            #[cfg(feature = "grpc-tonic")]
+            SupportedTransportClient::Tonic(client) => client.shutdown(),
+            #[cfg(any(feature = "http-proto", feature = "http-json"))]
+            SupportedTransportClient::Http(client) => client.shutdown(),
+        }
+    }
 }

opentelemetry-sdk/CHANGELOG.md

@@ -2,6 +2,10 @@
 
 ## vNext
 
+- **Breaking**: [#2779](https://github.com/open-telemetry/opentelemetry-rust/issues/2779) handle
+shutdown for span exporter for `http` exporters, shutdown for `grpc` would be added
+separately.
+
 ## 0.29.0
 
 Released 2025-Mar-21

opentelemetry-sdk/src/testing/trace/span_exporters.rs

@@ -49,7 +49,7 @@ impl SpanExporter for TokioSpanExporter {
         })
     }
 
-    fn shutdown(&mut self) -> OTelSdkResult {
+    fn shutdown(&self) -> OTelSdkResult {
         self.tx_shutdown.send(()).map_err(|_| {
             OTelSdkError::InternalFailure("Failed to send shutdown signal".to_string())
         })

opentelemetry-sdk/src/trace/export.rs

@@ -43,7 +43,7 @@ pub trait SpanExporter: Send + Sync + Debug {
     /// flush the data and the destination is unavailable). SDK authors
     /// can decide if they want to make the shutdown timeout
     /// configurable.
-    fn shutdown(&mut self) -> OTelSdkResult {
+    fn shutdown(&self) -> OTelSdkResult {
         Ok(())
     }
 

opentelemetry-sdk/src/trace/in_memory_exporter.rs

@@ -140,7 +140,7 @@ impl SpanExporter for InMemorySpanExporter {
         result
     }
 
-    fn shutdown(&mut self) -> OTelSdkResult {
+    fn shutdown(&self) -> OTelSdkResult {
         self.reset();
         Ok(())
     }

opentelemetry-sdk/src/trace/span_processor.rs

@@ -155,7 +155,7 @@
     }
 
     fn shutdown(&self) -> OTelSdkResult {
-        if let Ok(mut exporter) = self.exporter.lock() {
+        if let Ok(exporter) = self.exporter.lock() {
             exporter.shutdown()
         } else {
             Err(OTelSdkError::InternalFailure(
@@ -1089,7 +1089,7 @@
             Ok(())
         }
 
-        fn shutdown(&mut self) -> OTelSdkResult {
+        fn shutdown(&self) -> OTelSdkResult {
             Ok(())
         }
         fn set_resource(&mut self, resource: &Resource) {

opentelemetry-stdout/src/trace/exporter.rs

@@ -59,7 +59,7 @@
         }
     }
 
-    fn shutdown(&mut self) -> OTelSdkResult {
+    fn shutdown(&self) -> OTelSdkResult {
         self.is_shutdown.store(true, Ordering::SeqCst);
         Ok(())
     }