aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/grpc/server/grpc_counters.h
diff options
context:
space:
mode:
authormsherbakov <msherbakov@yandex-team.ru>2022-02-10 16:49:16 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:49:16 +0300
commitc224a621661ddd69699f9476922eb316607ef57e (patch)
tree33f4d878aa0a9faa964005e06bfab0272313aa71 /library/cpp/grpc/server/grpc_counters.h
parent29d0b2eeae154d04156e0698067c0c21a97ea61d (diff)
downloadydb-c224a621661ddd69699f9476922eb316607ef57e.tar.gz
Restoring authorship annotation for <msherbakov@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/grpc/server/grpc_counters.h')
-rw-r--r--library/cpp/grpc/server/grpc_counters.h38
1 files changed, 19 insertions, 19 deletions
diff --git a/library/cpp/grpc/server/grpc_counters.h b/library/cpp/grpc/server/grpc_counters.h
index 0b6c36c84c..387163cfea 100644
--- a/library/cpp/grpc/server/grpc_counters.h
+++ b/library/cpp/grpc/server/grpc_counters.h
@@ -6,14 +6,14 @@
namespace NGrpc {
-struct ICounterBlock : public TThrRefBase {
- virtual void CountNotOkRequest() = 0;
- virtual void CountNotOkResponse() = 0;
- virtual void CountNotAuthenticated() = 0;
- virtual void CountResourceExhausted() = 0;
- virtual void CountRequestBytes(ui32 requestSize) = 0;
- virtual void CountResponseBytes(ui32 responseSize) = 0;
- virtual void StartProcessing(ui32 requestSize) = 0;
+struct ICounterBlock : public TThrRefBase {
+ virtual void CountNotOkRequest() = 0;
+ virtual void CountNotOkResponse() = 0;
+ virtual void CountNotAuthenticated() = 0;
+ virtual void CountResourceExhausted() = 0;
+ virtual void CountRequestBytes(ui32 requestSize) = 0;
+ virtual void CountResponseBytes(ui32 responseSize) = 0;
+ virtual void StartProcessing(ui32 requestSize) = 0;
virtual void FinishProcessing(ui32 requestSize, ui32 responseSize, bool ok, ui32 status, TDuration requestDuration) = 0;
virtual void CountRequestsWithoutDatabase() {}
virtual void CountRequestsWithoutToken() {}
@@ -21,11 +21,11 @@ struct ICounterBlock : public TThrRefBase {
virtual TIntrusivePtr<ICounterBlock> Clone() { return this; }
virtual void UseDatabase(const TString& database) { Y_UNUSED(database); }
-};
-
+};
+
using ICounterBlockPtr = TIntrusivePtr<ICounterBlock>;
-class TCounterBlock final : public ICounterBlock {
+class TCounterBlock final : public ICounterBlock {
NMonitoring::TDynamicCounters::TCounterPtr TotalCounter;
NMonitoring::TDynamicCounters::TCounterPtr InflyCounter;
NMonitoring::TDynamicCounters::TCounterPtr NotOkRequestCounter;
@@ -36,7 +36,7 @@ class TCounterBlock final : public ICounterBlock {
NMonitoring::TDynamicCounters::TCounterPtr NotAuthenticated;
NMonitoring::TDynamicCounters::TCounterPtr ResourceExhausted;
bool Percentile = false;
- NMonitoring::TPercentileTracker<4, 512, 15> RequestHistMs;
+ NMonitoring::TPercentileTracker<4, 512, 15> RequestHistMs;
std::array<NMonitoring::TDynamicCounters::TCounterPtr, 2> GRpcStatusCounters;
public:
@@ -66,31 +66,31 @@ public:
}
}
- void CountNotOkRequest() override {
+ void CountNotOkRequest() override {
NotOkRequestCounter->Inc();
}
- void CountNotOkResponse() override {
+ void CountNotOkResponse() override {
NotOkResponseCounter->Inc();
}
- void CountNotAuthenticated() override {
+ void CountNotAuthenticated() override {
NotAuthenticated->Inc();
}
- void CountResourceExhausted() override {
+ void CountResourceExhausted() override {
ResourceExhausted->Inc();
}
- void CountRequestBytes(ui32 requestSize) override {
+ void CountRequestBytes(ui32 requestSize) override {
*RequestBytes += requestSize;
}
- void CountResponseBytes(ui32 responseSize) override {
+ void CountResponseBytes(ui32 responseSize) override {
*ResponseBytes += responseSize;
}
- void StartProcessing(ui32 requestSize) override {
+ void StartProcessing(ui32 requestSize) override {
TotalCounter->Inc();
InflyCounter->Inc();
*RequestBytes += requestSize;