aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/monlib/encode/prometheus
diff options
context:
space:
mode:
authorkbalakirev <kbalakirev@yandex-team.ru>2022-02-10 16:48:58 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:48:58 +0300
commit498a47e48d41e5ec64ee3aa622a76a80274f35bd (patch)
tree5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/monlib/encode/prometheus
parent1906a186042870fd03a12180acd1a6fcee045e42 (diff)
downloadydb-498a47e48d41e5ec64ee3aa622a76a80274f35bd.tar.gz
Restoring authorship annotation for <kbalakirev@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/monlib/encode/prometheus')
-rw-r--r--library/cpp/monlib/encode/prometheus/prometheus_encoder.cpp50
-rw-r--r--library/cpp/monlib/encode/prometheus/prometheus_encoder_ut.cpp36
2 files changed, 43 insertions, 43 deletions
diff --git a/library/cpp/monlib/encode/prometheus/prometheus_encoder.cpp b/library/cpp/monlib/encode/prometheus/prometheus_encoder.cpp
index f77c4a3137..15efeb8c03 100644
--- a/library/cpp/monlib/encode/prometheus/prometheus_encoder.cpp
+++ b/library/cpp/monlib/encode/prometheus/prometheus_encoder.cpp
@@ -45,11 +45,11 @@ namespace NMonitoring {
case EMetricType::HIST_RATE:
Out_->Write("histogram");
break;
- case EMetricType::LOGHIST:
- // TODO(@kbalakirev): implement this case
- break;
+ case EMetricType::LOGHIST:
+ // TODO(@kbalakirev): implement this case
+ break;
case EMetricType::DSUMMARY:
- ythrow yexception() << "writing summary type is forbiden";
+ ythrow yexception() << "writing summary type is forbiden";
case EMetricType::UNKNOWN:
ythrow yexception() << "unknown metric type: " << MetricTypeToStr(type)
<< ", name: " << name;
@@ -90,14 +90,14 @@ namespace NMonitoring {
WriteValue(name, NPrometheus::COUNT_SUFFIX, labels, "", "", time, totalCount);
}
- void WriteSummaryDouble(TStringBuf name, const TLabels& labels, TInstant time, ISummaryDoubleSnapshot* s) {
- WriteValue(name, NPrometheus::SUM_SUFFIX, labels, "", "", time, s->GetSum());
- WriteValue(name, NPrometheus::MIN_SUFFIX, labels, "", "", time, s->GetMin());
- WriteValue(name, NPrometheus::MAX_SUFFIX, labels, "", "", time, s->GetMax());
- WriteValue(name, NPrometheus::LAST_SUFFIX, labels, "", "", time, s->GetLast());
- WriteValue(name, NPrometheus::COUNT_SUFFIX, labels, "", "", time, s->GetCount());
- }
-
+ void WriteSummaryDouble(TStringBuf name, const TLabels& labels, TInstant time, ISummaryDoubleSnapshot* s) {
+ WriteValue(name, NPrometheus::SUM_SUFFIX, labels, "", "", time, s->GetSum());
+ WriteValue(name, NPrometheus::MIN_SUFFIX, labels, "", "", time, s->GetMin());
+ WriteValue(name, NPrometheus::MAX_SUFFIX, labels, "", "", time, s->GetMax());
+ WriteValue(name, NPrometheus::LAST_SUFFIX, labels, "", "", time, s->GetLast());
+ WriteValue(name, NPrometheus::COUNT_SUFFIX, labels, "", "", time, s->GetCount());
+ }
+
void WriteLn() {
Out_->Write('\n');
}
@@ -220,7 +220,7 @@ namespace NMonitoring {
if (ValueType == EMetricValueType::HISTOGRAM) {
Value.AsHistogram()->UnRef();
} else if (ValueType == EMetricValueType::SUMMARY) {
- Value.AsSummaryDouble()->UnRef();
+ Value.AsSummaryDouble()->UnRef();
}
ValueType = EMetricValueType::UNKNOWN;
Value = {};
@@ -232,14 +232,14 @@ namespace NMonitoring {
if (ValueType == EMetricValueType::HISTOGRAM) {
Value.AsHistogram()->UnRef();
} else if (ValueType == EMetricValueType::SUMMARY) {
- Value.AsSummaryDouble()->UnRef();
+ Value.AsSummaryDouble()->UnRef();
}
ValueType = TValueType<T>::Type;
Value = TMetricValue(value);
if (ValueType == EMetricValueType::HISTOGRAM) {
Value.AsHistogram()->Ref();
} else if (ValueType == EMetricValueType::SUMMARY) {
- Value.AsSummaryDouble()->Ref();
+ Value.AsSummaryDouble()->Ref();
}
}
};
@@ -335,16 +335,16 @@ namespace NMonitoring {
MetricState_.SetValue(snapshot.Get());
}
- void OnSummaryDouble(TInstant time, ISummaryDoubleSnapshotPtr snapshot) override {
+ void OnSummaryDouble(TInstant time, ISummaryDoubleSnapshotPtr snapshot) override {
State_.Expect(TEncoderState::EState::METRIC);
MetricState_.Time = time;
MetricState_.SetValue(snapshot.Get());
- }
-
- void OnLogHistogram(TInstant, TLogHistogramSnapshotPtr) override {
- // TODO(@kbalakirev): implement this function
- }
-
+ }
+
+ void OnLogHistogram(TInstant, TLogHistogramSnapshotPtr) override {
+ // TODO(@kbalakirev): implement this function
+ }
+
void Close() override {
}
@@ -366,7 +366,7 @@ namespace NMonitoring {
const TString& metricName = ToString(nameLabel->Value());
if (MetricState_.Type != EMetricType::DSUMMARY) {
Writer_.WriteType(MetricState_.Type, metricName);
- }
+ }
if (MetricState_.Time == TInstant::Zero()) {
MetricState_.Time = CommonTime_;
@@ -382,8 +382,8 @@ namespace NMonitoring {
MetricState_.Time,
MetricState_.Value.AsHistogram());
} else if (type == EMetricType::DSUMMARY) {
- Writer_.WriteSummaryDouble(
- metricName,
+ Writer_.WriteSummaryDouble(
+ metricName,
MetricState_.Labels,
MetricState_.Time,
MetricState_.Value.AsSummaryDouble());
diff --git a/library/cpp/monlib/encode/prometheus/prometheus_encoder_ut.cpp b/library/cpp/monlib/encode/prometheus/prometheus_encoder_ut.cpp
index 562dec43cd..fd9debb060 100644
--- a/library/cpp/monlib/encode/prometheus/prometheus_encoder_ut.cpp
+++ b/library/cpp/monlib/encode/prometheus/prometheus_encoder_ut.cpp
@@ -20,10 +20,10 @@ Y_UNIT_TEST_SUITE(TPrometheusEncoderTest) {
return ss.Str();
}
- ISummaryDoubleSnapshotPtr TestSummaryDouble() {
- return MakeIntrusive<TSummaryDoubleSnapshot>(10.1, -0.45, 0.478, 0.3, 30u);
- }
-
+ ISummaryDoubleSnapshotPtr TestSummaryDouble() {
+ return MakeIntrusive<TSummaryDoubleSnapshot>(10.1, -0.45, 0.478, 0.3, 30u);
+ }
+
Y_UNIT_TEST(Empty) {
auto result = EncodeToString([](IMetricEncoder* e) {
e->OnStreamBegin();
@@ -112,17 +112,17 @@ Y_UNIT_TEST_SUITE(TPrometheusEncoderTest) {
e->OnDouble(TInstant::Zero(), INFINITY);
e->OnMetricEnd();
}
- {
+ {
e->OnMetricBegin(EMetricType::DSUMMARY);
- {
- e->OnLabelsBegin();
- e->OnLabel("sensor", "seconds");
- e->OnLabel("disk", "sdb1");
- e->OnLabelsEnd();
- }
- e->OnSummaryDouble(TInstant::Zero(), TestSummaryDouble());
+ {
+ e->OnLabelsBegin();
+ e->OnLabel("sensor", "seconds");
+ e->OnLabel("disk", "sdb1");
+ e->OnLabelsEnd();
+ }
+ e->OnSummaryDouble(TInstant::Zero(), TestSummaryDouble());
e->OnMetricEnd();
- }
+ }
e->OnStreamEnd();
});
@@ -138,11 +138,11 @@ Y_UNIT_TEST_SUITE(TPrometheusEncoderTest) {
"nanValue nan\n"
"# TYPE infValue gauge\n"
"infValue inf\n"
- "seconds_sum{disk=\"sdb1\", } 10.1\n"
- "seconds_min{disk=\"sdb1\", } -0.45\n"
- "seconds_max{disk=\"sdb1\", } 0.478\n"
- "seconds_last{disk=\"sdb1\", } 0.3\n"
- "seconds_count{disk=\"sdb1\", } 30\n"
+ "seconds_sum{disk=\"sdb1\", } 10.1\n"
+ "seconds_min{disk=\"sdb1\", } -0.45\n"
+ "seconds_max{disk=\"sdb1\", } 0.478\n"
+ "seconds_last{disk=\"sdb1\", } 0.3\n"
+ "seconds_count{disk=\"sdb1\", } 30\n"
"\n");
}