From 1817efa22b6fbf7d76d8c7ca005c2506acc27441 Mon Sep 17 00:00:00 2001 From: Sergey Skovorodkin Date: Mon, 28 Oct 2024 12:13:47 +0000 Subject: [PATCH] Init counter for pqv0 read session (cherry picked from commit 9251f76d6c95d2b08c7852b710d984eef0d2872f) --- ydb/services/deprecated/persqueue_v0/grpc_pq_read_actor.cpp | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/ydb/services/deprecated/persqueue_v0/grpc_pq_read_actor.cpp b/ydb/services/deprecated/persqueue_v0/grpc_pq_read_actor.cpp index d5856e5b36f7..fdd793b30f11 100644 --- a/ydb/services/deprecated/persqueue_v0/grpc_pq_read_actor.cpp +++ b/ydb/services/deprecated/persqueue_v0/grpc_pq_read_actor.cpp @@ -897,6 +897,8 @@ void TReadSessionActor::SetupTopicCounters(const TTopicConverterPtr& topic) topicCounters.Errors = NKikimr::NPQ::TMultiCounter(subGroup, aggr, cons, {"PartitionsErrors"}, true); topicCounters.Commits = NKikimr::NPQ::TMultiCounter(subGroup, aggr, cons, {"Commits"}, true); topicCounters.WaitsForData = NKikimr::NPQ::TMultiCounter(subGroup, aggr, cons, {"WaitsForData"}, true); + + SetupBytesReadByUserAgentCounter(); } void TReadSessionActor::SetupTopicCounters(const TTopicConverterPtr& topic, const TString& cloudId, @@ -915,6 +917,8 @@ void TReadSessionActor::SetupTopicCounters(const TTopicConverterPtr& topic, cons topicCounters.PartitionsInfly = NKikimr::NPQ::TMultiCounter(subGroup, {}, subgroups, {"api.grpc.topic.stream_read.partition_session.count"}, false, "name"); topicCounters.Errors = NKikimr::NPQ::TMultiCounter(subGroup, {}, subgroups, {"api.grpc.topic.stream_read.partition_session.errors"}, true, "name"); topicCounters.Commits = NKikimr::NPQ::TMultiCounter(subGroup, {}, subgroups, {"api.grpc.topic.stream_read.commits"}, true, "name"); + + SetupBytesReadByUserAgentCounter(); } void TReadSessionActor::Handle(V1::TEvPQProxy::TEvAuthResultOk::TPtr& ev, const TActorContext& ctx) {