aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/monlib/messagebus
diff options
context:
space:
mode:
authorSergey Polovko <sergey@polovko.me>2022-02-10 16:47:02 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:47:02 +0300
commit3e0b762a82514bac89c1dd6ea7211e381d8aa248 (patch)
treec2d1b379ecaf05ca8f11ed0b5da9d1a950e6e554 /library/cpp/monlib/messagebus
parentab3783171cc30e262243a0227c86118f7080c896 (diff)
downloadydb-3e0b762a82514bac89c1dd6ea7211e381d8aa248.tar.gz
Restoring authorship annotation for Sergey Polovko <sergey@polovko.me>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/monlib/messagebus')
-rw-r--r--library/cpp/monlib/messagebus/mon_messagebus.cpp2
-rw-r--r--library/cpp/monlib/messagebus/mon_messagebus.h64
-rw-r--r--library/cpp/monlib/messagebus/mon_service_messagebus.cpp4
-rw-r--r--library/cpp/monlib/messagebus/mon_service_messagebus.h72
-rw-r--r--library/cpp/monlib/messagebus/ya.make2
5 files changed, 72 insertions, 72 deletions
diff --git a/library/cpp/monlib/messagebus/mon_messagebus.cpp b/library/cpp/monlib/messagebus/mon_messagebus.cpp
index 355b4386cd..414f3f6bb4 100644
--- a/library/cpp/monlib/messagebus/mon_messagebus.cpp
+++ b/library/cpp/monlib/messagebus/mon_messagebus.cpp
@@ -6,6 +6,6 @@ using namespace NMonitoring;
void TBusNgMonPage::Output(NMonitoring::IMonHttpRequest& request) {
NBus::TBusWww::TOptionalParams params;
- params.ParentLinks.push_back(NBus::TBusWww::TLink{"/", request.GetServiceTitle()});
+ params.ParentLinks.push_back(NBus::TBusWww::TLink{"/", request.GetServiceTitle()});
BusWww->ServeHttp(request.Output(), request.GetParams(), params);
}
diff --git a/library/cpp/monlib/messagebus/mon_messagebus.h b/library/cpp/monlib/messagebus/mon_messagebus.h
index e1fa73c69f..2cf46ecbbc 100644
--- a/library/cpp/monlib/messagebus/mon_messagebus.h
+++ b/library/cpp/monlib/messagebus/mon_messagebus.h
@@ -3,44 +3,44 @@
#include <library/cpp/messagebus/ybus.h>
#include <library/cpp/messagebus/www/www.h>
-#include <library/cpp/monlib/service/pages/mon_page.h>
+#include <library/cpp/monlib/service/pages/mon_page.h>
namespace NMonitoring {
- template <class TBusSmth>
- class TBusSmthMonPage: public NMonitoring::IMonPage {
- private:
- TBusSmth* Smth;
-
- public:
- explicit TBusSmthMonPage(const TString& name, const TString& title, TBusSmth* smth)
- : IMonPage("msgbus/" + name, title)
- , Smth(smth)
- {
- }
+ template <class TBusSmth>
+ class TBusSmthMonPage: public NMonitoring::IMonPage {
+ private:
+ TBusSmth* Smth;
+
+ public:
+ explicit TBusSmthMonPage(const TString& name, const TString& title, TBusSmth* smth)
+ : IMonPage("msgbus/" + name, title)
+ , Smth(smth)
+ {
+ }
void Output(NMonitoring::IMonHttpRequest& request) override {
- Y_UNUSED(request);
+ Y_UNUSED(request);
request.Output() << NMonitoring::HTTPOKHTML;
request.Output() << "<h2>" << Title << "</h2>";
request.Output() << "<pre>";
request.Output() << Smth->GetStatus();
request.Output() << "</pre>";
- }
- };
-
- using TBusQueueMonPage = TBusSmthMonPage<NBus::TBusMessageQueue>;
- using TBusModuleMonPage = TBusSmthMonPage<NBus::TBusModule>;
-
- class TBusNgMonPage: public NMonitoring::IMonPage {
- public:
- TIntrusivePtr<NBus::TBusWww> BusWww;
-
- public:
- TBusNgMonPage()
- : IMonPage("messagebus", "MessageBus")
- , BusWww(new NBus::TBusWww)
- {
- }
+ }
+ };
+
+ using TBusQueueMonPage = TBusSmthMonPage<NBus::TBusMessageQueue>;
+ using TBusModuleMonPage = TBusSmthMonPage<NBus::TBusModule>;
+
+ class TBusNgMonPage: public NMonitoring::IMonPage {
+ public:
+ TIntrusivePtr<NBus::TBusWww> BusWww;
+
+ public:
+ TBusNgMonPage()
+ : IMonPage("messagebus", "MessageBus")
+ , BusWww(new NBus::TBusWww)
+ {
+ }
void Output(NMonitoring::IMonHttpRequest& request) override;
- };
-
-}
+ };
+
+}
diff --git a/library/cpp/monlib/messagebus/mon_service_messagebus.cpp b/library/cpp/monlib/messagebus/mon_service_messagebus.cpp
index 4dd144ebe8..36ab81b012 100644
--- a/library/cpp/monlib/messagebus/mon_service_messagebus.cpp
+++ b/library/cpp/monlib/messagebus/mon_service_messagebus.cpp
@@ -4,5 +4,5 @@ using namespace NMonitoring;
TMonServiceMessageBus::TMonServiceMessageBus(ui16 port, const TString& title)
: TMonService2(port, title)
-{
-}
+{
+}
diff --git a/library/cpp/monlib/messagebus/mon_service_messagebus.h b/library/cpp/monlib/messagebus/mon_service_messagebus.h
index fe791e8a9b..32c7b4cb70 100644
--- a/library/cpp/monlib/messagebus/mon_service_messagebus.h
+++ b/library/cpp/monlib/messagebus/mon_service_messagebus.h
@@ -1,46 +1,46 @@
#pragma once
-#include "mon_messagebus.h"
-
-#include <library/cpp/monlib/service/monservice.h>
-
+#include "mon_messagebus.h"
+
+#include <library/cpp/monlib/service/monservice.h>
+
#include <util/system/mutex.h>
namespace NMonitoring {
- class TMonServiceMessageBus: public TMonService2 {
- private:
- TMutex Mtx;
- TIntrusivePtr<NMonitoring::TBusNgMonPage> BusNgMonPage;
-
- public:
- TMonServiceMessageBus(ui16 port, const TString& title);
-
- private:
- NBus::TBusWww* RegisterBusNgMonPage() {
- TGuard<TMutex> g(Mtx);
- if (!BusNgMonPage) {
- BusNgMonPage = new NMonitoring::TBusNgMonPage();
- Register(BusNgMonPage.Get());
- }
- return BusNgMonPage->BusWww.Get();
+ class TMonServiceMessageBus: public TMonService2 {
+ private:
+ TMutex Mtx;
+ TIntrusivePtr<NMonitoring::TBusNgMonPage> BusNgMonPage;
+
+ public:
+ TMonServiceMessageBus(ui16 port, const TString& title);
+
+ private:
+ NBus::TBusWww* RegisterBusNgMonPage() {
+ TGuard<TMutex> g(Mtx);
+ if (!BusNgMonPage) {
+ BusNgMonPage = new NMonitoring::TBusNgMonPage();
+ Register(BusNgMonPage.Get());
+ }
+ return BusNgMonPage->BusWww.Get();
+ }
+
+ public:
+ void RegisterClientSession(NBus::TBusClientSessionPtr clientSession) {
+ RegisterBusNgMonPage()->RegisterClientSession(clientSession);
}
- public:
- void RegisterClientSession(NBus::TBusClientSessionPtr clientSession) {
- RegisterBusNgMonPage()->RegisterClientSession(clientSession);
- }
+ void RegisterServerSession(NBus::TBusServerSessionPtr serverSession) {
+ RegisterBusNgMonPage()->RegisterServerSession(serverSession);
+ }
- void RegisterServerSession(NBus::TBusServerSessionPtr serverSession) {
- RegisterBusNgMonPage()->RegisterServerSession(serverSession);
- }
+ void RegisterQueue(NBus::TBusMessageQueuePtr queue) {
+ RegisterBusNgMonPage()->RegisterQueue(queue);
+ }
- void RegisterQueue(NBus::TBusMessageQueuePtr queue) {
- RegisterBusNgMonPage()->RegisterQueue(queue);
- }
-
- void RegisterModule(NBus::TBusModule* module) {
- RegisterBusNgMonPage()->RegisterModule(module);
- }
- };
+ void RegisterModule(NBus::TBusModule* module) {
+ RegisterBusNgMonPage()->RegisterModule(module);
+ }
+ };
-}
+}
diff --git a/library/cpp/monlib/messagebus/ya.make b/library/cpp/monlib/messagebus/ya.make
index a0b5362296..79889e38a7 100644
--- a/library/cpp/monlib/messagebus/ya.make
+++ b/library/cpp/monlib/messagebus/ya.make
@@ -10,7 +10,7 @@ SRCS(
PEERDIR(
library/cpp/messagebus
library/cpp/messagebus/www
- library/cpp/monlib/dynamic_counters
+ library/cpp/monlib/dynamic_counters
)
END()