// Copyright The OpenTelemetry Authors // SPDX-License-Identifier: Apache-2.0 #include #include #include #include #include #include "common.h" #include "opentelemetry/common/macros.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/string_view.h" #include "opentelemetry/nostd/variant.h" #include "opentelemetry/sdk/instrumentationscope/instrumentation_scope.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/instruments.h" #include "opentelemetry/sdk/metrics/meter_provider.h" #include "opentelemetry/sdk/metrics/metric_reader.h" #include "opentelemetry/sdk/metrics/push_metric_exporter.h" #include "opentelemetry/sdk/metrics/view/instrument_selector.h" #include "opentelemetry/sdk/metrics/view/meter_selector.h" #include "opentelemetry/sdk/metrics/view/view.h" #if OPENTELEMETRY_HAVE_WORKING_REGEX using namespace opentelemetry; using namespace opentelemetry::sdk::instrumentationscope; using namespace opentelemetry::sdk::metrics; TEST(HistogramInstrumentToHistogramAggregation, Double) { MeterProvider mp; auto m = mp.GetMeter("meter1", "version1", "schema1"); std::unique_ptr exporter(new MockMetricExporter()); std::shared_ptr reader{new MockMetricReader(std::move(exporter))}; mp.AddMetricReader(reader); auto h = m->CreateDoubleHistogram("histogram1", "histogram1_description", "histogram1_unit"); h->Record(5, {}); h->Record(10, {}); h->Record(15, {}); h->Record(20, {}); h->Record(25, {}); h->Record(30, {}); h->Record(35, {}); h->Record(40, {}); h->Record(45, {}); h->Record(50, {}); h->Record(1e6, {}); std::vector 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(dp.point_data)); } } } return true; }); ASSERT_EQ(1, actuals.size()); const auto &actual = actuals.at(0); ASSERT_EQ(1000275.0, opentelemetry::nostd::get(actual.sum_)); ASSERT_EQ(11, actual.count_); } TEST(CounterToHistogram, Double) { MeterProvider mp; auto m = mp.GetMeter("meter1", "version1", "schema1"); std::unique_ptr exporter(new MockMetricExporter()); std::shared_ptr reader{new MockMetricReader(std::move(exporter))}; mp.AddMetricReader(reader); std::unique_ptr view{ new View("view1", "view1_description", "unit", AggregationType::kHistogram)}; std::unique_ptr instrument_selector{ new InstrumentSelector(InstrumentType::kCounter, "counter1", "unit")}; std::unique_ptr meter_selector{new MeterSelector("meter1", "version1", "schema1")}; mp.AddView(std::move(instrument_selector), std::move(meter_selector), std::move(view)); auto h = m->CreateDoubleCounter("counter1", "counter1_description", "unit"); h->Add(5, {}); h->Add(10, {}); h->Add(15, {}); h->Add(20, {}); h->Add(25, {}); h->Add(30, {}); h->Add(35, {}); h->Add(40, {}); h->Add(45, {}); h->Add(50, {}); h->Add(1e6, {}); std::vector 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(dp.point_data)); } } } return true; }); ASSERT_EQ(1, actuals.size()); const auto &actual = actuals.at(0); ASSERT_EQ(1000275.0, opentelemetry::nostd::get(actual.sum_)); ASSERT_EQ(11, actual.count_); } #endif