Added support for the transfer describe to YDB CLI (#20401)

Author: nshestakov

.github/last_commit.txt

@@ -1 +1 @@
-ca39c1dc5e3592adab111f61e4aaec2021bfa95b
+b221825ccb0f9e8813d5df19a7167ecdd5b9f098

include/ydb-cpp-sdk/client/proto/accessor.h

@@ -54,6 +54,7 @@ class TProtoAccessor {
     static const Ydb::Import::ListObjectsInS3ExportResult& GetProto(const NYdb::NImport::TListObjectsInS3ExportResult& result);
 #ifdef YDB_SDK_INTERNAL_CLIENTS
     static const Ydb::Replication::DescribeReplicationResult& GetProto(const NYdb::NReplication::TDescribeReplicationResult& desc);
+    static const Ydb::Replication::DescribeTransferResult& GetProto(const NYdb::NReplication::TDescribeTransferResult& desc);
     static const Ydb::View::DescribeViewResult& GetProto(const NYdb::NView::TDescribeViewResult& desc);
 #endif
 

include/ydb-cpp-sdk/client/scheme/scheme.h

@@ -51,6 +51,7 @@ enum class ESchemeEntryType : i32 {
     View = 20,
     ResourcePool = 21,
     SysView = 22,
+    Transfer = 23,
 };
 
 struct TVirtualTimestamp {

src/api/grpc/draft/ydb_replication_v1.proto

@@ -7,4 +7,5 @@ option java_package = "com.yandex.ydb.replication.v1";
 
 service ReplicationService {
     rpc DescribeReplication(Replication.DescribeReplicationRequest) returns (Replication.DescribeReplicationResponse);
+    rpc DescribeTransfer(Replication.DescribeTransferRequest) returns (Replication.DescribeTransferResponse);
 }

src/api/protos/draft/ydb_replication.proto

@@ -97,3 +97,52 @@ message DescribeReplicationResult {
     }
 }
 
+message DescribeTransferRequest {
+    Ydb.Operations.OperationParams operation_params = 1;
+    // Replication path.
+    string path = 2 [(required) = true];
+}
+
+message DescribeTransferResponse {
+    // Result of request will be inside operation.
+    Ydb.Operations.Operation operation = 1;
+}
+
+message DescribeTransferResult {
+    message RunningState {
+    }
+
+    message ErrorState {
+        repeated Ydb.Issue.IssueMessage issues = 1;
+    }
+
+    message DoneState {
+    }
+
+    message PausedState {
+    }
+
+    // Description of scheme object.
+    Ydb.Scheme.Entry self = 1;
+
+    ConnectionParams connection_params = 2;
+
+    oneof state {
+        RunningState running = 3;
+        ErrorState error = 4;
+        DoneState done = 5;
+        PausedState paused = 6;
+    }
+
+    string source_path = 7;
+    string destination_path = 8;
+    string transformation_lambda = 9;
+    string consumer_name = 10;
+
+    message BatchSettings {
+        optional uint64 size_bytes = 1;
+        google.protobuf.Duration flush_interval = 2;
+    }
+
+    optional BatchSettings batch_settings = 11;
+}

src/client/scheme/scheme.cpp

@@ -111,6 +111,8 @@ static ESchemeEntryType ConvertProtoEntryType(::Ydb::Scheme::Entry::Type entry)
         return ESchemeEntryType::ResourcePool;
     case ::Ydb::Scheme::Entry::SYS_VIEW:
         return ESchemeEntryType::SysView;
+    case ::Ydb::Scheme::Entry::TRANSFER:
+        return ESchemeEntryType::Transfer;
     default:
         return ESchemeEntryType::Unknown;
     }