Fix first bucket otlp issue if invalid end stamp (#665)

leoparente · web-flow · commit fdb81ba75e7e · 2023-04-18T16:10:49.000-04:00
diff --git a/src/AbstractMetricsManager.h b/src/AbstractMetricsManager.h
@@ -218,7 +218,7 @@ class AbstractMetricsBucket
 
     virtual void to_json(json &j) const = 0;
     virtual void to_prometheus(std::stringstream &out, Metric::LabelMap add_labels = {}) const = 0;
-    virtual void to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels = {}) const = 0;
+    virtual void to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels = {}) const = 0;
     virtual void update_topn_metrics(size_t topn_count, uint64_t percentile_threshold) = 0;
 };
 
@@ -553,8 +553,13 @@ class AbstractMetricsManager
         if (!_tap_name.empty() && add_labels.find("tap") == add_labels.end()) {
             add_labels["tap"] = _tap_name;
         }
-
-        _metric_buckets.at(period)->to_opentelemetry(scope, add_labels);
+        auto bucket = _metric_buckets.at(period).get();
+        auto start_ts = bucket->start_tstamp();
+        auto end_ts = bucket->end_tstamp();
+        if (!end_ts.tv_sec) {
+            timespec_get(&end_ts, TIME_UTC);
+        }
+        bucket->to_opentelemetry(scope, start_ts, end_ts, add_labels);
     }
 
     void window_external_opentelemetry(metrics::v1::ScopeMetrics &scope, AbstractMetricsBucket *bucket, Metric::LabelMap add_labels = {}) const
@@ -563,7 +568,13 @@ class AbstractMetricsManager
             return;
         }
         // static because caller guarantees only our own bucket type
-        static_cast<MetricsBucketClass *>(bucket)->to_opentelemetry(scope, add_labels);
+        auto sbucket = static_cast<MetricsBucketClass *>(bucket);
+        auto start_ts = sbucket->start_tstamp();
+        auto end_ts = sbucket->end_tstamp();
+        if (!end_ts.tv_sec) {
+            timespec_get(&end_ts, TIME_UTC);
+        }
+        sbucket->to_opentelemetry(scope, start_ts, end_ts, add_labels);
     }
 
     void window_external_prometheus(std::stringstream &out, AbstractMetricsBucket *bucket, Metric::LabelMap add_labels = {}) const
diff --git a/src/handlers/bgp/BgpStreamHandler.cpp b/src/handlers/bgp/BgpStreamHandler.cpp
@@ -189,11 +189,8 @@ void BgpMetricsBucket::to_prometheus(std::stringstream &out, Metric::LabelMap ad
     _counters.filtered.to_prometheus(out, add_labels);
 }
 
-void BgpMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels) const
+void BgpMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels) const
 {
-    auto start_ts = start_tstamp();
-    auto end_ts = end_tstamp();
-
     _rate_total.to_opentelemetry(scope, start_ts, end_ts, add_labels);
 
     {
diff --git a/src/handlers/bgp/BgpStreamHandler.h b/src/handlers/bgp/BgpStreamHandler.h
@@ -78,7 +78,7 @@ class BgpMetricsBucket final : public visor::AbstractMetricsBucket
     void specialized_merge(const AbstractMetricsBucket &other, Metric::Aggregate agg_operator) override;
     void to_json(json &j) const override;
     void to_prometheus(std::stringstream &out, Metric::LabelMap add_labels = {}) const override;
-    void to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels = {}) const override;
+    void to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels = {}) const override;
     void update_topn_metrics(size_t, uint64_t) override
     {
     }
diff --git a/src/handlers/dhcp/DhcpStreamHandler.cpp b/src/handlers/dhcp/DhcpStreamHandler.cpp
@@ -150,11 +150,8 @@ void DhcpMetricsBucket::to_prometheus(std::stringstream &out, Metric::LabelMap a
     _dhcp_topServers.to_prometheus(out, add_labels);
 }
 
