[CI] Upgrade Prometheus CI to opentelemetry-cpp 1.15.0 (#434)

marcalff · web-flow · commit 7698a59801e2 · 2024-04-25T00:07:20.000+02:00
diff --git a/.github/workflows/prometheus.yml b/.github/workflows/prometheus.yml
@@ -65,7 +65,7 @@ jobs:
         uses: actions/checkout@v3
         with:
           repository: "open-telemetry/opentelemetry-cpp"
-          ref: "v1.11.0"
+          ref: "v1.15.0"
           path: "otel_cpp"
           submodules: "recursive"
       - name: run tests
@@ -103,7 +103,7 @@ jobs:
         uses: actions/checkout@v3
         with:
           repository: "open-telemetry/opentelemetry-cpp"
-          ref: "v1.11.0"
+          ref: "v1.15.0"
           path: "otel_cpp"
           submodules: "recursive"
       - name: setup
diff --git a/exporters/prometheus/repository.bzl b/exporters/prometheus/repository.bzl
@@ -19,24 +19,21 @@ def io_opentelemetry_cpp_contrib_deps():
     maybe(
         http_archive,
         name = "io_opentelemetry_cpp",
-        sha256 = "f30cd88bf898a5726d245eba882b8e81012021eb00df34109f4dfb203f005cea",
-        strip_prefix = "opentelemetry-cpp-1.11.0",
+        sha256 = "69b0fef380658e15be9d817bfcb32e3f5de96da652bcdce77b4e750ed8beddee",
+        strip_prefix = "opentelemetry-cpp-1.15.0",
         urls = [
-            "https://github.com/open-telemetry/opentelemetry-cpp/archive/v1.11.0.tar.gz",
+            "https://github.com/open-telemetry/opentelemetry-cpp/archive/v1.15.0.tar.gz",
         ],
     )
 
     # C++ Prometheus Client library.
     maybe(
         http_archive,
         name = "com_github_jupp0r_prometheus_cpp",
-        sha256 = "b4eff62bcdba10efd6210b9fa8a5b2505ad8ea6c211968be79aeb2c4c2f97338",
-        # strip_prefix = "prometheus-cpp-1.1.0",
-        # 1.1.0 with bazel 6 support
-        strip_prefix = "prometheus-cpp-81e208c250748657f1d5dab247e82c4429a931af",
+        sha256 = "48dbad454d314b836cc667ec4def93ec4a6e4255fc8387c20cacb3b8b6faee30",
+        strip_prefix = "prometheus-cpp-1.2.4",
         urls = [
-            # "https://github.com/jupp0r/prometheus-cpp/archive/refs/tags/v1.1.0.tar.gz",
-            "https://github.com/jupp0r/prometheus-cpp/archive/81e208c250748657f1d5dab247e82c4429a931af.tar.gz",
+            "https://github.com/jupp0r/prometheus-cpp/archive/refs/tags/v1.2.4.tar.gz",
         ],
     )
 
diff --git a/exporters/prometheus/test/prometheus_test_helper.h b/exporters/prometheus/test/prometheus_test_helper.h
@@ -25,17 +25,16 @@ inline opentelemetry::sdk::resource::Resource &GetEmptyResource()
 /**
  * Helper function to create ResourceMetrics
  */
-inline metric_sdk::ResourceMetrics CreateSumPointData()
+inline metric_sdk::ResourceMetrics CreateSumPointData(
+    opentelemetry::sdk::instrumentationscope::InstrumentationScope *scope)
 {
   metric_sdk::SumPointData sum_point_data{};
   sum_point_data.value_ = 10.0;
   metric_sdk::SumPointData sum_point_data2{};
   sum_point_data2.value_ = 20.0;
   metric_sdk::ResourceMetrics data;
   data.resource_ = &GetEmptyResource();
-  auto instrumentation_scope =
-      opentelemetry::sdk::instrumentationscope::InstrumentationScope::Create("library_name",
-                                                                             "1.9.1");
+
   metric_sdk::MetricData metric_data{
       metric_sdk::InstrumentDescriptor{"library_name", "description", "unit",
                                        metric_sdk::InstrumentType::kCounter,
@@ -46,11 +45,12 @@ inline metric_sdk::ResourceMetrics CreateSumPointData()
           {metric_sdk::PointAttributes{{"a1", "b1"}}, sum_point_data},
           {metric_sdk::PointAttributes{{"a2", "b2"}}, sum_point_data2}}};
   data.scope_metric_data_ = std::vector<metric_sdk::ScopeMetrics>{
-      {instrumentation_scope.get(), std::vector<metric_sdk::MetricData>{metric_data}}};
+      {scope, std::vector<metric_sdk::MetricData>{metric_data}}};
   return data;
 }
 
