histogram_aggregator.hpp

Go to the documentation of this file.

#pragma once
 
#include <memory>
 
#include <userver/utils/span.hpp>
#include <userver/utils/statistics/fwd.hpp>
#include <userver/utils/statistics/histogram_view.hpp>
 
/// @file userver/utils/statistics/histogram_aggregator.hpp
/// @brief @copybrief utils::statistics::HistogramAggregator
 
USERVER_NAMESPACE_BEGIN
 
namespace utils::statistics {
 
/// @brief Used to aggregate multiple utils::statistics::Histogram metrics.
///
/// Usage example:
/// @snippet utils/statistics/histogram_test.cpp  HistogramAggregator
class HistogramAggregator final {
public:
    explicit HistogramAggregator(utils::span<const double> upper_bounds);
 
    HistogramAggregator(HistogramAggregator&&) noexcept;
    HistogramAggregator& operator=(HistogramAggregator&&) noexcept;
    ~HistogramAggregator();
 
    /// @brief Add the other histogram to the current one.
    ///
    /// Bucket borders in `this` and `other` must be either identical, or bucket
    /// borders in `this` must be a strict subset of bucket borders in `other`.
    ///
    /// Writes to `*this` are non-atomic.
    void Add(HistogramView other);
 
    /// Non-atomically increment the bucket corresponding to the given index.
    void AccountAt(std::size_t bucket_index, std::uint64_t count = 1) noexcept;
 
    /// Non-atomically increment the "infinity" bucket.
    void AccountInf(std::uint64_t count = 1) noexcept;
 
    /// Reset all buckets to zero.
    void Reset() noexcept;
 
    /// Allows reading the histogram.
    HistogramView GetView() const& noexcept;
 
    /// @cond
    // Store Histogram in a variable before taking a view on it.
    HistogramView GetView() && noexcept = delete;
    /// @endcond
 
private:
    std::unique_ptr<impl::histogram::Bucket[]> buckets_;
};
 
/// Metric serialization support for HistogramAggregator.
void DumpMetric(Writer& writer, const HistogramAggregator& histogram);
 
}  // namespace utils::statistics
 
USERVER_NAMESPACE_END