-void DhcpMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels) const
+void DhcpMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels) const
 {
-    auto start_ts = start_tstamp();
-    auto end_ts = end_tstamp();
-
     _rate_total.to_opentelemetry(scope, start_ts, end_ts, add_labels);
 
     {
diff --git a/src/handlers/dhcp/DhcpStreamHandler.h b/src/handlers/dhcp/DhcpStreamHandler.h
@@ -100,7 +100,7 @@ class DhcpMetricsBucket final : public visor::AbstractMetricsBucket
     void specialized_merge(const AbstractMetricsBucket &other, Metric::Aggregate agg_operator) override;
     void to_json(json &j) const override;
     void to_prometheus(std::stringstream &out, Metric::LabelMap add_labels = {}) const override;
-    void to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels = {}) const override;
+    void to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels = {}) const override;
     void update_topn_metrics(size_t, uint64_t) override
     {
     }
diff --git a/src/handlers/dns/v1/DnsStreamHandler.cpp b/src/handlers/dns/v1/DnsStreamHandler.cpp
@@ -1238,11 +1238,8 @@ void DnsMetricsBucket::to_prometheus(std::stringstream &out, Metric::LabelMap ad
     });
 }
 
-void DnsMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels) const
+void DnsMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels) const
 {
-    auto start_ts = start_tstamp();
-    auto end_ts = end_tstamp();
-
     _rate_total.to_opentelemetry(scope, start_ts, end_ts, add_labels);
 
     {
diff --git a/src/handlers/dns/v1/DnsStreamHandler.h b/src/handlers/dns/v1/DnsStreamHandler.h
@@ -199,7 +199,7 @@ class DnsMetricsBucket final : public visor::AbstractMetricsBucket
     void specialized_merge(const AbstractMetricsBucket &other, Metric::Aggregate agg_operator) override;
     void to_json(json &j) const override;
     void to_prometheus(std::stringstream &out, Metric::LabelMap add_labels = {}) const override;
-    void to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels = {}) const override;
+    void to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels = {}) const override;
     void update_topn_metrics(size_t topn_count, uint64_t percentile_threshold) override
     {
         _dns_topGeoLocECS.set_settings(topn_count, percentile_threshold);
diff --git a/src/handlers/dns/v2/DnsStreamHandler.cpp b/src/handlers/dns/v2/DnsStreamHandler.cpp
@@ -840,11 +840,8 @@ void DnsMetricsBucket::to_prometheus(std::stringstream &out, Metric::LabelMap ad
     }
 }
 
-void DnsMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels) const
+void DnsMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels) const
 {
-    auto start_ts = start_tstamp();
-    auto end_ts = end_tstamp();
-
     for (auto &dns : _dns) {
         auto dir_labels = add_labels;
         dir_labels["direction"] = _dir_str.at(dns.first);
diff --git a/src/handlers/dns/v2/DnsStreamHandler.h b/src/handlers/dns/v2/DnsStreamHandler.h
@@ -362,7 +362,7 @@ class DnsMetricsBucket final : public visor::AbstractMetricsBucket
     void specialized_merge(const AbstractMetricsBucket &other, Metric::Aggregate agg_operator) override;
     void to_json(json &j) const override;
     void to_prometheus(std::stringstream &out, Metric::LabelMap add_labels = {}) const override;
-    void to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels = {}) const override;
+    void to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels = {}) const override;
     void update_topn_metrics(size_t topn_count, uint64_t percentile_threshold) override
     {
         _topn_count = topn_count;
diff --git a/src/handlers/flow/FlowStreamHandler.cpp b/src/handlers/flow/FlowStreamHandler.cpp
@@ -885,11 +885,8 @@ void FlowMetricsBucket::to_prometheus(std::stringstream &out, Metric::LabelMap a
     }
 }
 
