diff options
| author | Devtools Arcadia <arcadia-devtools@yandex-team.ru> | 2022-02-07 18:08:42 +0300 |
|---|---|---|
| committer | Devtools Arcadia <arcadia-devtools@mous.vla.yp-c.yandex.net> | 2022-02-07 18:08:42 +0300 |
| commit | 1110808a9d39d4b808aef724c861a2e1a38d2a69 (patch) | |
| tree | e26c9fed0de5d9873cce7e00bc214573dc2195b7 /library/cpp/monlib/service/pages/registry_mon_page.cpp | |
| download | ydb-1110808a9d39d4b808aef724c861a2e1a38d2a69.tar.gz | |
intermediate changes
ref:cde9a383711a11544ce7e107a78147fb96cc4029
Diffstat (limited to 'library/cpp/monlib/service/pages/registry_mon_page.cpp')
| -rw-r--r-- | library/cpp/monlib/service/pages/registry_mon_page.cpp | 46 |
1 files changed, 46 insertions, 0 deletions
diff --git a/library/cpp/monlib/service/pages/registry_mon_page.cpp b/library/cpp/monlib/service/pages/registry_mon_page.cpp new file mode 100644 index 0000000000..c59e50f622 --- /dev/null +++ b/library/cpp/monlib/service/pages/registry_mon_page.cpp @@ -0,0 +1,46 @@ +#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 { + void TMetricRegistryPage::Output(NMonitoring::IMonHttpRequest& request) { + const auto formatStr = TStringBuf{request.GetPathInfo()}.RNextTok('/'); + auto& out = request.Output(); + + if (!formatStr.empty()) { + IMetricEncoderPtr encoder; + TString resp; + + if (formatStr == TStringBuf("json")) { + resp = HTTPOKJSON; + encoder = NMonitoring::EncoderJson(&out); + } else if (formatStr == TStringBuf("spack")) { + 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 { + ythrow yexception() << "unsupported metric encoding format: " << formatStr; + } + + out.Write(resp); + RegistryRawPtr_->Accept(TInstant::Zero(), encoder.Get()); + + encoder->Close(); + } else { + THtmlMonPage::Output(request); + } + } + + void TMetricRegistryPage::OutputText(IOutputStream& out, NMonitoring::IMonHttpRequest&) { + IMetricEncoderPtr encoder = NMonitoring::EncoderText(&out); + RegistryRawPtr_->Accept(TInstant::Zero(), encoder.Get()); + } + +} |