Merge branch 'main' into cijothomas/future-exporter

Author: cijothomas

opentelemetry-sdk/Cargo.toml

@@ -68,6 +68,10 @@ harness = false
 name = "metric_gauge"
 harness = false
 
+[[bench]]
+name = "metric_histogram"
+harness = false
+
 [[bench]]
 name = "attribute_set"
 harness = false

opentelemetry-sdk/benches/metric_histogram.rs

@@ -0,0 +1,94 @@
+/*
+    The benchmark results:
+    criterion = "0.5.1"
+    OS: Ubuntu 22.04.4 LTS (5.15.153.1-microsoft-standard-WSL2)
+    Hardware: Intel(R) Xeon(R) Platinum 8370C CPU @ 2.80GHz, 16vCPUs,
+    RAM: 64.0 GB
+    | Test                           | Average time|
+    |--------------------------------|-------------|
+    | Histogram_Record               | 509.21 ns   |
+
+*/
+
+use criterion::{criterion_group, criterion_main, Criterion};
+use opentelemetry::{
+    metrics::{Histogram, MeterProvider as _},
+    KeyValue,
+};
+use opentelemetry_sdk::metrics::{ManualReader, SdkMeterProvider};
+use pprof::criterion::{Output, PProfProfiler};
+use rand::{
+    rngs::{self},
+    Rng, SeedableRng,
+};
+use std::cell::RefCell;
+
+thread_local! {
+    /// Store random number generator for each thread
+    static CURRENT_RNG: RefCell<rngs::SmallRng> = RefCell::new(rngs::SmallRng::from_entropy());
+}
+
+static ATTRIBUTE_VALUES: [&str; 10] = [
+    "value1", "value2", "value3", "value4", "value5", "value6", "value7", "value8", "value9",
+    "value10",
+];
+
+// Run this benchmark with:
+// cargo bench --bench metric_histogram
+fn create_histogram(name: &'static str) -> Histogram<u64> {
+    let meter_provider: SdkMeterProvider = SdkMeterProvider::builder()
+        .with_reader(ManualReader::builder().build())
+        .build();
+    let meter = meter_provider.meter("benchmarks");
+
+    meter.u64_histogram(name).init()
+}
+
+fn criterion_benchmark(c: &mut Criterion) {
+    histogram_record(c);
+}
+
+fn histogram_record(c: &mut Criterion) {
+    let histogram = create_histogram("Histogram_Record");
+    c.bench_function("Histogram_Record", |b| {
+        b.iter(|| {
+            // 4*4*10*10 = 1600 time series.
+            let rands = CURRENT_RNG.with(|rng| {
+                let mut rng = rng.borrow_mut();
+                [
+                    rng.gen_range(0..4),
+                    rng.gen_range(0..4),
+                    rng.gen_range(0..10),
+                    rng.gen_range(0..10),
+                ]
+            });
+            let index_first_attribute = rands[0];
+            let index_second_attribute = rands[1];
+            let index_third_attribute = rands[2];
+            let index_fourth_attribute = rands[3];
+            histogram.record(
+                1,
+                &[
+                    KeyValue::new("attribute1", ATTRIBUTE_VALUES[index_first_attribute]),
+                    KeyValue::new("attribute2", ATTRIBUTE_VALUES[index_second_attribute]),
+                    KeyValue::new("attribute3", ATTRIBUTE_VALUES[index_third_attribute]),
+                    KeyValue::new("attribute4", ATTRIBUTE_VALUES[index_fourth_attribute]),
+                ],
+            );
+        });
+    });
+}
+
+#[cfg(not(target_os = "windows"))]
+criterion_group! {
+    name = benches;
+    config = Criterion::default().with_profiler(PProfProfiler::new(100, Output::Flamegraph(None)));
+    targets = criterion_benchmark
+}
+#[cfg(target_os = "windows")]
+criterion_group! {
+    name = benches;
+    config = Criterion::default();
+    targets = criterion_benchmark
+}
+criterion_main!(benches);

stress/src/metrics_histogram.rs

@@ -40,10 +40,10 @@ thread_local! {
 }
 
 fn main() {
-    throughput::test_throughput(test_counter);
+    throughput::test_throughput(test_histogram);
 }
 
-fn test_counter() {
+fn test_histogram() {
     let len = ATTRIBUTE_VALUES.len();
     let rands = CURRENT_RNG.with(|rng| {
         let mut rng = rng.borrow_mut();