-void FlowMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels) const
+void FlowMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels) const
 {
-    auto start_ts = start_tstamp();
-    auto end_ts = end_tstamp();
-
     std::shared_lock r_lock(_mutex);
 
     for (const auto &device : _devices_metrics) {
diff --git a/src/handlers/flow/FlowStreamHandler.h b/src/handlers/flow/FlowStreamHandler.h
@@ -275,7 +275,7 @@ class FlowMetricsBucket final : public visor::AbstractMetricsBucket
     void specialized_merge(const AbstractMetricsBucket &other, Metric::Aggregate agg_operator) override;
     void to_json(json &j) const override;
     void to_prometheus(std::stringstream &out, Metric::LabelMap add_labels = {}) const override;
-    void to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels = {}) const override;
+    void to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels = {}) const override;
     void update_topn_metrics(size_t topn_count, uint64_t percentile_threshold) override
     {
         _topn_count = topn_count;
diff --git a/src/handlers/input_resources/InputResourcesStreamHandler.cpp b/src/handlers/input_resources/InputResourcesStreamHandler.cpp
@@ -165,11 +165,8 @@ void InputResourcesMetricsBucket::to_prometheus(std::stringstream &out, Metric::
     _handler_count.to_prometheus(out, add_labels);
 }
 
-void InputResourcesMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels) const
+void InputResourcesMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels) const
 {
-    auto start_ts = start_tstamp();
-    auto end_ts = end_tstamp();
-    
     {
         auto [num_events, num_samples, event_rate, event_lock] = event_data_locked(); // thread safe
 
diff --git a/src/handlers/input_resources/InputResourcesStreamHandler.h b/src/handlers/input_resources/InputResourcesStreamHandler.h
@@ -53,7 +53,7 @@ class InputResourcesMetricsBucket final : public visor::AbstractMetricsBucket
     void specialized_merge(const AbstractMetricsBucket &other, Metric::Aggregate agg_operator) override;
     void to_json(json &j) const override;
     void to_prometheus(std::stringstream &out, Metric::LabelMap add_labels = {}) const override;
-    void to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels = {}) const override;
+    void to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels = {}) const override;
     void update_topn_metrics(size_t, uint64_t) override
     {
     }
diff --git a/src/handlers/mock/MockStreamHandler.cpp b/src/handlers/mock/MockStreamHandler.cpp
@@ -78,11 +78,8 @@ void MockMetricsBucket::to_prometheus(std::stringstream &out, Metric::LabelMap a
     _counters.mock_counter.to_prometheus(out, add_labels);
 }
 
-void MockMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels) const
+void MockMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels) const
 {
-    auto start_ts = start_tstamp();
-    auto end_ts = end_tstamp();
-    
     std::shared_lock r_lock(_mutex);
 
     _counters.mock_counter.to_opentelemetry(scope, start_ts, end_ts, add_labels);
diff --git a/src/handlers/mock/MockStreamHandler.h b/src/handlers/mock/MockStreamHandler.h
@@ -7,9 +7,9 @@
 #include "AbstractMetricsManager.h"
 #include "MockInputStream.h"
 #include "StreamHandler.h"
-#include <spdlog/spdlog.h>
 #include <Corrade/Utility/Debug.h>
 #include <limits>
+#include <spdlog/spdlog.h>
 #include <string>
 
 namespace visor::handler::mock {
@@ -50,7 +50,7 @@ class MockMetricsBucket final : public visor::AbstractMetricsBucket
     void specialized_merge(const AbstractMetricsBucket &other, Metric::Aggregate agg_operator) override;
     void to_json(json &j) const override;
     void to_prometheus(std::stringstream &out, Metric::LabelMap add_labels = {}) const override;
-    void to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels = {}) const override;
+    void to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels = {}) const override;
     void update_topn_metrics(size_t, uint64_t) override
     {
     }
diff --git a/src/handlers/net/v1/NetStreamHandler.cpp b/src/handlers/net/v1/NetStreamHandler.cpp
@@ -387,11 +387,8 @@ void NetworkMetricsBucket::to_prometheus(std::stringstream &out, Metric::LabelMa
     _payload_size.to_prometheus(out, add_labels);
 }
 
