aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/monlib/service/pages/registry_mon_page.cpp
diff options
context:
space:
mode:
authormsherbakov <msherbakov@yandex-team.ru>2022-02-10 16:49:17 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:49:17 +0300
commita0ffafe83b7d6229709a32fa942c71d672ac989c (patch)
tree5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/monlib/service/pages/registry_mon_page.cpp
parentc224a621661ddd69699f9476922eb316607ef57e (diff)
downloadydb-a0ffafe83b7d6229709a32fa942c71d672ac989c.tar.gz
Restoring authorship annotation for <msherbakov@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/monlib/service/pages/registry_mon_page.cpp')
-rw-r--r--library/cpp/monlib/service/pages/registry_mon_page.cpp48
1 files changed, 24 insertions, 24 deletions
diff --git a/library/cpp/monlib/service/pages/registry_mon_page.cpp b/library/cpp/monlib/service/pages/registry_mon_page.cpp
index c47668391f..c59e50f622 100644
--- a/library/cpp/monlib/service/pages/registry_mon_page.cpp
+++ b/library/cpp/monlib/service/pages/registry_mon_page.cpp
@@ -1,46 +1,46 @@
-#include "registry_mon_page.h"
-
+#include "registry_mon_page.h"
+
#include <library/cpp/monlib/encode/text/text.h>
#include <library/cpp/monlib/encode/json/json.h>
#include <library/cpp/monlib/encode/prometheus/prometheus.h>
#include <library/cpp/monlib/encode/spack/spack_v1.h>
#include <library/cpp/monlib/service/format.h>
-
-namespace NMonitoring {
+
+namespace NMonitoring {
void TMetricRegistryPage::Output(NMonitoring::IMonHttpRequest& request) {
- const auto formatStr = TStringBuf{request.GetPathInfo()}.RNextTok('/');
- auto& out = request.Output();
-
+ const auto formatStr = TStringBuf{request.GetPathInfo()}.RNextTok('/');
+ auto& out = request.Output();
+
if (!formatStr.empty()) {
IMetricEncoderPtr encoder;
- TString resp;
-
+ TString resp;
+
if (formatStr == TStringBuf("json")) {
- resp = HTTPOKJSON;
- encoder = NMonitoring::EncoderJson(&out);
+ resp = HTTPOKJSON;
+ encoder = NMonitoring::EncoderJson(&out);
} else if (formatStr == TStringBuf("spack")) {
- resp = HTTPOKSPACK;
+ resp = HTTPOKSPACK;
const auto compression = ParseCompression(request);
encoder = NMonitoring::EncoderSpackV1(&out, ETimePrecision::SECONDS, compression);
} else if (formatStr == TStringBuf("prometheus")) {
resp = HTTPOKPROMETHEUS;
encoder = NMonitoring::EncoderPrometheus(&out);
- } else {
+ } else {
ythrow yexception() << "unsupported metric encoding format: " << formatStr;
- }
-
- out.Write(resp);
+ }
+
+ out.Write(resp);
RegistryRawPtr_->Accept(TInstant::Zero(), encoder.Get());
encoder->Close();
- } else {
- THtmlMonPage::Output(request);
- }
- }
-
+ } else {
+ THtmlMonPage::Output(request);
+ }
+ }
+
void TMetricRegistryPage::OutputText(IOutputStream& out, NMonitoring::IMonHttpRequest&) {
IMetricEncoderPtr encoder = NMonitoring::EncoderText(&out);
RegistryRawPtr_->Accept(TInstant::Zero(), encoder.Get());
- }
-
-}
+ }
+
+}