aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorYash Tibrewal <yashkt@google.com>2024-01-11 10:12:20 -0800
committerCopybara-Service <copybara-worker@google.com>2024-01-11 10:15:04 -0800
commit6741e2064d3b7826114b0d250ba9ebb415d951d9 (patch)
treefafdbe58f11f5455c1ac70bc6c4a1cdf2758c909
parent1ec0559b341e8a55893afddead8a7c2d409b9701 (diff)
downloadgrpc-grpc-6741e2064d3b7826114b0d250ba9ebb415d951d9.tar.gz
[xds interop] Use new CSM Observability APIs (#35508)
Closes #35508 COPYBARA_INTEGRATE_REVIEW=https://github.com/grpc/grpc/pull/35508 from yashykt:XdsInteropNewCsm 09d408c082b4cb8e534ce5143fea2cbb72b560f1 PiperOrigin-RevId: 597588033
-rw-r--r--test/cpp/interop/xds_interop_client.cc7
-rw-r--r--test/cpp/interop/xds_interop_server.cc7
2 files changed, 8 insertions, 6 deletions
diff --git a/test/cpp/interop/xds_interop_client.cc b/test/cpp/interop/xds_interop_client.cc
index d5a6d51988..b46926e517 100644
--- a/test/cpp/interop/xds_interop_client.cc
+++ b/test/cpp/interop/xds_interop_client.cc
@@ -403,9 +403,10 @@ void EnableCsmObservability() {
auto meter_provider =
std::make_shared<opentelemetry::sdk::metrics::MeterProvider>();
meter_provider->AddMetricReader(std::move(prometheus_exporter));
- grpc::experimental::CsmObservabilityBuilder observability;
- observability.SetMeterProvider(std::move(meter_provider));
- auto status = observability.BuildAndRegister();
+ grpc::experimental::OpenTelemetryPluginBuilder()
+ .AddPluginOption(grpc::experimental::MakeCsmOpenTelemetryPluginOption())
+ .SetMeterProvider(std::move(meter_provider))
+ .BuildAndRegisterGlobal();
}
void RunServer(const int port, StatsWatchers* stats_watchers,
diff --git a/test/cpp/interop/xds_interop_server.cc b/test/cpp/interop/xds_interop_server.cc
index 9db746f7d3..0cab7527b5 100644
--- a/test/cpp/interop/xds_interop_server.cc
+++ b/test/cpp/interop/xds_interop_server.cc
@@ -54,9 +54,10 @@ void EnableCsmObservability() {
auto meter_provider =
std::make_shared<opentelemetry::sdk::metrics::MeterProvider>();
meter_provider->AddMetricReader(std::move(prometheus_exporter));
- grpc::experimental::CsmObservabilityBuilder observability;
- observability.SetMeterProvider(std::move(meter_provider));
- auto status = observability.BuildAndRegister();
+ grpc::experimental::OpenTelemetryPluginBuilder()
+ .AddPluginOption(grpc::experimental::MakeCsmOpenTelemetryPluginOption())
+ .SetMeterProvider(std::move(meter_provider))
+ .BuildAndRegisterGlobal();
}
int main(int argc, char** argv) {