-void NetworkMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels) const
+void NetworkMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels) const
 {
-    auto start_ts = start_tstamp();
-    auto end_ts = end_tstamp();
-
     _rate_in.to_opentelemetry(scope, start_ts, end_ts, add_labels);
     _rate_out.to_opentelemetry(scope, start_ts, end_ts, add_labels);
     _rate_total.to_opentelemetry(scope, start_ts, end_ts, add_labels);
diff --git a/src/handlers/net/v1/NetStreamHandler.h b/src/handlers/net/v1/NetStreamHandler.h
@@ -139,7 +139,7 @@ class NetworkMetricsBucket final : public visor::AbstractMetricsBucket
     void specialized_merge(const AbstractMetricsBucket &other, Metric::Aggregate agg_operator) override;
     void to_json(json &j) const override;
     void to_prometheus(std::stringstream &out, Metric::LabelMap add_labels = {}) const override;
-    void to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels = {}) const override;
+    void to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels = {}) const override;
     void update_topn_metrics(size_t topn_count, uint64_t percentile_threshold) override
     {
         _topGeoLoc.set_settings(topn_count, percentile_threshold);
diff --git a/src/handlers/net/v2/NetStreamHandler.cpp b/src/handlers/net/v2/NetStreamHandler.cpp
@@ -382,11 +382,8 @@ void NetworkMetricsBucket::to_prometheus(std::stringstream &out, Metric::LabelMa
     }
 }
 
-void NetworkMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels) const
+void NetworkMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels) const
 {
-    auto start_ts = start_tstamp();
-    auto end_ts = end_tstamp();
-
     if (group_enabled(group::NetMetrics::Quantiles)) {
         for (auto &net : _net) {
             auto dir_labels = add_labels;
diff --git a/src/handlers/net/v2/NetStreamHandler.h b/src/handlers/net/v2/NetStreamHandler.h
@@ -192,7 +192,7 @@ class NetworkMetricsBucket final : public visor::AbstractMetricsBucket
     void specialized_merge(const AbstractMetricsBucket &other, Metric::Aggregate agg_operator) override;
     void to_json(json &j) const override;
     void to_prometheus(std::stringstream &out, Metric::LabelMap add_labels = {}) const override;
-    void to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels = {}) const override;
+    void to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels = {}) const override;
     void update_topn_metrics(size_t topn_count, uint64_t percentile_threshold) override
     {
         _topn_count = topn_count;
diff --git a/src/handlers/netprobe/NetProbeStreamHandler.cpp b/src/handlers/netprobe/NetProbeStreamHandler.cpp
@@ -186,11 +186,8 @@ void NetProbeMetricsBucket::to_prometheus(std::stringstream &out, Metric::LabelM
     }
 }
 
-void NetProbeMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels) const
+void NetProbeMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels) const
 {
-    auto start_ts = start_tstamp();
-    auto end_ts = end_tstamp();
-
     std::shared_lock r_lock(_mutex);
 
     for (const auto &target : _targets_metrics) {
diff --git a/src/handlers/netprobe/NetProbeStreamHandler.h b/src/handlers/netprobe/NetProbeStreamHandler.h
@@ -15,8 +15,8 @@
 #pragma GCC diagnostic ignored "-Wold-style-cast"
 #pragma GCC diagnostic ignored "-Wzero-as-null-pointer-constant"
 #endif
-#include <VisorTcpLayer.h>
 #include <IcmpLayer.h>
+#include <VisorTcpLayer.h>
 #ifdef __GNUC__
 #pragma GCC diagnostic pop
 #endif
@@ -81,7 +81,7 @@ class NetProbeMetricsBucket final : public visor::AbstractMetricsBucket
     void specialized_merge(const AbstractMetricsBucket &other, Metric::Aggregate agg_operator) override;
     void to_json(json &j) const override;
     void to_prometheus(std::stringstream &out, Metric::LabelMap add_labels = {}) const override;
-    void to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels = {}) const override;
+    void to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels = {}) const override;
     void update_topn_metrics(size_t, uint64_t) override
     {
     }
diff --git a/src/handlers/pcap/PcapStreamHandler.cpp b/src/handlers/pcap/PcapStreamHandler.cpp
@@ -98,19 +98,15 @@ void PcapMetricsBucket::to_prometheus(std::stringstream &out, Metric::LabelMap a
     _counters.pcap_if_drop.to_prometheus(out, add_labels);
 }
 
