Moved "improve CS-resharding" commit from ydb repo

Author: ivanmorozov333

src/client/CMakeLists.txt

@@ -31,6 +31,7 @@ add_subdirectory(query)
 add_subdirectory(rate_limiter)
 add_subdirectory(result)
 add_subdirectory(scheme)
+add_subdirectory(ss_tasks)
 add_subdirectory(table)
 add_subdirectory(topic)
 add_subdirectory(types)

src/client/operation/CMakeLists.txt

@@ -9,6 +9,7 @@ target_link_libraries(cpp-client-ydb_operation PUBLIC
   cpp-client-ydb_driver
   cpp-client-ydb_export
   cpp-client-ydb_import
+  cpp-client-ss_tasks
   client-ydb_types-operation
 )
 

src/client/operation/operation.cpp

@@ -8,6 +8,7 @@
 #include <ydb-cpp-sdk/client/query/query.h>
 #include <ydb-cpp-sdk/client/export/export.h>
 #include <ydb-cpp-sdk/client/import/import.h>
+#include <src/client/ss_tasks/task.h>
 #include <ydb-cpp-sdk/client/table/table.h>
 
 #include <src/api/grpc/ydb_operation_v1.grpc.pb.h>
@@ -168,6 +169,12 @@ TFuture<TOperationsList<TOp>> TOperationClient::List(const std::string& kind, ui
 }
 
 // Instantiations
+template TFuture<NSchemeShard::TBackgroundProcessesResponse> TOperationClient::Get(const TOperation::TOperationId& id);
+template <>
+TFuture<TOperationsList<NSchemeShard::TBackgroundProcessesResponse>> TOperationClient::List(ui64 pageSize, const std::string& pageToken) {
+    return List<NSchemeShard::TBackgroundProcessesResponse>("ss/backgrounds", pageSize, pageToken);
+}
+
 template TFuture<NExport::TExportToYtResponse> TOperationClient::Get(const TOperation::TOperationId& id);
 template <>
 TFuture<TOperationsList<NExport::TExportToYtResponse>> TOperationClient::List(ui64 pageSize, const std::string& pageToken) {

src/client/ss_tasks/CMakeLists.txt

@@ -0,0 +1,22 @@
+add_library(cpp-client-ss_tasks)
+
+target_link_libraries(cpp-client-ss_tasks PUBLIC
+  yutil
+  api-grpc
+  api-protos
+  client-ydb_common_client-impl
+  cpp-client-ydb_driver
+  cpp-client-ydb_proto
+  client-ydb_types-operation
+)
+
+target_sources(cpp-client-ss_tasks PRIVATE
+  task.cpp
+  out.cpp
+)
+
+generate_enum_serilization(cpp-client-ss_tasks
+  ${YDB_SDK_SOURCE_DIR}/src/client/ss_tasks/task.h
+  INCLUDE_HEADERS
+  src/client/ss_tasks/task.h
+)

src/client/ss_tasks/out.cpp

@@ -0,0 +1 @@
+#include "task.h"

src/client/ss_tasks/task.cpp

@@ -0,0 +1,23 @@
+#include "task.h"
+#include <src/api/grpc/ydb_discovery_v1.grpc.pb.h>
+#include <src/api/grpc/ydb_export_v1.grpc.pb.h>
+#include <src/api/protos/ydb_export.pb.h>
+#include <src/client/common_client/impl/client.h>
+#include <ydb-cpp-sdk/client/proto/accessor.h>
+
+namespace NYdb {
+namespace NSchemeShard {
+
+/// YT
+TBackgroundProcessesResponse::TBackgroundProcessesResponse(TStatus&& status, Ydb::Operations::Operation&& operation)
+    : TOperation(std::move(status), std::move(operation))
+{
+    Metadata_.Id = GetProto().DebugString();
+}
+
+const TBackgroundProcessesResponse::TMetadata& TBackgroundProcessesResponse::Metadata() const {
+    return Metadata_;
+}
+
+} // namespace NExport
+} // namespace NYdb

src/client/ss_tasks/task.h

@@ -0,0 +1,30 @@
+#pragma once
+
+#include <ydb-cpp-sdk/client/driver/driver.h>
+#include <ydb-cpp-sdk/client/types/operation/operation.h>
+
+#include <ydb-cpp-sdk/client/types/s3_settings.h>
+
+namespace NYdb {
+namespace NSchemeShard {
+
+class TBackgroundProcessesResponse: public TOperation {
+private:
+    using TBase = TOperation;
+public:
+    struct TMetadata {
+        std::string Id;
+    };
+
+public:
+    using TOperation::TOperation;
+    TBackgroundProcessesResponse(TStatus&& status, Ydb::Operations::Operation&& operation);
+
+    const TMetadata& Metadata() const;
+
+private:
+    TMetadata Metadata_;
+};
+
+} // namespace NExport
+} // namespace NYdb

src/library/operation_id/operation_id.cpp

@@ -180,6 +180,10 @@ void AddOptionalValue(Ydb::TOperationId& proto, const std::string& key, const st
 }
 
 Ydb::TOperationId::EKind ParseKind(const std::string_view value) {
+    if (value.starts_with("ss/backgrounds")) {
+        return Ydb::TOperationId::SS_BG_TASKS;
+    }
+
     if (value.starts_with("export")) {
         return Ydb::TOperationId::EXPORT;
     }

src/library/operation_id/protos/operation_id.proto

@@ -14,6 +14,7 @@ message TOperationId {
         BUILD_INDEX = 7;
         IMPORT = 8;
         SCRIPT_EXECUTION = 9;
+        SS_BG_TASKS = 10;
     }
 
     message TData {