EXT-1333 Refactor pq grpc requests (#27620)

UgnineSirdis · web-flow · commit 94ff246e42b5 · 2025-10-27T09:59:10.000+02:00
diff --git a/ydb/core/grpc_services/grpc_request_proxy.cpp b/ydb/core/grpc_services/grpc_request_proxy.cpp
@@ -670,8 +670,6 @@ void TGRpcRequestProxyImpl::StateFunc(TAutoPtr<IEventHandle>& ev) {
         HFunc(TEvStreamTopicWriteRequest, PreHandle);
         HFunc(TEvStreamTopicReadRequest, PreHandle);
         HFunc(TEvStreamTopicDirectReadRequest, PreHandle);
-        HFunc(TEvPQReadInfoRequest, PreHandle);
-        HFunc(TEvDiscoverPQClustersRequest, PreHandle);
         HFunc(TEvCoordinationSessionRequest, PreHandle);
         HFunc(TEvProxyRuntimeEvent, PreHandle);
         HFunc(TEvRequestAuthAndCheck, PreHandle);
diff --git a/ydb/core/grpc_services/grpc_request_proxy_handle_methods.h b/ydb/core/grpc_services/grpc_request_proxy_handle_methods.h
@@ -16,8 +16,6 @@ class TGRpcRequestProxyHandleMethods {
     static void Handle(TEvStreamTopicWriteRequest::TPtr& ev, const TActorContext& ctx);
     static void Handle(TEvStreamTopicReadRequest::TPtr& ev, const TActorContext& ctx);
     static void Handle(TEvStreamTopicDirectReadRequest::TPtr& ev, const TActorContext& ctx);
-    static void Handle(TEvPQReadInfoRequest::TPtr& ev, const TActorContext& ctx);
-    static void Handle(TEvDiscoverPQClustersRequest::TPtr& ev, const TActorContext& ctx);
     static void Handle(TEvCoordinationSessionRequest::TPtr& ev, const TActorContext& ctx);
 };
 
diff --git a/ydb/core/grpc_services/rpc_calls.h b/ydb/core/grpc_services/rpc_calls.h
@@ -53,10 +53,6 @@ using TEvStreamPQMigrationReadRequest = TGRpcRequestBiStreamWrapper<TRpcServices
 using TEvStreamTopicWriteRequest = TGRpcRequestBiStreamWrapper<TRpcServices::EvStreamTopicWrite, Ydb::Topic::StreamWriteMessage::FromClient, Ydb::Topic::StreamWriteMessage::FromServer>;
 using TEvStreamTopicReadRequest = TGRpcRequestBiStreamWrapper<TRpcServices::EvStreamTopicRead, Ydb::Topic::StreamReadMessage::FromClient, Ydb::Topic::StreamReadMessage::FromServer>;
 using TEvStreamTopicDirectReadRequest = TGRpcRequestBiStreamWrapper<TRpcServices::EvStreamTopicDirectRead, Ydb::Topic::StreamDirectReadMessage::FromClient, Ydb::Topic::StreamDirectReadMessage::FromServer>;
-using TEvPQReadInfoRequest = TGRpcRequestWrapper<TRpcServices::EvPQReadInfo, Ydb::PersQueue::V1::ReadInfoRequest, Ydb::PersQueue::V1::ReadInfoResponse, true>;
-//TODO: Change this to runtime dispatching!
-using TEvDiscoverPQClustersRequest = TGRpcRequestWrapper<TRpcServices::EvDiscoverPQClusters, Ydb::PersQueue::ClusterDiscovery::DiscoverClustersRequest, Ydb::PersQueue::ClusterDiscovery::DiscoverClustersResponse, true>;
-using TEvListFederationDatabasesRequest = TGRpcRequestWrapper<TRpcServices::EvListFederationDatabases, Ydb::FederationDiscovery::ListFederationDatabasesRequest, Ydb::FederationDiscovery::ListFederationDatabasesResponse, true>;
 
 using TEvCoordinationSessionRequest = TGRpcRequestBiStreamWrapper<TRpcServices::EvCoordinationSession, Ydb::Coordination::SessionRequest, Ydb::Coordination::SessionResponse>;
 
diff --git a/ydb/core/grpc_services/rpc_calls_topic.h b/ydb/core/grpc_services/rpc_calls_topic.h
@@ -21,5 +21,6 @@ using TEvPQAlterTopicRequest = TGrpcRequestOperationCall<Ydb::PersQueue::V1::Alt
 using TEvPQDescribeTopicRequest = TGrpcRequestOperationCall<Ydb::PersQueue::V1::DescribeTopicRequest, Ydb::PersQueue::V1::DescribeTopicResponse>;
 using TEvPQAddReadRuleRequest = TGrpcRequestOperationCall<Ydb::PersQueue::V1::AddReadRuleRequest, Ydb::PersQueue::V1::AddReadRuleResponse>;
 using TEvPQRemoveReadRuleRequest = TGrpcRequestOperationCall<Ydb::PersQueue::V1::RemoveReadRuleRequest, Ydb::PersQueue::V1::RemoveReadRuleResponse>;
+using TEvPQReadInfoRequest = TGrpcRequestOperationCall<Ydb::PersQueue::V1::ReadInfoRequest, Ydb::PersQueue::V1::ReadInfoResponse>;
 
 }
diff --git a/ydb/core/grpc_services/service_topic.h b/ydb/core/grpc_services/service_topic.h
@@ -28,6 +28,7 @@ void DoPQAlterTopicRequest(std::unique_ptr<IRequestOpCtx> p, const IFacilityProv
 void DoPQDescribeTopicRequest(std::unique_ptr<IRequestOpCtx> p, const IFacilityProvider& f);
 void DoPQAddReadRuleRequest(std::unique_ptr<IRequestOpCtx> p, const IFacilityProvider& f);
 void DoPQRemoveReadRuleRequest(std::unique_ptr<IRequestOpCtx> p, const IFacilityProvider& f);
+void DoPQReadInfoRequest(std::unique_ptr<IRequestOpCtx> p, const IFacilityProvider& f);
 
 }
 }
