Skip to content

Commit f2c7666

Browse files
committed
fix: Remove mut ref requirement for shutdown LogExporter
1 parent b33f0cc commit f2c7666

5 files changed

+5
-5
lines changed

opentelemetry-sdk/src/logs/export.rs

+1-1
Original file line numberDiff line numberDiff line change
@@ -136,7 +136,7 @@ pub trait LogExporter: Send + Sync + Debug {
136136
) -> impl std::future::Future<Output = OTelSdkResult> + Send;
137137

138138
/// Shuts down the exporter.
139-
fn shutdown(&mut self) -> OTelSdkResult {
139+
fn shutdown(&self) -> OTelSdkResult {
140140
Ok(())
141141
}
142142
#[cfg(feature = "spec_unstable_logs_enabled")]

opentelemetry-sdk/src/logs/in_memory_exporter.rs

+1-1
Original file line numberDiff line numberDiff line change
@@ -211,7 +211,7 @@ impl LogExporter for InMemoryLogExporter {
211211
Ok(())
212212
}
213213

214-
fn shutdown(&mut self) -> OTelSdkResult {
214+
fn shutdown(&self) -> OTelSdkResult {
215215
self.shutdown_called
216216
.store(true, std::sync::atomic::Ordering::Relaxed);
217217
if self.should_reset_on_shutdown {

opentelemetry-sdk/src/logs/log_processor.rs

+1-1
Original file line numberDiff line numberDiff line change
@@ -92,7 +92,7 @@ pub(crate) mod tests {
9292
Ok(())
9393
}
9494

95-
fn shutdown(&mut self) -> OTelSdkResult {
95+
fn shutdown(&self) -> OTelSdkResult {
9696
Ok(())
9797
}
9898

opentelemetry-sdk/src/logs/log_processor_with_async_runtime.rs

+1-1
Original file line numberDiff line numberDiff line change
@@ -321,7 +321,7 @@ mod tests {
321321
Ok(())
322322
}
323323

324-
fn shutdown(&mut self) -> OTelSdkResult {
324+
fn shutdown(&self) -> OTelSdkResult {
325325
Ok(())
326326
}
327327

opentelemetry-sdk/src/logs/simple_log_processor.rs

+1-1
Original file line numberDiff line numberDiff line change
@@ -117,7 +117,7 @@ impl<T: LogExporter> LogProcessor for SimpleLogProcessor<T> {
117117
fn shutdown(&self) -> OTelSdkResult {
118118
self.is_shutdown
119119
.store(true, std::sync::atomic::Ordering::Relaxed);
120-
if let Ok(mut exporter) = self.exporter.lock() {
120+
if let Ok(exporter) = self.exporter.lock() {
121121
exporter.shutdown()
122122
} else {
123123
Err(OTelSdkError::InternalFailure(

0 commit comments

Comments
 (0)