metrics_service.hpp

Go to the documentation of this file.

#pragma once
 
#include <prometheus/exposer.h>
#include <prometheus/gauge.h>
#include <prometheus/registry.h>
 
#include <thread>
 
#include "metrics/metrics_group.hpp"
 
namespace taraxa::metrics {
 
class MetricsService {
 public:
  MetricsService(const std::string& host, uint16_t port, uint16_t polling_interval_ms);
  ~MetricsService();
 
  void start();
 
  template <class T>
  std::shared_ptr<T> getMetrics() {
    if (!exposer_) {
      return nullptr;
    }
    auto metrics = metrics_.find(T::group_name);
    if (metrics == metrics_.end()) {
      auto emplace_result = metrics_.emplace(T::group_name, std::make_shared<T>(registry_)).first;
      metrics = emplace_result;
    }
    return dynamic_pointer_cast<T>(metrics->second);
  }
 
 private:
  const uint16_t kPollingIntervalMs = 0;
  std::unique_ptr<prometheus::Exposer> exposer_;
  std::shared_ptr<prometheus::Registry> registry_;
  std::map<std::string, SharedMetricsGroup> metrics_;
  std::unique_ptr<std::thread> thread_;
};
}  // namespace taraxa::metrics