aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/monlib/dynamic_counters/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/dynamic_counters/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/dynamic_counters/page.cpp')
-rw-r--r--library/cpp/monlib/dynamic_counters/page.cpp102
1 files changed, 51 insertions, 51 deletions
diff --git a/library/cpp/monlib/dynamic_counters/page.cpp b/library/cpp/monlib/dynamic_counters/page.cpp
index 85214ac883..5124a47bb3 100644
--- a/library/cpp/monlib/dynamic_counters/page.cpp
+++ b/library/cpp/monlib/dynamic_counters/page.cpp
@@ -14,7 +14,7 @@ namespace {
currentCounters(nullptr);
}
-TMaybe<EFormat> ParseFormat(TStringBuf str) {
+TMaybe<EFormat> ParseFormat(TStringBuf str) {
if (str == TStringBuf("json")) {
return EFormat::JSON;
} else if (str == TStringBuf("spack")) {
@@ -26,20 +26,20 @@ TMaybe<EFormat> ParseFormat(TStringBuf str) {
}
}
-void TDynamicCountersPage::Output(NMonitoring::IMonHttpRequest& request) {
+void TDynamicCountersPage::Output(NMonitoring::IMonHttpRequest& request) {
if (OutputCallback) {
OutputCallback();
}
- TCountableBase::EVisibility visibility{
- TCountableBase::EVisibility::Public
- };
-
- TVector<TStringBuf> parts;
- StringSplitter(request.GetPathInfo())
- .Split('/')
- .SkipEmpty()
- .Collect(&parts);
+ TCountableBase::EVisibility visibility{
+ TCountableBase::EVisibility::Public
+ };
+
+ TVector<TStringBuf> parts;
+ StringSplitter(request.GetPathInfo())
+ .Split('/')
+ .SkipEmpty()
+ .Collect(&parts);
TMaybe<EFormat> format = !parts.empty() ? ParseFormat(parts.back()) : Nothing();
if (format) {
@@ -47,29 +47,29 @@ void TDynamicCountersPage::Output(NMonitoring::IMonHttpRequest& request) {
}
if (!parts.empty() && parts.back() == TStringBuf("private")) {
- visibility = TCountableBase::EVisibility::Private;
- parts.pop_back();
- }
-
+ visibility = TCountableBase::EVisibility::Private;
+ parts.pop_back();
+ }
+
auto counters = Counters;
- for (const auto& escaped : parts) {
- const auto part = CGIUnescapeRet(escaped);
-
+ for (const auto& escaped : parts) {
+ const auto part = CGIUnescapeRet(escaped);
+
TVector<TString> labels;
- StringSplitter(part).Split('=').SkipEmpty().Collect(&labels);
+ StringSplitter(part).Split('=').SkipEmpty().Collect(&labels);
if (labels.size() != 2U)
return NotFound(request);
- if (const auto child = counters->FindSubgroup(
- labels.front(),
- labels.back())) {
-
+ if (const auto child = counters->FindSubgroup(
+ labels.front(),
+ labels.back())) {
+
counters = child;
- } else {
- return HandleAbsentSubgroup(request);
- }
+ } else {
+ return HandleAbsentSubgroup(request);
+ }
}
if (!format) {
@@ -95,21 +95,21 @@ void TDynamicCountersPage::Output(NMonitoring::IMonHttpRequest& request) {
out.Flush();
}
-void TDynamicCountersPage::HandleAbsentSubgroup(IMonHttpRequest& request) {
- if (UnknownGroupPolicy == EUnknownGroupPolicy::Error) {
- NotFound(request);
- } else if (UnknownGroupPolicy == EUnknownGroupPolicy::Ignore) {
- NoContent(request);
- } else {
- Y_FAIL("Unsupported policy set");
- }
-}
-
-void TDynamicCountersPage::BeforePre(IMonHttpRequest& request) {
- IOutputStream& out = request.Output();
+void TDynamicCountersPage::HandleAbsentSubgroup(IMonHttpRequest& request) {
+ if (UnknownGroupPolicy == EUnknownGroupPolicy::Error) {
+ NotFound(request);
+ } else if (UnknownGroupPolicy == EUnknownGroupPolicy::Ignore) {
+ NoContent(request);
+ } else {
+ Y_FAIL("Unsupported policy set");
+ }
+}
+
+void TDynamicCountersPage::BeforePre(IMonHttpRequest& request) {
+ IOutputStream& out = request.Output();
HTML(out) {
DIV() {
- out << "<a href='" << request.GetPath() << "/json'>Counters as JSON</a>";
+ out << "<a href='" << request.GetPath() << "/json'>Counters as JSON</a>";
out << " for <a href='https://wiki.yandex-team.ru/solomon/'>Solomon</a>";
}
@@ -117,13 +117,13 @@ void TDynamicCountersPage::BeforePre(IMonHttpRequest& request) {
out << "Counters subgroups";
}
UL() {
- currentCounters->EnumerateSubgroups([&](const TString& name, const TString& value) {
- LI() {
- TString pathPart = name + "=" + value;
- Quote(pathPart, "");
- out << "\n<a href='" << request.GetPath() << "/" << pathPart << "'>" << name << " " << value << "</a>";
- }
- });
+ currentCounters->EnumerateSubgroups([&](const TString& name, const TString& value) {
+ LI() {
+ TString pathPart = name + "=" + value;
+ Quote(pathPart, "");
+ out << "\n<a href='" << request.GetPath() << "/" << pathPart << "'>" << name << " " << value << "</a>";
+ }
+ });
}
H4() {
@@ -132,10 +132,10 @@ void TDynamicCountersPage::BeforePre(IMonHttpRequest& request) {
}
}
-void TDynamicCountersPage::OutputText(IOutputStream& out, IMonHttpRequest&) {
+void TDynamicCountersPage::OutputText(IOutputStream& out, IMonHttpRequest&) {
currentCounters->OutputPlainText(out);
}
-
-void TDynamicCountersPage::SetUnknownGroupPolicy(EUnknownGroupPolicy value) {
- UnknownGroupPolicy = value;
-}
+
+void TDynamicCountersPage::SetUnknownGroupPolicy(EUnknownGroupPolicy value) {
+ UnknownGroupPolicy = value;
+}