1 files changed, 259 insertions, 0 deletions
diff --git a/src/jaegertracing/opentelemetry-cpp/sdk/src/metrics/meter.cc b/src/jaegertracing/opentelemetry-cpp/sdk/src/metrics/meter.cc
new file mode 100644
index 000000000..600bae986
--- /dev/null
+++ b/src/jaegertracing/opentelemetry-cpp/sdk/src/metrics/meter.cc
@@ -0,0 +1,259 @@
+// Copyright The OpenTelemetry Authors
+// SPDX-License-Identifier: Apache-2.0
+
+#ifndef ENABLE_METRICS_PREVIEW
+#  include "opentelemetry/sdk/metrics/meter.h"
+#  include "opentelemetry/metrics/noop.h"
+#  include "opentelemetry/nostd/shared_ptr.h"
+#  include "opentelemetry/sdk/metrics/async_instruments.h"
+#  include "opentelemetry/sdk/metrics/exemplar/no_exemplar_reservoir.h"
+#  include "opentelemetry/sdk/metrics/state/multi_metric_storage.h"
+#  include "opentelemetry/sdk/metrics/state/sync_metric_storage.h"
+#  include "opentelemetry/sdk/metrics/sync_instruments.h"
+#  include "opentelemetry/sdk_config.h"
+
+#  include "opentelemetry/version.h"
+
+#  include <memory>
+
+OPENTELEMETRY_BEGIN_NAMESPACE
+namespace sdk
+{
+namespace metrics
+{
+
+namespace metrics = opentelemetry::metrics;
+namespace nostd   = opentelemetry::nostd;
+
+Meter::Meter(std::shared_ptr<MeterContext> meter_context,
+             std::unique_ptr<sdk::instrumentationlibrary::InstrumentationLibrary>
+                 instrumentation_library) noexcept
+    : instrumentation_library_{std::move(instrumentation_library)}, meter_context_{meter_context}
+{}
+
+nostd::shared_ptr<metrics::Counter<long>> Meter::CreateLongCounter(nostd::string_view name,
+                                                                   nostd::string_view description,
+                                                                   nostd::string_view unit) noexcept
+{
+  InstrumentDescriptor instrument_descriptor = {
+      std::string{name.data(), name.size()}, std::string{description.data(), description.size()},
+      std::string{unit.data(), unit.size()}, InstrumentType::kCounter, InstrumentValueType::kLong};
+  auto storage = RegisterMetricStorage(instrument_descriptor);
+  return nostd::shared_ptr<metrics::Counter<long>>(
+      new LongCounter(instrument_descriptor, std::move(storage)));
+}
+
+nostd::shared_ptr<metrics::Counter<double>> Meter::CreateDoubleCounter(
+    nostd::string_view name,
+    nostd::string_view description,
+    nostd::string_view unit) noexcept
+{
+  InstrumentDescriptor instrument_descriptor = {
+      std::string{name.data(), name.size()}, std::string{description.data(), description.size()},
+      std::string{unit.data(), unit.size()}, InstrumentType::kCounter,
+      InstrumentValueType::kDouble};
+  auto storage = RegisterMetricStorage(instrument_descriptor);
+  return nostd::shared_ptr<metrics::Counter<double>>{
+      new DoubleCounter(instrument_descriptor, std::move(storage))};
+}
+
+void Meter::CreateLongObservableCounter(nostd::string_view name,
+                                        void (*callback)(metrics::ObserverResult<long> &, void *),
+                                        nostd::string_view description,
+                                        nostd::string_view unit,
+                                        void *state) noexcept
+{
+  InstrumentDescriptor instrument_descriptor = {
+      std::string{name.data(), name.size()}, std::string{description.data(), description.size()},
+      std::string{unit.data(), unit.size()}, InstrumentType::kObservableCounter,
+      InstrumentValueType::kLong};
+  RegisterAsyncMetricStorage<long>(instrument_descriptor, callback, state);
+}
+
+void Meter::CreateDoubleObservableCounter(nostd::string_view name,
+                                          void (*callback)(metrics::ObserverResult<double> &,
+                                                           void *),
+                                          nostd::string_view description,
+                                          nostd::string_view unit,
+                                          void *state) noexcept
+{
+  InstrumentDescriptor instrument_descriptor = {
+      std::string{name.data(), name.size()}, std::string{description.data(), description.size()},
+      std::string{unit.data(), unit.size()}, InstrumentType::kObservableCounter,
+      InstrumentValueType::kDouble};
+  RegisterAsyncMetricStorage<double>(instrument_descriptor, callback, state);
+}
+
+nostd::shared_ptr<metrics::Histogram<long>> Meter::CreateLongHistogram(
+    nostd::string_view name,
+    nostd::string_view description,
+    nostd::string_view unit) noexcept
+{
+  InstrumentDescriptor instrument_descriptor = {
+      std::string{name.data(), name.size()}, std::string{description.data(), description.size()},
+      std::string{unit.data(), unit.size()}, InstrumentType::kHistogram,
+      InstrumentValueType::kLong};
+  auto storage = RegisterMetricStorage(instrument_descriptor);
+  return nostd::shared_ptr<metrics::Histogram<long>>{
+      new LongHistogram(instrument_descriptor, std::move(storage))};
+}
+
+nostd::shared_ptr<metrics::Histogram<double>> Meter::CreateDoubleHistogram(
+    nostd::string_view name,
+    nostd::string_view description,
+    nostd::string_view unit) noexcept
+{
+  InstrumentDescriptor instrument_descriptor = {
+      std::string{name.data(), name.size()}, std::string{description.data(), description.size()},
+      std::string{unit.data(), unit.size()}, InstrumentType::kHistogram,
+      InstrumentValueType::kDouble};
+  auto storage = RegisterMetricStorage(instrument_descriptor);
+  return nostd::shared_ptr<metrics::Histogram<double>>{
+      new DoubleHistogram(instrument_descriptor, std::move(storage))};
+}
+
+void Meter::CreateLongObservableGauge(nostd::string_view name,
+                                      void (*callback)(metrics::ObserverResult<long> &, void *),
+                                      nostd::string_view description,
+                                      nostd::string_view unit,
+                                      void *state) noexcept
+{
+  InstrumentDescriptor instrument_descriptor = {
+      std::string{name.data(), name.size()}, std::string{description.data(), description.size()},
+      std::string{unit.data(), unit.size()}, InstrumentType::kObservableGauge,
+      InstrumentValueType::kLong};
+  RegisterAsyncMetricStorage<long>(instrument_descriptor, callback, state);
+}
+
+void Meter::CreateDoubleObservableGauge(nostd::string_view name,
+                                        void (*callback)(metrics::ObserverResult<double> &, void *),
+                                        nostd::string_view description,
+                                        nostd::string_view unit,
+                                        void *state) noexcept
+{
+  InstrumentDescriptor instrument_descriptor = {
+      std::string{name.data(), name.size()}, std::string{description.data(), description.size()},
+      std::string{unit.data(), unit.size()}, InstrumentType::kObservableGauge,
+      InstrumentValueType::kDouble};
+  RegisterAsyncMetricStorage<double>(instrument_descriptor, callback, state);
+}
+
+nostd::shared_ptr<metrics::UpDownCounter<long>> Meter::CreateLongUpDownCounter(
+    nostd::string_view name,
+    nostd::string_view description,
+    nostd::string_view unit) noexcept
+{
+  InstrumentDescriptor instrument_descriptor = {
+      std::string{name.data(), name.size()}, std::string{description.data(), description.size()},
+      std::string{unit.data(), unit.size()}, InstrumentType::kUpDownCounter,
+      InstrumentValueType::kLong};
+  auto storage = RegisterMetricStorage(instrument_descriptor);
+  return nostd::shared_ptr<metrics::UpDownCounter<long>>{
+      new LongUpDownCounter(instrument_descriptor, std::move(storage))};
+}
+
+nostd::shared_ptr<metrics::UpDownCounter<double>> Meter::CreateDoubleUpDownCounter(
+    nostd::string_view name,
+    nostd::string_view description,
+    nostd::string_view unit) noexcept
+{
+  InstrumentDescriptor instrument_descriptor = {
+      std::string{name.data(), name.size()}, std::string{description.data(), description.size()},
+      std::string{unit.data(), unit.size()}, InstrumentType::kUpDownCounter,
+      InstrumentValueType::kDouble};
+  auto storage = RegisterMetricStorage(instrument_descriptor);
+  return nostd::shared_ptr<metrics::UpDownCounter<double>>{
+      new DoubleUpDownCounter(instrument_descriptor, std::move(storage))};
+}
+
+void Meter::CreateLongObservableUpDownCounter(nostd::string_view name,
+                                              void (*callback)(metrics::ObserverResult<long> &,
+                                                               void *),
+                                              nostd::string_view description,
+                                              nostd::string_view unit,
+                                              void *state) noexcept
+{
+  InstrumentDescriptor instrument_descriptor = {
+      std::string{name.data(), name.size()}, std::string{description.data(), description.size()},
+      std::string{unit.data(), unit.size()}, InstrumentType::kObservableUpDownCounter,
+      InstrumentValueType::kLong};
+  RegisterAsyncMetricStorage<long>(instrument_descriptor, callback, state);
+}
+
+void Meter::CreateDoubleObservableUpDownCounter(nostd::string_view name,
+                                                void (*callback)(metrics::ObserverResult<double> &,
+                                                                 void *),
+                                                nostd::string_view description,
+                                                nostd::string_view unit,
+                                                void *state) noexcept
+{
+  InstrumentDescriptor instrument_descriptor = {
+      std::string{name.data(), name.size()}, std::string{description.data(), description.size()},
+      std::string{unit.data(), unit.size()}, InstrumentType::kObservableUpDownCounter,
+      InstrumentValueType::kDouble};
+  RegisterAsyncMetricStorage<double>(instrument_descriptor, callback, state);
+}
+
+const sdk::instrumentationlibrary::InstrumentationLibrary *Meter::GetInstrumentationLibrary()
+    const noexcept
+{
+  return instrumentation_library_.get();
+}
+
+std::unique_ptr<WritableMetricStorage> Meter::RegisterMetricStorage(
+    InstrumentDescriptor &instrument_descriptor)
+{
+  auto view_registry = meter_context_->GetViewRegistry();
+  std::unique_ptr<WritableMetricStorage> storages(new MultiMetricStorage());
+
+  auto success = view_registry->FindViews(
+      instrument_descriptor, *instrumentation_library_,
+      [this, &instrument_descriptor, &storages](const View &view) {
+        auto view_instr_desc = instrument_descriptor;
+        if (!view.GetName().empty())
+        {
+          view_instr_desc.name_ = view.GetName();
+        }
+        if (!view.GetDescription().empty())
+        {
+          view_instr_desc.description_ = view.GetDescription();
+        }
+        auto storage = std::shared_ptr<SyncMetricStorage>(new SyncMetricStorage(
+            view_instr_desc, view.GetAggregationType(), &view.GetAttributesProcessor(),
+            NoExemplarReservoir::GetNoExemplarReservoir()));
+        storage_registry_[instrument_descriptor.name_] = storage;
+        auto multi_storage = static_cast<MultiMetricStorage *>(storages.get());
+        multi_storage->AddStorage(storage);
+        return true;
+      });
+
+  if (!success)
+  {
+    OTEL_INTERNAL_LOG_ERROR(
+        "[Meter::RegisterMetricStorage] - Error during finding matching views."
+        << "Some of the matching view configurations mayn't be used for metric collection");
+  }
+  return storages;
+}
+
+/** collect metrics across all the meters **/
+std::vector<MetricData> Meter::Collect(CollectorHandle *collector,
+                                       opentelemetry::common::SystemTimestamp collect_ts) noexcept
+{
+  std::vector<MetricData> metric_data_list;
+  for (auto &metric_storage : storage_registry_)
+  {
+    metric_storage.second->Collect(collector, meter_context_->GetCollectors(),
+                                   meter_context_->GetSDKStartTime(), collect_ts,
+                                   [&metric_data_list](MetricData metric_data) {
+                                     metric_data_list.push_back(metric_data);
+                                     return true;
+                                   });
+  }
+  return metric_data_list;
+}
+
+}  // namespace metrics
+}  // namespace sdk
+OPENTELEMETRY_END_NAMESPACE
+#endif