-void PcapMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels) const
+void PcapMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels) const
 {
-    auto start_ts = start_tstamp();
-    auto end_ts = end_tstamp();
-    
     std::shared_lock r_lock(_mutex);
 
     _counters.pcap_TCP_reassembly_errors.to_opentelemetry(scope, start_ts, end_ts, add_labels);
     _counters.pcap_os_drop.to_opentelemetry(scope, start_ts, end_ts, add_labels);
     _counters.pcap_if_drop.to_opentelemetry(scope, start_ts, end_ts, add_labels);
 }
 
-
 void PcapMetricsBucket::to_json(json &j) const
 {
     std::shared_lock r_lock(_mutex);
diff --git a/src/handlers/pcap/PcapStreamHandler.h b/src/handlers/pcap/PcapStreamHandler.h
@@ -59,7 +59,7 @@ class PcapMetricsBucket final : public visor::AbstractMetricsBucket
     void specialized_merge(const AbstractMetricsBucket &other, Metric::Aggregate agg_operator) override;
     void to_json(json &j) const override;
     void to_prometheus(std::stringstream &out, Metric::LabelMap add_labels = {}) const override;
-    void to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels = {}) const override;
+    void to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels = {}) const override;
     void update_topn_metrics(size_t, uint64_t) override
     {
     }
diff --git a/src/tests/test_metrics.cpp b/src/tests/test_metrics.cpp
@@ -17,7 +17,7 @@ class TestMetricsBucket final : public AbstractMetricsBucket
     {
         out << "test_performed" << std::endl;
     }
