forked from open-telemetry/opentelemetry-cpp
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Fixes open-telemetry#1405
- Loading branch information
Showing
6 changed files
with
246 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
56 changes: 56 additions & 0 deletions
56
exporters/memory/include/opentelemetry/exporters/memory/in_memory_metric_exporter.h
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,56 @@ | ||
| // Copyright The OpenTelemetry Authors | ||
| // SPDX-License-Identifier: Apache-2.0 | ||
|
|
||
| #pragma once | ||
|
|
||
| #include <atomic> | ||
| #include <vector> | ||
|
|
||
| #include "opentelemetry/sdk/metrics/export/metric_producer.h" | ||
| #include "opentelemetry/sdk/metrics/instruments.h" | ||
| #include "opentelemetry/sdk/metrics/push_metric_exporter.h" | ||
| #include "opentelemetry/version.h" | ||
|
|
||
| OPENTELEMETRY_BEGIN_NAMESPACE | ||
| namespace exporter | ||
| { | ||
| namespace memory | ||
| { | ||
|
|
||
| /// A Push Metric Exporter which accumulates metrics data in memory and allows it to be inspected. | ||
| /// It is not thread-safe. | ||
| class InMemoryMetricExporter final : public sdk::metrics::PushMetricExporter | ||
| { | ||
| using AggregationTemporalityMap = | ||
| std::map<sdk::metrics::InstrumentType, sdk::metrics::AggregationTemporality>; | ||
|
|
||
| public: | ||
| /// @param temporality Output temporality as a function of instrument kind. | ||
| InMemoryMetricExporter(const sdk::metrics::AggregationTemporalitySelector &temporality) | ||
| : temporality_(temporality) | ||
| {} | ||
|
|
||
| InMemoryMetricExporter(const InMemoryMetricExporter &) = delete; | ||
| InMemoryMetricExporter(const InMemoryMetricExporter &&) = delete; | ||
| void operator=(const InMemoryMetricExporter &) = delete; | ||
| void operator=(const InMemoryMetricExporter &&) = delete; | ||
| ~InMemoryMetricExporter() override = default; | ||
|
|
||
| sdk::common::ExportResult Export(const sdk::metrics::ResourceMetrics &data) noexcept override; | ||
| sdk::metrics::AggregationTemporality GetAggregationTemporality( | ||
| sdk::metrics::InstrumentType instrument_type) const noexcept override; | ||
| bool ForceFlush( | ||
| std::chrono::microseconds timeout = (std::chrono::microseconds::max)()) noexcept override; | ||
| bool Shutdown(std::chrono::microseconds timeout = std::chrono::microseconds(0)) noexcept override; | ||
|
|
||
| const std::vector<sdk::metrics::ResourceMetrics> &GetData() const; | ||
|
|
||
| private: | ||
| std::vector<sdk::metrics::ResourceMetrics> data_{}; | ||
| std::atomic<bool> is_shutdown_{false}; | ||
| sdk::metrics::AggregationTemporalitySelector temporality_; | ||
| }; | ||
|
|
||
| } // namespace memory | ||
| } // namespace exporter | ||
| OPENTELEMETRY_END_NAMESPACE |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,53 @@ | ||
| // Copyright The OpenTelemetry Authors | ||
| // SPDX-License-Identifier: Apache-2.0 | ||
|
|
||
| #include "opentelemetry/exporters/memory/in_memory_metric_exporter.h" | ||
| #include "opentelemetry/sdk/common/global_log_handler.h" | ||
|
|
||
| OPENTELEMETRY_BEGIN_NAMESPACE | ||
| namespace exporter | ||
| { | ||
| namespace memory | ||
| { | ||
|
|
||
| using sdk::common::ExportResult; | ||
| using sdk::metrics::AggregationTemporality; | ||
| using sdk::metrics::InstrumentType; | ||
| using sdk::metrics::ResourceMetrics; | ||
|
|
||
| ExportResult InMemoryMetricExporter::Export(const ResourceMetrics &data) noexcept | ||
| { | ||
| if (is_shutdown_) | ||
| { | ||
| OTEL_INTERNAL_LOG_ERROR("[In Memory Metric Exporter] Exporting failed, exporter is shutdown"); | ||
| return ExportResult::kFailure; | ||
| } | ||
| data_.push_back(data); | ||
| return ExportResult::kSuccess; | ||
| } | ||
|
|
||
| AggregationTemporality InMemoryMetricExporter::GetAggregationTemporality( | ||
| InstrumentType instrument_type) const noexcept | ||
| { | ||
| return temporality_(instrument_type); | ||
| } | ||
|
|
||
| bool InMemoryMetricExporter::ForceFlush(std::chrono::microseconds /* timeout */) noexcept | ||
| { | ||
| return true; | ||
| } | ||
|
|
||
| bool InMemoryMetricExporter::Shutdown(std::chrono::microseconds /* timeout */) noexcept | ||
| { | ||
| is_shutdown_ = true; | ||
| return true; | ||
| } | ||
|
|
||
| const std::vector<ResourceMetrics> &InMemoryMetricExporter::GetData() const | ||
| { | ||
| return data_; | ||
| } | ||
|
|
||
| } // namespace memory | ||
| } // namespace exporter | ||
| OPENTELEMETRY_END_NAMESPACE |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,76 @@ | ||
| // Copyright The OpenTelemetry Authors | ||
| // SPDX-License-Identifier: Apache-2.0 | ||
|
|
||
| #include "opentelemetry/exporters/memory/in_memory_metric_exporter.h" | ||
| #include "opentelemetry/nostd/unique_ptr.h" | ||
| #include "opentelemetry/sdk/instrumentationscope/instrumentation_scope.h" | ||
| #include "opentelemetry/sdk/metrics/data/metric_data.h" | ||
| #include "opentelemetry/sdk/metrics/export/metric_producer.h" | ||
| #include "opentelemetry/sdk/metrics/instruments.h" | ||
| #include "opentelemetry/sdk/resource/resource.h" | ||
|
|
||
| #include <gtest/gtest.h> | ||
|
|
||
| using opentelemetry::exporter::memory::InMemoryMetricExporter; | ||
| using opentelemetry::sdk::common::ExportResult; | ||
| using opentelemetry::sdk::instrumentationscope::InstrumentationScope; | ||
| using opentelemetry::sdk::metrics::AggregationTemporality; | ||
| using opentelemetry::sdk::metrics::InstrumentType; | ||
| using opentelemetry::sdk::metrics::InstrumentValueType; | ||
| using opentelemetry::sdk::metrics::MetricData; | ||
| using opentelemetry::sdk::metrics::ScopeMetrics; | ||
| using opentelemetry::sdk::metrics::SumPointData; | ||
| using opentelemetry::sdk::resource::Resource; | ||
|
|
||
| class InMemoryMetricExporterTest : public ::testing::Test | ||
| { | ||
| protected: | ||
| InMemoryMetricExporter exporter_{[](auto) { return AggregationTemporality::kCumulative; }}; | ||
|
|
||
| Resource resource_ = Resource::GetEmpty(); | ||
| opentelemetry::nostd::unique_ptr<InstrumentationScope> instrumentation_scope_ = | ||
| InstrumentationScope::Create("test"); | ||
| opentelemetry::sdk::metrics::ResourceMetrics resource_metrics_{ | ||
| &resource_, | ||
| std::vector<ScopeMetrics>{{ | ||
| instrumentation_scope_.get(), | ||
| std::vector<MetricData>{MetricData{ | ||
| { | ||
| "test-metric", | ||
| "test-description", | ||
| "test-unit", | ||
| InstrumentType::kCounter, | ||
| InstrumentValueType::kDouble, | ||
| }, | ||
| AggregationTemporality::kCumulative, | ||
| {}, | ||
| {}, | ||
| {{ | ||
| {{"hello", "world"}}, | ||
| SumPointData{4.2, true}, | ||
| }}, | ||
| }}, | ||
| }}, | ||
| }; | ||
| }; | ||
|
|
||
| TEST_F(InMemoryMetricExporterTest, Export) | ||
| { | ||
| EXPECT_EQ(exporter_.Export(resource_metrics_), ExportResult::kSuccess); | ||
|
|
||
| auto &data = exporter_.GetData(); | ||
| EXPECT_EQ(data.size(), 1); | ||
| EXPECT_EQ(data.begin()->resource_, &resource_); | ||
| } | ||
|
|
||
| TEST_F(InMemoryMetricExporterTest, Shutdown) | ||
| { | ||
| EXPECT_TRUE(exporter_.Shutdown()); | ||
| EXPECT_EQ(exporter_.Export(resource_metrics_), ExportResult::kFailure); | ||
| } | ||
|
|
||
| TEST_F(InMemoryMetricExporterTest, TemporalitySelector) | ||
| { | ||
| EXPECT_EQ(exporter_.GetAggregationTemporality(InstrumentType::kCounter), | ||
| AggregationTemporality::kCumulative); | ||
| } |