Performance.cpp

Go to the documentation of this file.

#include "metrics/Performance.hpp"
 
#include <format>
 
#include <prometheus/gauge.h>
#include <prometheus/summary.h>
 
#define QUANTILE_DEFAULTS                                                                                              \
    prometheus::Summary::Quantiles { {0.5, 0.1}, {0.9, 0.1}, {0.99, 0.1} }
 
PerformanceTracker::PerformanceTracker(const std::shared_ptr<prometheus::Registry> &reg, const std::string &name,
                                       uint64_t metricID)
{
    _perfTiming = &prometheus::BuildSummary()
                       .Name(std::format("{}{}{}", name, "_processing_time_", metricID))
                       .Help(name + " processing performance")
                       .Register(*reg)
                       .Add({}, QUANTILE_DEFAULTS);
    _maxTiming = &prometheus::BuildGauge()
                      .Name(std::format("{}{}{}", name, "_maximum_processing_time_", metricID))
                      .Help("Maximum value of the " + name + " processing performance")
                      .Register(*reg)
                      .Add({});
    _minTiming = &prometheus::BuildGauge()
                      .Name(std::format("{}{}{}", name, "_minimum_processing_time_", metricID))
                      .Help("Minimum value of the " + name + " processing performance")
                      .Register(*reg)
                      .Add({});
 
    _minTiming->Set(std::numeric_limits<int>::max());
}
 
void PerformanceTracker::startTimer() { _startTime = std::chrono::high_resolution_clock::now(); }
 
double PerformanceTracker::endTimer()
{
    const auto val = static_cast<double>((std::chrono::high_resolution_clock::now() - _startTime).count());
 
    _perfTiming->Observe(val);
    if (val < _minTiming->Value())
    {
        _minTiming->Set(val);
    }
    if (val > _maxTiming->Value())
    {
        _maxTiming->Set(val);
    }
 
    return val;
}