aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/monlib/metrics
diff options
context:
space:
mode:
authordanibw <danibw@yandex-team.ru>2022-02-10 16:50:12 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:50:12 +0300
commite8fdd1e6c0645bf1702aaf85cc7460dbd09977cb (patch)
treed96a47e62e16b199f4ffbf41f6848e9fad7dfa21 /library/cpp/monlib/metrics
parentdf6eb5b163c763cd9633a4850cfae72f8d742996 (diff)
downloadydb-e8fdd1e6c0645bf1702aaf85cc7460dbd09977cb.tar.gz
Restoring authorship annotation for <danibw@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/monlib/metrics')
-rw-r--r--library/cpp/monlib/metrics/atomics_array.h12
-rw-r--r--library/cpp/monlib/metrics/histogram_collector.h10
-rw-r--r--library/cpp/monlib/metrics/histogram_collector_explicit.cpp8
-rw-r--r--library/cpp/monlib/metrics/histogram_collector_exponential.cpp8
-rw-r--r--library/cpp/monlib/metrics/histogram_collector_linear.cpp8
-rw-r--r--library/cpp/monlib/metrics/metric.h4
-rw-r--r--library/cpp/monlib/metrics/metric_registry.cpp56
-rw-r--r--library/cpp/monlib/metrics/metric_registry.h4
8 files changed, 55 insertions, 55 deletions
diff --git a/library/cpp/monlib/metrics/atomics_array.h b/library/cpp/monlib/metrics/atomics_array.h
index f19aebf291..e044f14b00 100644
--- a/library/cpp/monlib/metrics/atomics_array.h
+++ b/library/cpp/monlib/metrics/atomics_array.h
@@ -31,12 +31,12 @@ namespace NMonitoring {
Values_[index].fetch_add(count, std::memory_order_relaxed);
}
- void Reset() noexcept {
- for (size_t i = 0; i < Size_; i++) {
- Values_[i].store(0, std::memory_order_relaxed);
- }
- }
-
+ void Reset() noexcept {
+ for (size_t i = 0; i < Size_; i++) {
+ Values_[i].store(0, std::memory_order_relaxed);
+ }
+ }
+
TVector<ui64> Copy() const {
TVector<ui64> copy(Reserve(Size_));
for (size_t i = 0; i < Size_; i++) {
diff --git a/library/cpp/monlib/metrics/histogram_collector.h b/library/cpp/monlib/metrics/histogram_collector.h
index 9f6bbbdfb7..5afbf63c8e 100644
--- a/library/cpp/monlib/metrics/histogram_collector.h
+++ b/library/cpp/monlib/metrics/histogram_collector.h
@@ -33,11 +33,11 @@ namespace NMonitoring {
}
/**
- * Reset collector values
- */
- virtual void Reset() = 0;
-
- /**
+ * Reset collector values
+ */
+ virtual void Reset() = 0;
+
+ /**
* @return snapshot of the state of this collector.
*/
virtual IHistogramSnapshotPtr Snapshot() const = 0;
diff --git a/library/cpp/monlib/metrics/histogram_collector_explicit.cpp b/library/cpp/monlib/metrics/histogram_collector_explicit.cpp
index 377fc233ef..7684468a2d 100644
--- a/library/cpp/monlib/metrics/histogram_collector_explicit.cpp
+++ b/library/cpp/monlib/metrics/histogram_collector_explicit.cpp
@@ -27,10 +27,10 @@ namespace NMonitoring {
Values_.Add(index, count);
}
- void Reset() override {
- Values_.Reset();
- }
-
+ void Reset() override {
+ Values_.Reset();
+ }
+
IHistogramSnapshotPtr Snapshot() const override {
auto values = Values_.Copy();
return ExplicitHistogramSnapshot(Bounds_, values);
diff --git a/library/cpp/monlib/metrics/histogram_collector_exponential.cpp b/library/cpp/monlib/metrics/histogram_collector_exponential.cpp
index 2f8a50a5f9..e4dc327dff 100644
--- a/library/cpp/monlib/metrics/histogram_collector_exponential.cpp
+++ b/library/cpp/monlib/metrics/histogram_collector_exponential.cpp
@@ -35,10 +35,10 @@ namespace NMonitoring {
Values_.Add(index, count);
}
- void Reset() override {
- Values_.Reset();
- }
-
+ void Reset() override {
+ Values_.Reset();
+ }
+
IHistogramSnapshotPtr Snapshot() const override {
return new TExponentialHistogramSnapshot(Base_, Scale_, Values_.Copy());
}
diff --git a/library/cpp/monlib/metrics/histogram_collector_linear.cpp b/library/cpp/monlib/metrics/histogram_collector_linear.cpp
index f8ad86f3a4..8cd6aafcb7 100644
--- a/library/cpp/monlib/metrics/histogram_collector_linear.cpp
+++ b/library/cpp/monlib/metrics/histogram_collector_linear.cpp
@@ -36,10 +36,10 @@ namespace NMonitoring {
Values_.Add(index, count);
}
- void Reset() override {
- Values_.Reset();
- }
-
+ void Reset() override {
+ Values_.Reset();
+ }
+
IHistogramSnapshotPtr Snapshot() const override {
return new TLinearHistogramSnapshot(
StartValue_, BucketWidth_, Values_.Copy());
diff --git a/library/cpp/monlib/metrics/metric.h b/library/cpp/monlib/metrics/metric.h
index b8ce12d753..725d4fecef 100644
--- a/library/cpp/monlib/metrics/metric.h
+++ b/library/cpp/monlib/metrics/metric.h
@@ -379,8 +379,8 @@ namespace NMonitoring {
}
void Reset() override {
- Collector_->Reset();
- }
+ Collector_->Reset();
+ }
private:
IHistogramCollectorPtr Collector_;
diff --git a/library/cpp/monlib/metrics/metric_registry.cpp b/library/cpp/monlib/metrics/metric_registry.cpp
index b083163a7b..d1bb063aab 100644
--- a/library/cpp/monlib/metrics/metric_registry.cpp
+++ b/library/cpp/monlib/metrics/metric_registry.cpp
@@ -124,34 +124,34 @@ namespace NMonitoring {
return Metric<THistogram, EMetricType::HIST_RATE>(std::move(labels), std::move(collector), true);
}
- void TMetricRegistry::Reset() {
- TWriteGuard g{Lock_};
- for (auto& [label, metric] : Metrics_) {
- switch (metric->Type()) {
- case EMetricType::GAUGE:
- static_cast<TGauge*>(metric.Get())->Set(.0);
- break;
- case EMetricType::IGAUGE:
- static_cast<TIntGauge*>(metric.Get())->Set(0);
- break;
- case EMetricType::COUNTER:
- static_cast<TCounter*>(metric.Get())->Reset();
- break;
- case EMetricType::RATE:
- static_cast<TRate*>(metric.Get())->Reset();
- break;
- case EMetricType::HIST:
- case EMetricType::HIST_RATE:
- static_cast<THistogram*>(metric.Get())->Reset();
- break;
- case EMetricType::UNKNOWN:
- case EMetricType::DSUMMARY:
- case EMetricType::LOGHIST:
- break;
- }
- }
- }
-
+ void TMetricRegistry::Reset() {
+ TWriteGuard g{Lock_};
+ for (auto& [label, metric] : Metrics_) {
+ switch (metric->Type()) {
+ case EMetricType::GAUGE:
+ static_cast<TGauge*>(metric.Get())->Set(.0);
+ break;
+ case EMetricType::IGAUGE:
+ static_cast<TIntGauge*>(metric.Get())->Set(0);
+ break;
+ case EMetricType::COUNTER:
+ static_cast<TCounter*>(metric.Get())->Reset();
+ break;
+ case EMetricType::RATE:
+ static_cast<TRate*>(metric.Get())->Reset();
+ break;
+ case EMetricType::HIST:
+ case EMetricType::HIST_RATE:
+ static_cast<THistogram*>(metric.Get())->Reset();
+ break;
+ case EMetricType::UNKNOWN:
+ case EMetricType::DSUMMARY:
+ case EMetricType::LOGHIST:
+ break;
+ }
+ }
+ }
+
void TMetricRegistry::Clear() {
TWriteGuard g{Lock_};
Metrics_.clear();
diff --git a/library/cpp/monlib/metrics/metric_registry.h b/library/cpp/monlib/metrics/metric_registry.h
index 670cf8651e..ade57cfef3 100644
--- a/library/cpp/monlib/metrics/metric_registry.h
+++ b/library/cpp/monlib/metrics/metric_registry.h
@@ -82,12 +82,12 @@ namespace NMonitoring {
/**
* Set all registered metrics to zero
*/
- void Reset();
+ 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;