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
55
56
57
58
59
60
61
62
63
64
65
66
67
68
|
#include "histogram_collector.h"
#include "atomics_array.h"
#include <util/generic/algorithm.h>
#include <util/generic/vector.h>
#include <util/generic/yexception.h>
#include <util/generic/ylimits.h>
namespace NMonitoring {
///////////////////////////////////////////////////////////////////////////
// TExponentialHistogramCollector
///////////////////////////////////////////////////////////////////////////
class TExponentialHistogramCollector: public IHistogramCollector {
public:
TExponentialHistogramCollector(ui32 bucketsCount, double base, double scale)
: Values_(bucketsCount)
, Base_(base)
, Scale_(scale)
, MinValue_(scale)
, MaxValue_(scale * std::pow(base, bucketsCount - 2))
, LogOfBase_(std::log(base))
{
}
void Collect(double value, ui64 count) noexcept override {
ui32 index = Max<ui32>();
if (value <= MinValue_) {
index = 0;
} else if (value > MaxValue_) {
index = Values_.Size() - 1;
} else {
double logBase = std::log(value / Scale_) / LogOfBase_;
index = static_cast<ui32>(std::ceil(logBase));
}
Values_.Add(index, count);
}
void Reset() noexcept override {
Values_.Reset();
}
IHistogramSnapshotPtr Snapshot() const override {
return new TExponentialHistogramSnapshot(Base_, Scale_, Values_.Copy());
}
private:
TAtomicsArray Values_;
double Base_;
double Scale_;
TBucketBound MinValue_;
TBucketBound MaxValue_;
double LogOfBase_;
};
IHistogramCollectorPtr ExponentialHistogram(
ui32 bucketsCount, double base, double scale)
{
Y_ENSURE(bucketsCount >= 2,
"exponential histogram must contain at least two buckets");
Y_ENSURE(bucketsCount <= HISTOGRAM_MAX_BUCKETS_COUNT,
"buckets count must be <=" << HISTOGRAM_MAX_BUCKETS_COUNT
<< ", but got: " << bucketsCount);
Y_ENSURE(base > 1.0, "base must be > 1.0, got: " << base);
Y_ENSURE(scale >= 1.0, "scale must be >= 1.0, got: " << scale);
return MakeHolder<TExponentialHistogramCollector>(bucketsCount, base, scale);
}
}
|
