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
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
|
#pragma once
#include "labels.h"
#include "metric.h"
#include <util/system/rwlock.h>
#include <library/cpp/threading/light_rw_lock/lightrwlock.h>
namespace NMonitoring {
class IMetricFactory {
public:
virtual ~IMetricFactory() = default;
virtual IGauge* Gauge(ILabelsPtr labels) = 0;
virtual ILazyGauge* LazyGauge(ILabelsPtr labels, std::function<double()> supplier) = 0;
virtual IIntGauge* IntGauge(ILabelsPtr labels) = 0;
virtual ILazyIntGauge* LazyIntGauge(ILabelsPtr labels, std::function<i64()> supplier) = 0;
virtual ICounter* Counter(ILabelsPtr labels) = 0;
virtual ILazyCounter* LazyCounter(ILabelsPtr labels, std::function<ui64()> supplier) = 0;
virtual IRate* Rate(ILabelsPtr labels) = 0;
virtual ILazyRate* LazyRate(ILabelsPtr labels, std::function<ui64()> supplier) = 0;
virtual IHistogram* HistogramCounter(
ILabelsPtr labels,
IHistogramCollectorPtr collector) = 0;
virtual IHistogram* HistogramRate(
ILabelsPtr labels,
IHistogramCollectorPtr collector) = 0;
};
class IMetricSupplier {
public:
virtual ~IMetricSupplier() = default;
virtual void Accept(TInstant time, IMetricConsumer* consumer) const = 0;
virtual void Append(TInstant time, IMetricConsumer* consumer) const = 0;
};
class IMetricRegistry: public IMetricSupplier, public IMetricFactory {
public:
virtual const TLabels& CommonLabels() const noexcept = 0;
virtual void RemoveMetric(const ILabels& labels) noexcept = 0;
virtual bool HasMetric(const ILabels& labels) noexcept = 0;
};
///////////////////////////////////////////////////////////////////////////////
// TMetricRegistry
///////////////////////////////////////////////////////////////////////////////
class TMetricRegistry: public IMetricRegistry {
public:
TMetricRegistry();
~TMetricRegistry();
explicit TMetricRegistry(const TLabels& commonLabels);
/**
* Not thread-safe. There should be no concurrent operations in the registry.
*/
TMetricRegistry& operator=(TMetricRegistry&& other);
/**
* Get a global metrics registry instance.
*/
static TMetricRegistry* Instance();
static std::shared_ptr<TMetricRegistry> SharedInstance();
TGauge* Gauge(TLabels labels);
TLazyGauge* LazyGauge(TLabels labels, std::function<double()> supplier);
TIntGauge* IntGauge(TLabels labels);
TLazyIntGauge* LazyIntGauge(TLabels labels, std::function<i64()> supplier);
TCounter* Counter(TLabels labels);
TLazyCounter* LazyCounter(TLabels labels, std::function<ui64()> supplier);
TRate* Rate(TLabels labels);
TLazyRate* LazyRate(TLabels labels, std::function<ui64()> supplier);
THistogram* HistogramCounter(
TLabels labels,
IHistogramCollectorPtr collector);
THistogram* HistogramRate(
TLabels labels,
IHistogramCollectorPtr collector);
THistogram* HistogramCounter(
TLabels labels,
std::function<IHistogramCollectorPtr()> makeHistogramCollector);
THistogram* HistogramRate(
TLabels labels,
std::function<IHistogramCollectorPtr()> makeHistogramCollector);
THistogram* HistogramCounter(
TLabels labels,
nullptr_t);
THistogram* HistogramRate(
TLabels labels,
nullptr_t);
/**
* Set all registered metrics to zero
*/
void Reset();
/**
* Remove all registered metrics from registry
*/
void Clear();
void Accept(TInstant time, IMetricConsumer* consumer) const override;
void Append(TInstant time, IMetricConsumer* consumer) const override;
const TLabels& CommonLabels() const noexcept override {
return CommonLabels_;
}
void RemoveMetric(const ILabels& labels) noexcept override;
bool HasMetric(const ILabels &labels) noexcept override;
private:
TGauge* Gauge(ILabelsPtr labels) override;
TLazyGauge* LazyGauge(ILabelsPtr labels, std::function<double()> supplier) override;
TIntGauge* IntGauge(ILabelsPtr labels) override;
TLazyIntGauge* LazyIntGauge(ILabelsPtr labels, std::function<i64()> supplier) override;
TCounter* Counter(ILabelsPtr labels) override;
TLazyCounter* LazyCounter(ILabelsPtr labels, std::function<ui64()> supplier) override;
TRate* Rate(ILabelsPtr labels) override;
TLazyRate* LazyRate(ILabelsPtr labels, std::function<ui64()> supplier) override;
THistogram* HistogramCounter(
ILabelsPtr labels,
IHistogramCollectorPtr collector) override;
THistogram* HistogramRate(
ILabelsPtr labels,
IHistogramCollectorPtr collector) override;
private:
THolder<TRWMutex> Lock_ = MakeHolder<TRWMutex>();
THashMap<ILabelsPtr, IMetricPtr> Metrics_;
template <typename TMetric, EMetricType type, typename TLabelsType, typename... Args>
TMetric* Metric(TLabelsType&& labels, Args&&... args);
TLabels CommonLabels_;
};
void WriteLabels(IMetricConsumer* consumer, const ILabels& labels);
}
|
