Skip to content

Commit 301ab14

Browse files
authored
persqueue: fix user agent counters (for 24-3-11-hotfix) (#10876)
1 parent 77e23b8 commit 301ab14

File tree

4 files changed

+4
-4
lines changed

4 files changed

+4
-4
lines changed

ydb/services/deprecated/persqueue_v0/grpc_pq_read_actor.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -839,7 +839,7 @@ void TReadSessionActor::RegisterSessions(const TActorContext& ctx) {
839839
}
840840

841841
void TReadSessionActor::SetupBytesReadByUserAgentCounter() {
842-
BytesReadByUserAgent = GetServiceCounters(Counters, "pqproxy|userAgents")
842+
BytesReadByUserAgent = GetServiceCounters(Counters, "pqproxy|userAgents", false)
843843
->GetSubgroup("host", "")
844844
->GetSubgroup("protocol", "pqv0")
845845
->GetSubgroup("consumer", ClientPath)

ydb/services/deprecated/persqueue_v0/grpc_pq_write_actor.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -258,7 +258,7 @@ void TWriteSessionActor::InitAfterDiscovery(const TActorContext& ctx) {
258258

259259

260260
void TWriteSessionActor::SetupBytesWrittenByUserAgentCounter() {
261-
BytesWrittenByUserAgent = GetServiceCounters(Counters, "pqproxy|userAgents")
261+
BytesWrittenByUserAgent = GetServiceCounters(Counters, "pqproxy|userAgents", false)
262262
->GetSubgroup("host", "")
263263
->GetSubgroup("protocol", "pqv0")
264264
->GetSubgroup("topic", FullConverter->GetFederationPath())

ydb/services/persqueue_v1/actors/read_session_actor.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -894,7 +894,7 @@ void TReadSessionActor<UseMigrationProtocol>::Handle(typename TEvReadInit::TPtr&
894894
template<bool UseMigrationProtocol>
895895
void TReadSessionActor<UseMigrationProtocol>::SetupBytesReadByUserAgentCounter() {
896896
static constexpr auto protocol = UseMigrationProtocol ? "pqv1" : "topic";
897-
BytesReadByUserAgent = GetServiceCounters(Counters, "pqproxy|userAgents")
897+
BytesReadByUserAgent = GetServiceCounters(Counters, "pqproxy|userAgents", false)
898898
->GetSubgroup("host", "")
899899
->GetSubgroup("protocol", protocol)
900900
->GetSubgroup("consumer", ClientPath)

ydb/services/persqueue_v1/actors/write_session_actor.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -497,7 +497,7 @@ void TWriteSessionActor<UseMigrationProtocol>::InitAfterDiscovery(const TActorCo
497497
template<bool UseMigrationProtocol>
498498
void TWriteSessionActor<UseMigrationProtocol>::SetupBytesWrittenByUserAgentCounter(const TString& topicPath) {
499499
static constexpr auto protocol = UseMigrationProtocol ? "pqv1" : "topic";
500-
BytesWrittenByUserAgent = GetServiceCounters(Counters, "pqproxy|userAgents")
500+
BytesWrittenByUserAgent = GetServiceCounters(Counters, "pqproxy|userAgents", false)
501501
->GetSubgroup("host", "")
502502
->GetSubgroup("protocol", protocol)
503503
->GetSubgroup("topic", topicPath)

0 commit comments

Comments
 (0)