-inline metric_sdk::ResourceMetrics CreateHistogramPointData()
+inline metric_sdk::ResourceMetrics CreateHistogramPointData(
+    opentelemetry::sdk::instrumentationscope::InstrumentationScope *scope)
 {
   metric_sdk::HistogramPointData histogram_point_data{};
   histogram_point_data.boundaries_ = std::vector<double>{10.1, 20.2, 30.2};
@@ -65,9 +65,7 @@ inline metric_sdk::ResourceMetrics CreateHistogramPointData()
 
   metric_sdk::ResourceMetrics data;
   data.resource_ = &GetEmptyResource();
-  auto instrumentation_scope =
-      opentelemetry::sdk::instrumentationscope::InstrumentationScope::Create("library_name",
-                                                                             "1.9.1");
+
   metric_sdk::MetricData metric_data{
       metric_sdk::InstrumentDescriptor{"library_name", "description", "unit",
                                        metric_sdk::InstrumentType::kHistogram,
@@ -78,17 +76,16 @@ inline metric_sdk::ResourceMetrics CreateHistogramPointData()
           {metric_sdk::PointAttributes{{"a1", "b1"}}, histogram_point_data},
           {metric_sdk::PointAttributes{{"a2", "b2"}}, histogram_point_data2}}};
   data.scope_metric_data_ = std::vector<metric_sdk::ScopeMetrics>{
-      {instrumentation_scope.get(), std::vector<metric_sdk::MetricData>{metric_data}}};
+      {scope, std::vector<metric_sdk::MetricData>{metric_data}}};
   return data;
 }
 
-inline metric_sdk::ResourceMetrics CreateLastValuePointData()
+inline metric_sdk::ResourceMetrics CreateLastValuePointData(
+    opentelemetry::sdk::instrumentationscope::InstrumentationScope *scope)
 {
   metric_sdk::ResourceMetrics data;
   data.resource_ = &GetEmptyResource();
-  auto instrumentation_scope =
-      opentelemetry::sdk::instrumentationscope::InstrumentationScope::Create("library_name",
-                                                                             "1.2.0");
+
   metric_sdk::LastValuePointData last_value_point_data{};
   last_value_point_data.value_              = 10.0;
   last_value_point_data.is_lastvalue_valid_ = true;
@@ -107,17 +104,16 @@ inline metric_sdk::ResourceMetrics CreateLastValuePointData()
           {metric_sdk::PointAttributes{{"a1", "b1"}}, last_value_point_data},
           {metric_sdk::PointAttributes{{"a2", "b2"}}, last_value_point_data2}}};
   data.scope_metric_data_ = std::vector<metric_sdk::ScopeMetrics>{
-      {instrumentation_scope.get(), std::vector<metric_sdk::MetricData>{metric_data}}};
+      {scope, std::vector<metric_sdk::MetricData>{metric_data}}};
   return data;
 }
 
