Skip to content

Commit

Permalink
Fix stress test for Logs to use OTelSdkResult (#2627)
Browse files Browse the repository at this point in the history
  • Loading branch information
cijothomas authored Feb 7, 2025
1 parent 3a8cedd commit c2a2b8d
Showing 1 changed file with 5 additions and 4 deletions.
9 changes: 5 additions & 4 deletions stress/src/logs.rs
Original file line number Diff line number Diff line change
Expand Up @@ -11,8 +11,9 @@

use opentelemetry::InstrumentationScope;
use opentelemetry_appender_tracing::layer;
use opentelemetry_sdk::error::OTelSdkResult;
use opentelemetry_sdk::logs::{LogBatch, LogExporter};
use opentelemetry_sdk::logs::{LogProcessor, LogResult, SdkLogRecord, SdkLoggerProvider};
use opentelemetry_sdk::logs::{LogProcessor, SdkLogRecord, SdkLoggerProvider};

use tracing::error;
use tracing_subscriber::prelude::*;
Expand All @@ -26,7 +27,7 @@ impl LogExporter for MockLogExporter {
fn export(
&self,
_batch: LogBatch<'_>,
) -> impl std::future::Future<Output = LogResult<()>> + Send {
) -> impl std::future::Future<Output = OTelSdkResult> + Send {
async { Ok(()) }
}
}
Expand All @@ -46,11 +47,11 @@ impl LogProcessor for MockLogProcessor {
let _ = futures_executor::block_on(self.exporter.export(LogBatch::new(log_tuple)));
}

fn force_flush(&self) -> LogResult<()> {
fn force_flush(&self) -> OTelSdkResult {
Ok(())
}

fn shutdown(&self) -> LogResult<()> {
fn shutdown(&self) -> OTelSdkResult {
Ok(())
}
}
Expand Down

0 comments on commit c2a2b8d

Please sign in to comment.