diff --git a/ydb/services/persqueue_cluster_discovery/cluster_discovery_service.cpp b/ydb/services/persqueue_cluster_discovery/cluster_discovery_service.cpp
@@ -4,6 +4,7 @@
 #include "counters.h"
 
 #include <ydb/core/base/appdata.h>
+#include <ydb/core/grpc_services/base/base.h>
 #include <ydb/core/grpc_services/grpc_request_proxy.h>
 #include <ydb/core/mind/address_classification/net_classifier.h>
 #include <ydb/core/mon/mon.h>
@@ -196,22 +197,23 @@ class TClusterDiscoveryServiceActor: public TActorBootstrapped<TClusterDiscovery
         switch (ev->GetTypeRewrite()) {
             hFunc(NNetClassifier::TEvNetClassifier::TEvClassifierUpdate, HandleClassifierUpdateWhileIniting);
             hFunc(NClusterTracker::TEvClusterTracker::TEvClustersUpdate, HandleClustersUpdateWhileIniting);
-            hFunc(NGRpcService::TEvDiscoverPQClustersRequest, HandleDiscoverPQClustersRequestWhileIniting);
+            fFunc(NGRpcService::TRpcServices::EvDiscoverPQClusters, HandleDiscoverPQClustersRequestWhileIniting);
             hFunc(NMon::TEvHttpInfo, HandleHttpRequest);
             hFunc(TEvents::TEvWakeup, UpdateTimedCounters);
         }
     }
 
