YQ-3561 supported in memory cp storage (#15031)

Author: GrigoriyPA

ydb/core/fq/libs/control_plane_storage/control_plane_storage.h

@@ -40,7 +40,13 @@ namespace NFq {
 
 NActors::TActorId ControlPlaneStorageServiceActorId(ui32 nodeId = 0);
 
-NActors::IActor* CreateInMemoryControlPlaneStorageServiceActor(const NConfig::TControlPlaneStorageConfig& config);
+NActors::IActor* CreateInMemoryControlPlaneStorageServiceActor(
+    const NConfig::TControlPlaneStorageConfig& config,
+    const NYql::TS3GatewayConfig& s3Config,
+    const NConfig::TCommonConfig& common,
+    const NConfig::TComputeConfig& computeConfig,
+    const ::NMonitoring::TDynamicCounterPtr& counters,
+    const TString& tenantName);
 
 NActors::IActor* CreateYdbControlPlaneStorageServiceActor(
     const NConfig::TControlPlaneStorageConfig& config,

ydb/core/fq/libs/control_plane_storage/events/events.h

@@ -392,6 +392,7 @@ struct TEvControlPlaneStorage {
 
     // internal messages
     struct TEvWriteResultDataRequest : NActors::TEventLocal<TEvWriteResultDataRequest, EvWriteResultDataRequest> {
+        using TProto = Fq::Private::WriteTaskResultRequest;
 
         TEvWriteResultDataRequest() = default;
 
@@ -411,6 +412,8 @@ struct TEvControlPlaneStorage {
     struct TEvWriteResultDataResponse : NActors::TEventLocal<TEvWriteResultDataResponse, EvWriteResultDataResponse> {
         static constexpr bool Auditable = false;
 
+        using TProto = Fq::Private::WriteTaskResultResult;
+
         explicit TEvWriteResultDataResponse(
             const Fq::Private::WriteTaskResultResult& record)
             : Record(record)
@@ -434,6 +437,7 @@ struct TEvControlPlaneStorage {
     };
 
     struct TEvGetTaskRequest : NActors::TEventLocal<TEvGetTaskRequest, EvGetTaskRequest> {
+        using TProto = Fq::Private::GetTaskRequest;
 
         TEvGetTaskRequest() = default;
 
@@ -454,6 +458,8 @@ struct TEvControlPlaneStorage {
     struct TEvGetTaskResponse : NActors::TEventLocal<TEvGetTaskResponse, EvGetTaskResponse> {
         static constexpr bool Auditable = false;
 
+        using TProto = Fq::Private::GetTaskResult;
+
         explicit TEvGetTaskResponse(
             const Fq::Private::GetTaskResult& record)
             : Record(record)
@@ -499,6 +505,7 @@ struct TEvControlPlaneStorage {
     };
 
     struct TEvPingTaskRequest : NActors::TEventLocal<TEvPingTaskRequest, EvPingTaskRequest> {
+        using TProto = Fq::Private::PingTaskRequest;
 
         TEvPingTaskRequest() = default;
 
@@ -519,6 +526,8 @@ struct TEvControlPlaneStorage {
     struct TEvPingTaskResponse : NActors::TEventLocal<TEvPingTaskResponse, EvPingTaskResponse> {
         static constexpr bool Auditable = false;
 
+        using TProto = Fq::Private::PingTaskResult;
+
         explicit TEvPingTaskResponse(
             const Fq::Private::PingTaskResult& record)
             : Record(record)
@@ -542,6 +551,7 @@ struct TEvControlPlaneStorage {
     };
 
     struct TEvNodesHealthCheckRequest : NActors::TEventLocal<TEvNodesHealthCheckRequest, EvNodesHealthCheckRequest> {
+        using TProto = Fq::Private::NodesHealthCheckRequest;
 
         TEvNodesHealthCheckRequest() = default;
 
@@ -561,6 +571,8 @@ struct TEvControlPlaneStorage {
     struct TEvNodesHealthCheckResponse : NActors::TEventLocal<TEvNodesHealthCheckResponse, EvNodesHealthCheckResponse> {
         static constexpr bool Auditable = false;
 
+        using TProto = Fq::Private::NodesHealthCheckResult;
+
         explicit TEvNodesHealthCheckResponse(
             const Fq::Private::NodesHealthCheckResult& record)
             : Record(record)