1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
|
// Copyright The OpenTelemetry Authors
// SPDX-License-Identifier: Apache-2.0
#include <benchmark/benchmark.h>
#include <stddef.h>
#include <algorithm>
#include <chrono>
#include <functional>
#include <random>
#include <thread>
#include <utility>
#include <vector>
#include "common.h"
#include "opentelemetry/context/context.h"
#include "opentelemetry/metrics/meter.h"
#include "opentelemetry/metrics/sync_instruments.h"
#include "opentelemetry/nostd/function_ref.h"
#include "opentelemetry/nostd/shared_ptr.h"
#include "opentelemetry/nostd/variant.h"
#include "opentelemetry/sdk/metrics/data/metric_data.h"
#include "opentelemetry/sdk/metrics/data/point_data.h"
#include "opentelemetry/sdk/metrics/export/metric_producer.h"
#include "opentelemetry/sdk/metrics/meter_provider.h"
#include "opentelemetry/sdk/metrics/metric_reader.h"
#include "opentelemetry/sdk/metrics/push_metric_exporter.h"
using namespace opentelemetry;
using namespace opentelemetry::sdk::instrumentationscope;
using namespace opentelemetry::sdk::metrics;
namespace
{
void BM_HistogramAggregation(benchmark::State &state)
{
MeterProvider mp;
auto m = mp.GetMeter("meter1", "version1", "schema1");
std::unique_ptr<MockMetricExporter> exporter(new MockMetricExporter());
std::shared_ptr<MetricReader> reader{new MockMetricReader(std::move(exporter))};
mp.AddMetricReader(reader);
auto h = m->CreateDoubleHistogram("histogram1", "histogram1_description", "histogram1_unit");
std::default_random_engine generator;
std::uniform_int_distribution<int> distribution(0, 1000000);
// Generate 100000 measurements
constexpr size_t TOTAL_MEASUREMENTS = 100000;
double measurements[TOTAL_MEASUREMENTS];
for (size_t i = 0; i < TOTAL_MEASUREMENTS; i++)
{
measurements[i] = static_cast<double>(distribution(generator));
}
std::vector<HistogramPointData> actuals;
std::vector<std::thread> collectionThreads;
std::function<void()> collectMetrics = [&reader, &actuals]() {
reader->Collect([&](ResourceMetrics &rm) {
for (const ScopeMetrics &smd : rm.scope_metric_data_)
{
for (const MetricData &md : smd.metric_data_)
{
for (const PointDataAttributes &dp : md.point_data_attr_)
{
actuals.push_back(opentelemetry::nostd::get<HistogramPointData>(dp.point_data));
}
}
}
return true;
});
};
while (state.KeepRunning())
{
for (size_t i = 0; i < TOTAL_MEASUREMENTS; i++)
{
h->Record(measurements[i], {});
if (i % 1000 == 0 || i == TOTAL_MEASUREMENTS - 1)
{
collectMetrics();
}
if (i == 100)
{
std::this_thread::sleep_for(std::chrono::nanoseconds(4));
}
}
}
}
BENCHMARK(BM_HistogramAggregation);
} // namespace
BENCHMARK_MAIN();
|