-    void RespondServiceUnavailable(NGRpcService::TEvDiscoverPQClustersRequest::TPtr& ev) {
+    void RespondServiceUnavailable(NGRpcService::TEvDiscoverPQClustersRequest* ev) {
         Counters->DroppedRequestsCount->Inc();
 
-        ev->Get()->ReplyWithYdbStatus(Ydb::StatusIds::UNAVAILABLE);
+        ev->ReplyWithYdbStatus(Ydb::StatusIds::UNAVAILABLE);
     }
 
-    void HandleDiscoverPQClustersRequestWhileIniting(NGRpcService::TEvDiscoverPQClustersRequest::TPtr& ev) {
+    void HandleDiscoverPQClustersRequestWhileIniting(TAutoPtr<NActors::IEventHandle>& ev) {
+        ev->DropRewrite();
         Counters->TotalRequestsCount->Inc();
 
-        RespondServiceUnavailable(ev);
+        RespondServiceUnavailable(ev->Get<NGRpcService::TEvDiscoverPQClustersRequest>());
     }
 
     void HandleClassifierUpdateWhileWorking(NNetClassifier::TEvNetClassifier::TEvClassifierUpdate::TPtr& ev) {
@@ -222,23 +224,24 @@ class TClusterDiscoveryServiceActor: public TActorBootstrapped<TClusterDiscovery
         UpdateClustersList(ev);
     }
 
-    void HandleDiscoverPQClustersRequestWhileWorking(NGRpcService::TEvDiscoverPQClustersRequest::TPtr& ev) {
+    void HandleDiscoverPQClustersRequestWhileWorking(TAutoPtr<NActors::IEventHandle>& ev) {
+        ev->DropRewrite();
         Counters->TotalRequestsCount->Inc();
 
         if (!IsHealthy()) {
-            RespondServiceUnavailable(ev);
+            RespondServiceUnavailable(ev->Get<NGRpcService::TEvDiscoverPQClustersRequest>());
             return;
         }
 
-        IActor* actor = NWorker::CreateClusterDiscoveryWorker(ev, DatacenterClassifier, CloudNetworksClassifier, ClustersList, Counters);
+        IActor* actor = NWorker::CreateClusterDiscoveryWorker(THolder(ev->Release<NGRpcService::TEvDiscoverPQClustersRequest>().Release()), DatacenterClassifier, CloudNetworksClassifier, ClustersList, Counters);
         Register(actor, TMailboxType::HTSwap, AppData(Ctx())->UserPoolId);
     }
 
     STATEFN(Working) {
         switch (ev->GetTypeRewrite()) {
             hFunc(NNetClassifier::TEvNetClassifier::TEvClassifierUpdate, HandleClassifierUpdateWhileWorking);
             hFunc(NClusterTracker::TEvClusterTracker::TEvClustersUpdate, HandleClustersUpdateWhileWorking);
-            hFunc(NGRpcService::TEvDiscoverPQClustersRequest, HandleDiscoverPQClustersRequestWhileWorking);
+            fFunc(NGRpcService::TRpcServices::EvDiscoverPQClusters, HandleDiscoverPQClustersRequestWhileWorking);
             hFunc(NMon::TEvHttpInfo, HandleHttpRequest);
             hFunc(TEvents::TEvWakeup, UpdateTimedCounters);
         }
diff --git a/ydb/services/persqueue_cluster_discovery/cluster_discovery_worker.cpp b/ydb/services/persqueue_cluster_discovery/cluster_discovery_worker.cpp
@@ -27,12 +27,12 @@ class TClusterDiscoveryWorker : public TActorBootstrapped<TClusterDiscoveryWorke
         return NKikimrServices::TActivity::GRPC_REQ;
     }
 
-    TClusterDiscoveryWorker(TEvDiscoverPQClustersRequest::TPtr& ev,
+    TClusterDiscoveryWorker(THolder<NGRpcService::TEvDiscoverPQClustersRequest> ev,
                             TLabeledAddressClassifier::TConstPtr datacenterClassifier,
                             TLabeledAddressClassifier::TConstPtr cloudNetsClassifier,
                             TClustersList::TConstPtr clustersList,
                             TClusterDiscoveryCounters::TPtr counters)
-        : Request(ev->Release().Release())
+        : Request(std::move(ev))
         , DatacenterClassifier(std::move(datacenterClassifier))
         , CloudNetsClassifier(std::move(cloudNetsClassifier))
         , ClustersList(std::move(clustersList))
@@ -271,13 +271,13 @@ class TClusterDiscoveryWorker : public TActorBootstrapped<TClusterDiscoveryWorke
     TClusterDiscoveryCounters::TPtr Counters;
 };
 
-IActor* CreateClusterDiscoveryWorker(TEvDiscoverPQClustersRequest::TPtr& ev,
+IActor* CreateClusterDiscoveryWorker(THolder<NGRpcService::TEvDiscoverPQClustersRequest> ev,
                                      TLabeledAddressClassifier::TConstPtr datacenterClassifier,
                                      TLabeledAddressClassifier::TConstPtr cloudNetsClassifier,
                                      TClustersList::TConstPtr clustersList,
                                      TClusterDiscoveryCounters::TPtr counters)
 {
-    return new TClusterDiscoveryWorker(ev,
+    return new TClusterDiscoveryWorker(std::move(ev),
                                        std::move(datacenterClassifier),
                                        std::move(cloudNetsClassifier),
                                        std::move(clustersList),
diff --git a/ydb/services/persqueue_cluster_discovery/cluster_discovery_worker.h b/ydb/services/persqueue_cluster_discovery/cluster_discovery_worker.h
@@ -1,6 +1,7 @@
 #pragma once
 
 #include "counters.h"
+#include "grpc_service.h"
 
 #include <ydb/core/grpc_services/grpc_request_proxy.h>
 #include <ydb/core/persqueue/public/cluster_tracker/cluster_tracker.h>
@@ -16,7 +17,7 @@ using namespace NGRpcService;
 using namespace NPQ::NClusterTracker;
 using namespace NCounters;
 
-IActor* CreateClusterDiscoveryWorker(TEvDiscoverPQClustersRequest::TPtr& ev,
+IActor* CreateClusterDiscoveryWorker(THolder<NGRpcService::TEvDiscoverPQClustersRequest> ev,
                                      TLabeledAddressClassifier::TConstPtr datacenterClassifier,
                                      TLabeledAddressClassifier::TConstPtr cloudNetsClassifier,
                                      TClustersList::TConstPtr clustersList,
diff --git a/ydb/services/persqueue_cluster_discovery/grpc_service.cpp b/ydb/services/persqueue_cluster_discovery/grpc_service.cpp
@@ -55,6 +55,19 @@ void TGRpcPQClusterDiscoveryService::DecRequest() {
     }
 }
 
+static void DoDiscoverPQClustersRequest(std::unique_ptr<IRequestOpCtx> ctx, const IFacilityProvider&) {
+    auto ev = dynamic_cast<TEvDiscoverPQClustersRequest*>(ctx.release());
+    Y_ENSURE(ev);
+
+    auto evHandle = std::make_unique<NActors::IEventHandle>(
+        NPQ::NClusterDiscovery::MakeClusterDiscoveryServiceID(),
+        NPQ::NClusterDiscovery::MakeClusterDiscoveryServiceID(),
+        ev
+    );
+    evHandle->Rewrite(TRpcServices::EvDiscoverPQClusters, NPQ::NClusterDiscovery::MakeClusterDiscoveryServiceID());
+    NActors::TActivationContext::Send(std::move(evHandle));
+}
+
 void TGRpcPQClusterDiscoveryService::SetupIncomingRequests(NYdbGrpc::TLoggerPtr logger) {
     auto getCounterBlock = NGRpcService::CreateCounterCb(Counters_, ActorSystem_);
 
@@ -70,7 +83,7 @@ void TGRpcPQClusterDiscoveryService::SetupIncomingRequests(NYdbGrpc::TLoggerPtr
         #NAME, logger, getCounterBlock("pq_cluster_discovery", #NAME))->Run();
 
         ADD_REQUEST(DiscoverClusters, DiscoverClustersRequest, DiscoverClustersResponse, {
-            ActorSystem_->Send(GRpcRequestProxyId_, new TEvDiscoverPQClustersRequest(ctx));
+            ActorSystem_->Send(GRpcRequestProxyId_, new TEvDiscoverPQClustersRequest(ctx, DoDiscoverPQClustersRequest, TRequestAuxSettings{TRateLimiterMode::Off, nullptr, TAuditMode::NonModifying()}));
         })
 #undef ADD_REQUEST
 
@@ -80,8 +93,4 @@ void TGRpcPQClusterDiscoveryService::StopService() noexcept {
     TGrpcServiceBase::StopService();
 }
 
-void TGRpcRequestProxyHandleMethods::Handle(TEvDiscoverPQClustersRequest::TPtr& ev, const TActorContext& ctx) {
-    ctx.Send(ev->Forward(NPQ::NClusterDiscovery::MakeClusterDiscoveryServiceID()));
-}
-
 } // namespace NKikimr::NGRpcService
diff --git a/ydb/services/persqueue_cluster_discovery/grpc_service.h b/ydb/services/persqueue_cluster_discovery/grpc_service.h
@@ -1,12 +1,15 @@
 #pragma once
 
+#include <ydb/core/grpc_services/base/base.h>
 #include <ydb/library/actors/core/actorsystem_fwd.h>
 #include <ydb/library/actors/core/actorid.h>
 #include <ydb/public/api/grpc/draft/ydb_persqueue_v1.grpc.pb.h>
 #include <ydb/library/grpc/server/grpc_server.h>
 
 namespace NKikimr::NGRpcService {
 
+using TEvDiscoverPQClustersRequest = TGrpcRequestOperationCall<Ydb::PersQueue::ClusterDiscovery::DiscoverClustersRequest, Ydb::PersQueue::ClusterDiscovery::DiscoverClustersResponse>;
+
 class TGRpcPQClusterDiscoveryService
    : public NYdbGrpc::TGrpcServiceBase<Ydb::PersQueue::V1::ClusterDiscoveryService> {
 public:
diff --git a/ydb/services/persqueue_v1/grpc_pq_read.cpp b/ydb/services/persqueue_v1/grpc_pq_read.cpp
@@ -5,6 +5,7 @@
 #include "actors/schema_actors.h"
 
 #include <ydb/core/grpc_services/grpc_helper.h>
+#include <ydb/core/grpc_services/rpc_calls_topic.h>
 #include <ydb/core/tx/scheme_board/cache.h>
 
 #include <algorithm>
@@ -15,8 +16,7 @@ using namespace NKikimrClient;
 using grpc::Status;
 
 namespace NKikimr {
-namespace NGRpcProxy {
-namespace V1 {
+namespace NGRpcProxy::V1 {
 
 ///////////////////////////////////////////////////////////////////////////////
 
@@ -164,19 +164,20 @@ void TPQReadService::Handle(NGRpcService::TEvStreamPQMigrationReadRequest::TPtr&
 }
 
 
-void TPQReadService::Handle(NGRpcService::TEvPQReadInfoRequest::TPtr& ev, const TActorContext& ctx) {
+void TPQReadService::HandleReadInfo(TAutoPtr<NActors::IEventHandle>& evHandle, const TActorContext& ctx) {
+    evHandle->DropRewrite();
+    auto* ev = evHandle->Get<TEvPQReadInfoRequest>();
 
     LOG_DEBUG_S(ctx, NKikimrServices::PQ_READ_PROXY, "new read info request");
 
     if (HaveClusters && (Clusters.empty() || LocalCluster.empty())) {
         LOG_INFO_S(ctx, NKikimrServices::PQ_READ_PROXY, "new read info request failed - cluster is not known yet");
 
-        ev->Get()->RaiseIssue(FillIssue("cluster initializing", PersQueue::ErrorCode::INITIALIZING));
-        ev->Get()->ReplyWithYdbStatus(ConvertPersQueueInternalCodeToStatus(PersQueue::ErrorCode::INITIALIZING));
+        ev->RaiseIssue(FillIssue("cluster initializing", PersQueue::ErrorCode::INITIALIZING));
+        ev->ReplyWithYdbStatus(ConvertPersQueueInternalCodeToStatus(PersQueue::ErrorCode::INITIALIZING));
         return;
     } else {
-        //ctx.Register(new TReadInfoActor(ev->Release().Release(), Clusters, LocalCluster, SchemeCache, NewSchemeCache, Counters));
-        ctx.Register(new TReadInfoActor(ev->Release().Release(), *TopicsHandler, SchemeCache, NewSchemeCache, Counters));
+        ctx.Register(new TReadInfoActor(evHandle->Release<TEvPQReadInfoRequest>().Release(), *TopicsHandler, SchemeCache, NewSchemeCache, Counters));
     }
 }
 
@@ -186,11 +187,26 @@ bool TPQReadService::TooMuchSessions() {
     return Sessions.size() >= MaxSessions;
 }
 
+} // namespace NGRpcProxy::V1
 
-}
-}
+namespace NGRpcService {
+
+void DoPQReadInfoRequest(std::unique_ptr<IRequestOpCtx> ctx, const NKikimr::NGRpcService::IFacilityProvider&) {
+    auto ev = dynamic_cast<TEvPQReadInfoRequest*>(ctx.release());
+    Y_ENSURE(ev);
+
+    auto evHandle = std::make_unique<NActors::IEventHandle>(
+        NGRpcProxy::V1::GetPQReadServiceActorID(),
+        NGRpcProxy::V1::GetPQReadServiceActorID(),
+        ev
+    );
+    evHandle->Rewrite(TRpcServices::EvPQReadInfo, NGRpcProxy::V1::GetPQReadServiceActorID());
+    NActors::TActivationContext::Send(std::move(evHandle));
 }
 
+} // namespace NGRpcService
+} // namespace NKikimr
+
 
 void NKikimr::NGRpcService::TGRpcRequestProxyHandleMethods::Handle(NKikimr::NGRpcService::TEvStreamTopicReadRequest::TPtr& ev, const TActorContext& ctx) {
     ctx.Send(NKikimr::NGRpcProxy::V1::GetPQReadServiceActorID(), ev->Release().Release());
@@ -204,7 +220,3 @@ void NKikimr::NGRpcService::TGRpcRequestProxyHandleMethods::Handle(NKikimr::NGRp
 void NKikimr::NGRpcService::TGRpcRequestProxyHandleMethods::Handle(NKikimr::NGRpcService::TEvStreamPQMigrationReadRequest::TPtr& ev, const TActorContext& ctx) {
     ctx.Send(NKikimr::NGRpcProxy::V1::GetPQReadServiceActorID(), ev->Release().Release());
 }
-
-void NKikimr::NGRpcService::TGRpcRequestProxyHandleMethods::Handle(NKikimr::NGRpcService::TEvPQReadInfoRequest::TPtr& ev, const TActorContext& ctx) {
-    ctx.Send(NKikimr::NGRpcProxy::V1::GetPQReadServiceActorID(), ev->Release().Release());
-}
diff --git a/ydb/services/persqueue_v1/grpc_pq_read.h b/ydb/services/persqueue_v1/grpc_pq_read.h
@@ -45,7 +45,7 @@ class TPQReadService : public NActors::TActorBootstrapped<TPQReadService> {
             HFunc(NGRpcService::TEvStreamTopicReadRequest, Handle);
             HFunc(NGRpcService::TEvStreamTopicDirectReadRequest, Handle);
             HFunc(NGRpcService::TEvStreamPQMigrationReadRequest, Handle);
-            HFunc(NGRpcService::TEvPQReadInfoRequest, Handle);
+            FFunc(TRpcServices::EvPQReadInfo, HandleReadInfo);
             HFunc(NPQ::NClusterTracker::TEvClusterTracker::TEvClustersUpdate, Handle);
             HFunc(NNetClassifier::TEvNetClassifier::TEvClassifierUpdate, Handle);
             HFunc(TEvPQProxy::TEvSessionDead, Handle);
@@ -59,7 +59,7 @@ class TPQReadService : public NActors::TActorBootstrapped<TPQReadService> {
     void Handle(NGRpcService::TEvStreamTopicReadRequest::TPtr& ev, const TActorContext& ctx);
     void Handle(NGRpcService::TEvStreamTopicDirectReadRequest::TPtr& ev, const TActorContext& ctx);
     void Handle(NGRpcService::TEvStreamPQMigrationReadRequest::TPtr& ev, const TActorContext& ctx);
-    void Handle(NGRpcService::TEvPQReadInfoRequest::TPtr& ev, const TActorContext& ctx);
+    void HandleReadInfo(TAutoPtr<NActors::IEventHandle>& ev, const TActorContext& ctx);
     void Handle(NPQ::NClusterTracker::TEvClusterTracker::TEvClustersUpdate::TPtr& ev, const TActorContext& ctx);
     void Handle(NNetClassifier::TEvNetClassifier::TEvClassifierUpdate::TPtr& ev, const TActorContext& ctx);
 
diff --git a/ydb/services/persqueue_v1/persqueue.cpp b/ydb/services/persqueue_v1/persqueue.cpp
@@ -87,7 +87,7 @@ void TGRpcPersQueueService::SetupIncomingRequests(NYdbGrpc::TLoggerPtr logger) {
         #NAME, logger, getCounterBlock("persistent_queue", #NAME))->Run();
 
     ADD_REQUEST(GetReadSessionsInfo, PersQueueService, ReadInfoRequest, ReadInfoResponse, {
-        ActorSystem_->Send(GRpcRequestProxyId_, new NGRpcService::TEvPQReadInfoRequest(ctx));
+        ActorSystem_->Send(GRpcRequestProxyId_, new TEvPQReadInfoRequest(ctx, &DoPQReadInfoRequest, TRequestAuxSettings{RLSWITCH(TRateLimiterMode::Rps), nullptr, TAuditMode::NonModifying()}));
     })
 
     ADD_REQUEST(DropTopic, PersQueueService, DropTopicRequest, DropTopicResponse, {
@@ -117,8 +117,6 @@ void TGRpcPersQueueService::SetupIncomingRequests(NYdbGrpc::TLoggerPtr logger) {
     })
 
 #undef ADD_REQUEST
-
-
 }
 
 void TGRpcPersQueueService::StopService() noexcept {

Original file line number	Diff line number	Diff line change
`@@ -21,5 +21,6 @@ using TEvPQAlterTopicRequest = TGrpcRequestOperationCall<Ydb::PersQueue::V1::Alt`
`21`	`21`	`using TEvPQDescribeTopicRequest = TGrpcRequestOperationCall<Ydb::PersQueue::V1::DescribeTopicRequest, Ydb::PersQueue::V1::DescribeTopicResponse>;`
`22`	`22`	`using TEvPQAddReadRuleRequest = TGrpcRequestOperationCall<Ydb::PersQueue::V1::AddReadRuleRequest, Ydb::PersQueue::V1::AddReadRuleResponse>;`
`23`	`23`	`using TEvPQRemoveReadRuleRequest = TGrpcRequestOperationCall<Ydb::PersQueue::V1::RemoveReadRuleRequest, Ydb::PersQueue::V1::RemoveReadRuleResponse>;`
	`24`	`+using TEvPQReadInfoRequest = TGrpcRequestOperationCall<Ydb::PersQueue::V1::ReadInfoRequest, Ydb::PersQueue::V1::ReadInfoResponse>;`
`24`	`25`
`25`	`26`	`}`
Original file line number	Diff line number	Diff line change
`@@ -28,6 +28,7 @@ void DoPQAlterTopicRequest(std::unique_ptr<IRequestOpCtx> p, const IFacilityProv`
`28`	`28`	`void DoPQDescribeTopicRequest(std::unique_ptr<IRequestOpCtx> p, const IFacilityProvider& f);`
`29`	`29`	`void DoPQAddReadRuleRequest(std::unique_ptr<IRequestOpCtx> p, const IFacilityProvider& f);`
`30`	`30`	`void DoPQRemoveReadRuleRequest(std::unique_ptr<IRequestOpCtx> p, const IFacilityProvider& f);`
	`31`	`+void DoPQReadInfoRequest(std::unique_ptr<IRequestOpCtx> p, const IFacilityProvider& f);`
`31`	`32`
`32`	`33`	`}`
`33`	`34`	`}`