-    void to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap) const
+    void to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &, timespec &, Metric::LabelMap) const
     {
         scope.add_metrics()->set_name("test1");
         scope.add_metrics()->set_name("test2");

Original file line number	Diff line number	Diff line change
`@@ -189,11 +189,8 @@ void BgpMetricsBucket::to_prometheus(std::stringstream &out, Metric::LabelMap ad`
`189`	`189`	`_counters.filtered.to_prometheus(out, add_labels);`
`190`	`190`	`}`
`191`	`191`
`192`		`-void BgpMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels) const`
	`192`	`+void BgpMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels) const`
`193`	`193`	`{`
`194`		`- auto start_ts = start_tstamp();`
`195`		`- auto end_ts = end_tstamp();`
`196`		`-`
`197`	`194`	`_rate_total.to_opentelemetry(scope, start_ts, end_ts, add_labels);`
`198`	`195`
`199`	`196`	`{`
Original file line number	Diff line number	Diff line change
`@@ -78,7 +78,7 @@ class BgpMetricsBucket final : public visor::AbstractMetricsBucket`
`78`	`78`	`void specialized_merge(const AbstractMetricsBucket &other, Metric::Aggregate agg_operator) override;`
`79`	`79`	`void to_json(json &j) const override;`
`80`	`80`	`void to_prometheus(std::stringstream &out, Metric::LabelMap add_labels = {}) const override;`
`81`		`- void to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels = {}) const override;`
	`81`	`+ void to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels = {}) const override;`
`82`	`82`	`void update_topn_metrics(size_t, uint64_t) override`
`83`	`83`	`{`
`84`	`84`	`}`
Original file line number	Diff line number	Diff line change
`@@ -150,11 +150,8 @@ void DhcpMetricsBucket::to_prometheus(std::stringstream &out, Metric::LabelMap a`
`150`	`150`	`_dhcp_topServers.to_prometheus(out, add_labels);`
`151`	`151`	`}`
`152`	`152`
`153`		`-void DhcpMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels) const`
	`153`	`+void DhcpMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels) const`
`154`	`154`	`{`
`155`		`- auto start_ts = start_tstamp();`
`156`		`- auto end_ts = end_tstamp();`
`157`		`-`
`158`	`155`	`_rate_total.to_opentelemetry(scope, start_ts, end_ts, add_labels);`
`159`	`156`
`160`	`157`	`{`
Original file line number	Diff line number	Diff line change
`@@ -100,7 +100,7 @@ class DhcpMetricsBucket final : public visor::AbstractMetricsBucket`
`100`	`100`	`void specialized_merge(const AbstractMetricsBucket &other, Metric::Aggregate agg_operator) override;`
`101`	`101`	`void to_json(json &j) const override;`
`102`	`102`	`void to_prometheus(std::stringstream &out, Metric::LabelMap add_labels = {}) const override;`
`103`		`- void to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels = {}) const override;`
	`103`	`+ void to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels = {}) const override;`
`104`	`104`	`void update_topn_metrics(size_t, uint64_t) override`
`105`	`105`	`{`
`106`	`106`	`}`
Original file line number	Diff line number	Diff line change
`@@ -1238,11 +1238,8 @@ void DnsMetricsBucket::to_prometheus(std::stringstream &out, Metric::LabelMap ad`
`1238`	`1238`	`});`
`1239`	`1239`	`}`
`1240`	`1240`
`1241`		`-void DnsMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels) const`
	`1241`	`+void DnsMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels) const`
`1242`	`1242`	`{`
`1243`		`- auto start_ts = start_tstamp();`
`1244`		`- auto end_ts = end_tstamp();`
`1245`		`-`
`1246`	`1243`	`_rate_total.to_opentelemetry(scope, start_ts, end_ts, add_labels);`
`1247`	`1244`
`1248`	`1245`	`{`
Original file line number	Diff line number	Diff line change
`@@ -199,7 +199,7 @@ class DnsMetricsBucket final : public visor::AbstractMetricsBucket`
`199`	`199`	`void specialized_merge(const AbstractMetricsBucket &other, Metric::Aggregate agg_operator) override;`
`200`	`200`	`void to_json(json &j) const override;`
`201`	`201`	`void to_prometheus(std::stringstream &out, Metric::LabelMap add_labels = {}) const override;`
`202`		`- void to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels = {}) const override;`
	`202`	`+ void to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels = {}) const override;`
`203`	`203`	`void update_topn_metrics(size_t topn_count, uint64_t percentile_threshold) override`
`204`	`204`	`{`
`205`	`205`	`_dns_topGeoLocECS.set_settings(topn_count, percentile_threshold);`
Original file line number	Diff line number	Diff line change
`@@ -840,11 +840,8 @@ void DnsMetricsBucket::to_prometheus(std::stringstream &out, Metric::LabelMap ad`
`840`	`840`	`}`
`841`	`841`	`}`
`842`	`842`
`843`		`-void DnsMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels) const`
	`843`	`+void DnsMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels) const`
`844`	`844`	`{`
`845`		`- auto start_ts = start_tstamp();`
`846`		`- auto end_ts = end_tstamp();`
`847`		`-`
`848`	`845`	`for (auto &dns : _dns) {`
`849`	`846`	`auto dir_labels = add_labels;`
`850`	`847`	`dir_labels["direction"] = _dir_str.at(dns.first);`
Original file line number	Diff line number	Diff line change
`@@ -362,7 +362,7 @@ class DnsMetricsBucket final : public visor::AbstractMetricsBucket`
`362`	`362`	`void specialized_merge(const AbstractMetricsBucket &other, Metric::Aggregate agg_operator) override;`
`363`	`363`	`void to_json(json &j) const override;`
`364`	`364`	`void to_prometheus(std::stringstream &out, Metric::LabelMap add_labels = {}) const override;`
`365`		`- void to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels = {}) const override;`
	`365`	`+ void to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels = {}) const override;`
`366`	`366`	`void update_topn_metrics(size_t topn_count, uint64_t percentile_threshold) override`
`367`	`367`	`{`
`368`	`368`	`_topn_count = topn_count;`
Original file line number	Diff line number	Diff line change
`@@ -885,11 +885,8 @@ void FlowMetricsBucket::to_prometheus(std::stringstream &out, Metric::LabelMap a`
`885`	`885`	`}`
`886`	`886`	`}`
`887`	`887`
`888`		`-void FlowMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, Metric::LabelMap add_labels) const`
	`888`	`+void FlowMetricsBucket::to_opentelemetry(metrics::v1::ScopeMetrics &scope, timespec &start_ts, timespec &end_ts, Metric::LabelMap add_labels) const`
`889`	`889`	`{`
`890`		`- auto start_ts = start_tstamp();`
`891`		`- auto end_ts = end_tstamp();`
`892`		`-`
`893`	`890`	`std::shared_lock r_lock(_mutex);`
`894`	`891`
`895`	`892`	`for (const auto &device : _devices_metrics) {`