-inline metric_sdk::ResourceMetrics CreateDropPointData()
+inline metric_sdk::ResourceMetrics CreateDropPointData(
+    opentelemetry::sdk::instrumentationscope::InstrumentationScope *scope)
 {
   metric_sdk::ResourceMetrics data;
   data.resource_ = &GetEmptyResource();
-  auto instrumentation_scope =
-      opentelemetry::sdk::instrumentationscope::InstrumentationScope::Create("library_name",
-                                                                             "1.2.0");
+
   metric_sdk::DropPointData drop_point_data{};
   metric_sdk::DropPointData drop_point_data2{};
   metric_sdk::MetricData metric_data{
@@ -130,7 +126,7 @@ inline metric_sdk::ResourceMetrics CreateDropPointData()
           {metric_sdk::PointAttributes{{"a1", "b1"}}, drop_point_data},
           {metric_sdk::PointAttributes{{"a2", "b2"}}, drop_point_data2}}};
   data.scope_metric_data_ = std::vector<metric_sdk::ScopeMetrics>{
-      {instrumentation_scope.get(), std::vector<metric_sdk::MetricData>{metric_data}}};
+      {scope, std::vector<metric_sdk::MetricData>{metric_data}}};
   return data;
 }
 }  // namespace
diff --git a/exporters/prometheus/test/push_exporter_test.cc b/exporters/prometheus/test/push_exporter_test.cc
@@ -91,7 +91,13 @@ TEST(PrometheusPushExporter, ExportSuccessfully)
   PrometheusPushExporterTest p;
   PrometheusPushExporter exporter = p.GetExporter();
 
-  auto res = exporter.Export(CreateSumPointData());
+  auto instrumentation_scope =
+      opentelemetry::sdk::instrumentationscope::InstrumentationScope::Create("library_name",
+                                                                             "1.9.1");
+
+  auto data = CreateSumPointData(instrumentation_scope.get());
+
+  auto res = exporter.Export(data);
 
   // result should be kSuccess = 0
   ExportResult code = ExportResult::kSuccess;
@@ -109,8 +115,14 @@ TEST(PrometheusPushExporter, ExporterIsShutdown)
 
   exporter.Shutdown();
 
+  auto instrumentation_scope =
+      opentelemetry::sdk::instrumentationscope::InstrumentationScope::Create("library_name",
+                                                                             "1.9.1");
+
+  auto data = CreateSumPointData(instrumentation_scope.get());
+
   // send export request after shutdown
-  auto res = exporter.Export(CreateSumPointData());
+  auto res = exporter.Export(data);
 
   // result code should be kFailure = 1
   ExportResult code = ExportResult::kFailure;
@@ -134,18 +146,28 @@ TEST(PrometheusPushExporter, CollectionNotEnoughSpace)
 
   int max_collection_size = exporter.GetMaxCollectionSize();
 
+  auto instrumentation_scope =
+      opentelemetry::sdk::instrumentationscope::InstrumentationScope::Create("library_name",
+                                                                             "1.15.0");
+
   // send export request to fill the
   // collection in the collector
+  // In each loop, there are 2 collections:
+  // - the instrumentation_scope
+  // - the data
   ExportResult code = ExportResult::kSuccess;
-  for (int count = 1; count <= max_collection_size; ++count)
+  for (int count = 1; count <= max_collection_size; count += 2)
   {
-    auto res = exporter.Export(CreateSumPointData());
+    auto data = CreateSumPointData(instrumentation_scope.get());
+    auto res  = exporter.Export(data);
     ASSERT_EQ(res, code);
   }
 
+  auto data = CreateSumPointData(instrumentation_scope.get());
+
   // send export request that does not complete
   // due to not enough space in the collection
-  auto res = exporter.Export(CreateSumPointData());
+  auto res = exporter.Export(data);
 
   // the result code should be kFailureFull = 2
   code = ExportResult::kFailureFull;
@@ -178,7 +200,7 @@ TEST(PrometheusPushExporterFactory, Create)
 {
   PrometheusPushExporterOptions options;
   options.host                 = "localhost";
-  options.port                 = 4138;
+  options.port                 = "4138";
   options.jobname              = "jobname";
   options.labels["test_label"] = "test_value";
   options.username             = "user";
