diff options
author | jon2205 <jon2205@yandex-team.ru> | 2022-02-10 16:50:59 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:50:59 +0300 |
commit | 1cbb079ecb3328b501da4e4bdb362ef2b91ad2bb (patch) | |
tree | 9cd683cacc394d43b524657469696f43c90f2824 /library/cpp/monlib/dynamic_counters | |
parent | 886713d680d0ec0e1d8847528a7a6e5fa825c58d (diff) | |
download | ydb-1cbb079ecb3328b501da4e4bdb362ef2b91ad2bb.tar.gz |
Restoring authorship annotation for <jon2205@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/monlib/dynamic_counters')
-rw-r--r-- | library/cpp/monlib/dynamic_counters/golovan_page.cpp | 130 | ||||
-rw-r--r-- | library/cpp/monlib/dynamic_counters/golovan_page.h | 42 |
2 files changed, 86 insertions, 86 deletions
diff --git a/library/cpp/monlib/dynamic_counters/golovan_page.cpp b/library/cpp/monlib/dynamic_counters/golovan_page.cpp index 49cf2d39bb..2c658858c7 100644 --- a/library/cpp/monlib/dynamic_counters/golovan_page.cpp +++ b/library/cpp/monlib/dynamic_counters/golovan_page.cpp @@ -1,79 +1,79 @@ #include "golovan_page.h" - + #include <library/cpp/monlib/service/pages/templates.h> - -#include <util/string/split.h> -#include <util/system/tls.h> - -using namespace NMonitoring; - -class TGolovanCountableConsumer: public ICountableConsumer { -public: - using TOutputCallback = std::function<void()>; - - TGolovanCountableConsumer(IOutputStream& out, TOutputCallback& OutputCallback) - : out(out) - { - if (OutputCallback) { - OutputCallback(); - } - - out << HTTPOKJSON << "["; - FirstCounter = true; - } - + +#include <util/string/split.h> +#include <util/system/tls.h> + +using namespace NMonitoring; + +class TGolovanCountableConsumer: public ICountableConsumer { +public: + using TOutputCallback = std::function<void()>; + + TGolovanCountableConsumer(IOutputStream& out, TOutputCallback& OutputCallback) + : out(out) + { + if (OutputCallback) { + OutputCallback(); + } + + out << HTTPOKJSON << "["; + FirstCounter = true; + } + void OnCounter(const TString&, const TString& value, const TCounterForPtr* counter) override { - if (FirstCounter) { - FirstCounter = false; - } else { - out << ","; - } - - out << "[\"" << prefix + value; - if (counter->ForDerivative()) { + if (FirstCounter) { + FirstCounter = false; + } else { + out << ","; + } + + out << "[\"" << prefix + value; + if (counter->ForDerivative()) { out << "_dmmm"; - } else { - out << "_ahhh"; - } - - out << "\"," << counter->Val() << "]"; - } - + } else { + out << "_ahhh"; + } + + out << "\"," << counter->Val() << "]"; + } + void OnHistogram(const TString&, const TString&, IHistogramSnapshotPtr, bool) override { } void OnGroupBegin(const TString&, const TString& value, const TDynamicCounters*) override { - prefix += value; + prefix += value; if (!value.empty()) { - prefix += "_"; - } - } - + prefix += "_"; + } + } + void OnGroupEnd(const TString&, const TString&, const TDynamicCounters*) override { - prefix = ""; - } - - void Flush() { - out << "]"; - out.Flush(); - } - -private: + prefix = ""; + } + + void Flush() { + out << "]"; + out.Flush(); + } + +private: IOutputStream& out; - bool FirstCounter; + bool FirstCounter; TString prefix; -}; - -TGolovanCountersPage::TGolovanCountersPage(const TString& path, TIntrusivePtr<NMonitoring::TDynamicCounters> counters, - TOutputCallback outputCallback) - : IMonPage(path) - , Counters(counters) - , OutputCallback(outputCallback) -{ -} - +}; + +TGolovanCountersPage::TGolovanCountersPage(const TString& path, TIntrusivePtr<NMonitoring::TDynamicCounters> counters, + TOutputCallback outputCallback) + : IMonPage(path) + , Counters(counters) + , OutputCallback(outputCallback) +{ +} + void TGolovanCountersPage::Output(IMonHttpRequest& request) { TGolovanCountableConsumer consumer(request.Output(), OutputCallback); - Counters->Accept("", "", consumer); - consumer.Flush(); -} + Counters->Accept("", "", consumer); + consumer.Flush(); +} diff --git a/library/cpp/monlib/dynamic_counters/golovan_page.h b/library/cpp/monlib/dynamic_counters/golovan_page.h index e1772c7734..fe0877ad48 100644 --- a/library/cpp/monlib/dynamic_counters/golovan_page.h +++ b/library/cpp/monlib/dynamic_counters/golovan_page.h @@ -1,25 +1,25 @@ -#pragma once - +#pragma once + #include "counters.h" - + #include <library/cpp/monlib/service/pages/mon_page.h> - -#include <util/generic/ptr.h> - -#include <functional> - -// helper class to output json for Golovan. -class TGolovanCountersPage: public NMonitoring::IMonPage { -public: - using TOutputCallback = std::function<void()>; - - const TIntrusivePtr<NMonitoring::TDynamicCounters> Counters; - - TGolovanCountersPage(const TString& path, TIntrusivePtr<NMonitoring::TDynamicCounters> counters, - TOutputCallback outputCallback = nullptr); - + +#include <util/generic/ptr.h> + +#include <functional> + +// helper class to output json for Golovan. +class TGolovanCountersPage: public NMonitoring::IMonPage { +public: + using TOutputCallback = std::function<void()>; + + const TIntrusivePtr<NMonitoring::TDynamicCounters> Counters; + + TGolovanCountersPage(const TString& path, TIntrusivePtr<NMonitoring::TDynamicCounters> counters, + TOutputCallback outputCallback = nullptr); + void Output(NMonitoring::IMonHttpRequest& request) override; -private: - TOutputCallback OutputCallback; -}; +private: + TOutputCallback OutputCallback; +}; |