diff --git a/opentelemetry-prometheus/examples/hyper.rs b/opentelemetry-prometheus/examples/hyper.rs index a2bd593ba9..ab3a083307 100644 --- a/opentelemetry-prometheus/examples/hyper.rs +++ b/opentelemetry-prometheus/examples/hyper.rs @@ -15,7 +15,7 @@ use opentelemetry_sdk::metrics::SdkMeterProvider; use prometheus::{Encoder, Registry, TextEncoder}; use std::net::SocketAddr; use std::sync::Arc; -use std::time::SystemTime; +use opentelemetry::time::now; use tokio::net::TcpListener; static HANDLER_ALL: Lazy<[KeyValue; 1]> = Lazy::new(|| [KeyValue::new("handler", "all")]); @@ -25,7 +25,7 @@ async fn serve_req( state: Arc, ) -> Result>, hyper::Error> { println!("Receiving request at path {}", req.uri()); - let request_start = SystemTime::now(); + let request_start = now(); state.http_counter.add(1, HANDLER_ALL.as_ref()); diff --git a/opentelemetry-sdk/benches/batch_span_processor.rs b/opentelemetry-sdk/benches/batch_span_processor.rs index 7cd9ff5c1c..3457755b46 100644 --- a/opentelemetry-sdk/benches/batch_span_processor.rs +++ b/opentelemetry-sdk/benches/batch_span_processor.rs @@ -1,4 +1,5 @@ use criterion::{criterion_group, criterion_main, BenchmarkId, Criterion}; +use opentelemetry::time::now; use opentelemetry::trace::{ SpanContext, SpanId, SpanKind, Status, TraceFlags, TraceId, TraceState, }; @@ -8,7 +9,6 @@ use opentelemetry_sdk::trace::{ BatchConfigBuilder, BatchSpanProcessor, SpanEvents, SpanLinks, SpanProcessor, }; use std::sync::Arc; -use std::time::SystemTime; use tokio::runtime::Runtime; fn get_span_data() -> Vec { @@ -24,8 +24,8 @@ fn get_span_data() -> Vec { parent_span_id: SpanId::from_u64(12), span_kind: SpanKind::Client, name: Default::default(), - start_time: SystemTime::now(), - end_time: SystemTime::now(), + start_time: now(), + end_time: now(), attributes: Vec::new(), dropped_attributes_count: 0, events: SpanEvents::default(), diff --git a/opentelemetry-sdk/benches/log.rs b/opentelemetry-sdk/benches/log.rs index 99083fbdae..b96fa99456 100644 --- a/opentelemetry-sdk/benches/log.rs +++ b/opentelemetry-sdk/benches/log.rs @@ -15,8 +15,8 @@ RAM: 64.0 GB | Logging_Comparable_To_Appender | 87 ns | */ +use opentelemetry::time::now; use std::collections::HashMap; -use std::time::SystemTime; use criterion::{criterion_group, criterion_main, Criterion}; @@ -111,7 +111,7 @@ fn logging_comparable_to_appender(c: &mut Criterion) { c.bench_function("Logging_Comparable_To_Appender", |b| { b.iter(|| { let mut log_record = logger.create_log_record(); - let now = SystemTime::now(); + let now = now(); log_record.set_observed_timestamp(now); log_record.set_target("my-target".to_string()); log_record.set_event_name("CheckoutFailed"); @@ -253,7 +253,7 @@ fn criterion_benchmark(c: &mut Criterion) { logger.emit(log_record); }); - let now = SystemTime::now(); + let now = now(); log_benchmark_group(c, "full-log", |logger| { let mut log_record = logger.create_log_record(); log_record.set_body("full log".into()); diff --git a/opentelemetry-sdk/benches/log_exporter.rs b/opentelemetry-sdk/benches/log_exporter.rs index 523725fc7e..97b1647111 100644 --- a/opentelemetry-sdk/benches/log_exporter.rs +++ b/opentelemetry-sdk/benches/log_exporter.rs @@ -10,8 +10,8 @@ | LogExporterWithoutFuture | 92 ns | */ +use opentelemetry::time::now; use std::sync::Mutex; -use std::time::SystemTime; use async_trait::async_trait; use criterion::{criterion_group, criterion_main, Criterion}; @@ -126,7 +126,7 @@ fn exporter_with_future(c: &mut Criterion) { c.bench_function("LogExporterWithFuture", |b| { b.iter(|| { let mut log_record = logger.create_log_record(); - let now = SystemTime::now(); + let now = now(); log_record.set_observed_timestamp(now); log_record.set_target("my-target".to_string()); log_record.set_event_name("CheckoutFailed"); @@ -152,7 +152,7 @@ fn exporter_without_future(c: &mut Criterion) { c.bench_function("LogExporterWithoutFuture", |b| { b.iter(|| { let mut log_record = logger.create_log_record(); - let now = SystemTime::now(); + let now = now(); log_record.set_observed_timestamp(now); log_record.set_target("my-target".to_string()); log_record.set_event_name("CheckoutFailed"); diff --git a/opentelemetry-sdk/benches/log_processor.rs b/opentelemetry-sdk/benches/log_processor.rs index 87cd242d0d..8eefc0bd37 100644 --- a/opentelemetry-sdk/benches/log_processor.rs +++ b/opentelemetry-sdk/benches/log_processor.rs @@ -11,10 +11,10 @@ | log_clone_and_send_to_channel_processor | 403 ns | */ +use opentelemetry::time::now; use std::{ sync::{Arc, Mutex}, thread::sleep, - time::SystemTime, }; use criterion::{criterion_group, criterion_main, Criterion}; @@ -29,7 +29,7 @@ use opentelemetry_sdk::logs::{LogProcessor, LogRecord, LogResult, Logger, Logger fn create_log_record(logger: &Logger) -> LogRecord { let mut log_record = logger.create_log_record(); - let now = SystemTime::now(); + let now = now(); log_record.set_observed_timestamp(now); log_record.set_target("my-target".to_string()); log_record.set_event_name("CheckoutFailed");