Skip to content

Commit b4550a9

Browse files
committed
moving ResourceFilterDataFnOption to internal namespace
1 parent 13efa83 commit b4550a9

File tree

6 files changed

+14
-35
lines changed

6 files changed

+14
-35
lines changed

google/cloud/opentelemetry/internal/monitoring_exporter.cc

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,12 +32,13 @@ std::string FormatProjectFullName(std::string const& project) {
3232
}
3333

3434
otel_internal::ResourceFilterDataFn MakeFilter(Options const& options) {
35-
if (!options.has<otel::ResourceFilterDataFnOption>()) {
35+
if (!options.has<otel_internal::ResourceFilterDataFnOption>()) {
3636
return nullptr;
3737
}
3838

3939
// Get the metric labels set to be excluded.
40-
auto const& excluded = options.get<otel::ResourceFilterDataFnOption>();
40+
auto const& excluded =
41+
options.get<otel_internal::ResourceFilterDataFnOption>();
4142
if (excluded.empty()) return nullptr;
4243

4344
// Capture by value to avoid dangling reference in the lambda.

google/cloud/opentelemetry/internal/monitoring_exporter.h

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -45,6 +45,12 @@ using MonitoredResourceFromDataFn =
4545
// of the google::api::Metric proto.
4646
using ResourceFilterDataFn = std::function<bool(std::string const&)>;
4747

48+
// Filter resource labels. A set of OpenTelemetry resource attribute keys to
49+
// exclude from metric labels when exporting metrics.
50+
struct ResourceFilterDataFnOption {
51+
using Type = std::set<std::string>;
52+
};
53+
4854
class MonitoringExporter final
4955
: public opentelemetry::sdk::metrics::PushMetricExporter {
5056
public:

google/cloud/opentelemetry/internal/monitoring_exporter_test.cc

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -173,7 +173,8 @@ TEST(MonitoringExporterTest, MakeFilterEmptySet) {
173173
auto mock =
174174
std::make_shared<monitoring_v3_mocks::MockMetricServiceConnection>();
175175
Options options;
176-
options.set<otel::ResourceFilterDataFnOption>(std::set<std::string>{});
176+
options.set<otel_internal::ResourceFilterDataFnOption>(
177+
std::set<std::string>{});
177178

178179
auto exporter = std::make_unique<MonitoringExporter>(Project("test-project"),
179180
mock, options);
@@ -185,7 +186,7 @@ TEST(MonitoringExporterTest, MakeFilterWithExcludedKeys) {
185186
std::make_shared<monitoring_v3_mocks::MockMetricServiceConnection>();
186187
Options options;
187188
std::set<std::string> excluded{"service_name", "service_version"};
188-
options.set<otel::ResourceFilterDataFnOption>(excluded);
189+
options.set<otel_internal::ResourceFilterDataFnOption>(excluded);
189190

190191
auto exporter = std::make_unique<MonitoringExporter>(Project("test-project"),
191192
mock, options);

google/cloud/opentelemetry/monitoring_exporter.h

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -75,16 +75,6 @@ struct MonitoredResourceOption {
7575
using Type = google::api::MonitoredResource;
7676
};
7777

78-
/**
79-
* Filter resource labels.
80-
*
81-
* This option is primarily relevant to Google applications and libraries. It
82-
* can be ignored by external developers.
83-
*/
84-
struct ResourceFilterDataFnOption {
85-
using Type = std::set<std::string>;
86-
};
87-
8878
std::unique_ptr<opentelemetry::sdk::metrics::PushMetricExporter>
8979
MakeMonitoringExporter(
9080
Project project,

google/cloud/opentelemetry/monitoring_exporter_test.cc

Lines changed: 0 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -264,25 +264,6 @@ TEST(MonitoringExporter, CustomMonitoredResource) {
264264
EXPECT_EQ(result, opentelemetry::sdk::common::ExportResult::kSuccess);
265265
}
266266

267-
TEST(MonitoringExporter, CustomResourceFilterDataFunction) {
268-
auto mock =
269-
std::make_shared<monitoring_v3_mocks::MockMetricServiceConnection>();
270-
EXPECT_CALL(*mock, CreateTimeSeries)
271-
.WillOnce(
272-
[](google::monitoring::v3::CreateTimeSeriesRequest const& request) {
273-
EXPECT_THAT(request.name(), "projects/test-project");
274-
EXPECT_THAT(request.time_series(), SizeIs(2));
275-
return Status();
276-
});
277-
278-
auto options = Options{}.set<ResourceFilterDataFnOption>({"test_label"});
279-
auto exporter =
280-
MakeMonitoringExporter(Project("test-project"), std::move(mock), options);
281-
auto data = MakeResourceMetrics(/*expected_time_series_count=*/2);
282-
auto result = exporter->Export(data);
283-
EXPECT_EQ(result, opentelemetry::sdk::common::ExportResult::kSuccess);
284-
}
285-
286267
TEST(MonitoringExporter, CreateServiceTimeSeries) {
287268
auto mock =
288269
std::make_shared<monitoring_v3_mocks::MockMetricServiceConnection>();

google/cloud/storage/internal/grpc/metrics_exporter_impl.cc

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616

1717
#include "google/cloud/storage/internal/grpc/metrics_exporter_impl.h"
1818
#include "google/cloud/monitoring/v3/metric_connection.h"
19-
#include "google/cloud/opentelemetry/monitoring_exporter.h"
19+
#include "google/cloud/opentelemetry/internal/monitoring_exporter.h"
2020
#include "google/cloud/storage/grpc_plugin.h"
2121
#include "google/cloud/storage/internal/grpc/metrics_exporter_options.h"
2222
#include "google/cloud/storage/internal/grpc/metrics_meter_provider.h"
@@ -92,7 +92,7 @@ absl::optional<ExporterConfig> MakeMeterProviderConfig(
9292

9393
auto exporter_options = MetricsExporterOptions(*project, resource);
9494
if (options.has<storage_experimental::GrpcMetricsExcludedLabelsOption>()) {
95-
exporter_options.set<otel::ResourceFilterDataFnOption>(
95+
exporter_options.set<otel_internal::ResourceFilterDataFnOption>(
9696
options.get<storage_experimental::GrpcMetricsExcludedLabelsOption>());
9797
}
9898

0 commit comments

Comments
 (0)