jupp0r / prometheus-cpp / 4192383612

#pragma once

#include <chrono>

#include <cstddef>

#include <vector>

#include "prometheus/detail/ckms_quantiles.h"  // IWYU pragma: export

#include "prometheus/detail/core_export.h"

// IWYU pragma: private, include "prometheus/summary.h"

namespace prometheus {

namespace detail {

class PROMETHEUS_CPP_CORE_EXPORT TimeWindowQuantiles {

  using Clock = std::chrono::steady_clock;

 public:

  TimeWindowQuantiles(const std::vector<CKMSQuantiles::Quantile>& quantiles,

                      Clock::duration max_age_seconds, int age_buckets);

  double get(double q) const;

  void insert(double value);

 private:

  CKMSQuantiles& rotate() const;

  const std::vector<CKMSQuantiles::Quantile>& quantiles_;

  mutable std::vector<CKMSQuantiles> ckms_quantiles_;

  mutable std::size_t current_bucket_;

  mutable Clock::time_point last_rotation_;

  const Clock::duration rotation_interval_;

};

}  // namespace detail

}  // namespace prometheus