1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54/**
* @file src/stat_trackers.h
* @brief Declarations for streaming statistic tracking.
*/
#pragma once
// standard includes
#include <chrono>
#include <functional>
#include <limits>
// lib includes
#include <boost/format.hpp>
namespace stat_trackers {
boost::format one_digit_after_decimal();
boost::format two_digits_after_decimal();
template<typename T>
class min_max_avg_tracker {
public:
using callback_function = std::function<void(T stat_min, T stat_max, double stat_avg)>;
void collect_and_callback_on_interval(T stat, const callback_function &callback, std::chrono::seconds interval_in_seconds) {
if (data.calls == 0) {
data.last_callback_time = std::chrono::steady_clock::now();
} else if (std::chrono::steady_clock::now() > data.last_callback_time + interval_in_seconds) {
callback(data.stat_min, data.stat_max, data.stat_total / data.calls);
data = {};
}
data.stat_min = std::min(data.stat_min, stat);
data.stat_max = std::max(data.stat_max, stat);
data.stat_total += stat;
data.calls += 1;
}
void reset() {
data = {};
}
private:
struct {
std::chrono::steady_clock::time_point last_callback_time = std::chrono::steady_clock::now();
T stat_min = std::numeric_limits<T>::max();
T stat_max = std::numeric_limits<T>::min();
double stat_total = 0;
uint32_t calls = 0;
} data;
};
} // namespace stat_trackers