summaryrefslogtreecommitdiffstats
path: root/library/cpp/grpc/server/grpc_counters.h
diff options
context:
space:
mode:
authormsherbakov <[email protected]>2022-02-10 16:49:17 +0300
committerDaniil Cherednik <[email protected]>2022-02-10 16:49:17 +0300
commita0ffafe83b7d6229709a32fa942c71d672ac989c (patch)
tree5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/grpc/server/grpc_counters.h
parentc224a621661ddd69699f9476922eb316607ef57e (diff)
Restoring authorship annotation for <[email protected]>. Commit 2 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 387163cfea5..0b6c36c84cc 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;