Added the ability to pause and resume transfers (#16339)

Author: nshestakov

include/ydb-cpp-sdk/client/draft/ydb_replication.h

@@ -100,6 +100,8 @@ class TRunningState {
 
 struct TDoneState {};
 
+struct TPausedState {};
+
 class TErrorState {
     class TImpl;
 
@@ -131,6 +133,7 @@ class TReplicationDescription {
         Running,
         Error,
         Done,
+        Paused,
     };
 
     explicit TReplicationDescription(const Ydb::Replication::DescribeReplicationResult& desc);
@@ -145,6 +148,7 @@ class TReplicationDescription {
     const TRunningState& GetRunningState() const;
     const TErrorState& GetErrorState() const;
     const TDoneState& GetDoneState() const;
+    const TPausedState& GetPausedState() const;
 
 private:
     TConnectionParams ConnectionParams_;
@@ -158,7 +162,8 @@ class TReplicationDescription {
     std::variant<
         TRunningState,
         TErrorState,
-        TDoneState
+        TDoneState,
+        TPausedState
     > State_;
 };
 

src/api/protos/draft/ydb_replication.proto

@@ -77,6 +77,9 @@ message DescribeReplicationResult {
     message DoneState {
     }
 
+    message PausedState {
+    }
+
     // Description of scheme object.
     Ydb.Scheme.Entry self = 1;
 
@@ -90,6 +93,7 @@ message DescribeReplicationResult {
         RunningState running = 4;
         ErrorState error = 5;
         DoneState done = 6;
+        PausedState paused = 9;
     }
 }
 

src/client/draft/ydb_replication.cpp

@@ -162,6 +162,10 @@ TReplicationDescription::TReplicationDescription(const Ydb::Replication::Describ
         State_ = TDoneState();
         break;
 
+    case Ydb::Replication::DescribeReplicationResult::kPaused:
+        State_ = TPausedState();
+        break;
+
     default:
         break;
     }
@@ -200,6 +204,10 @@ const TDoneState& TReplicationDescription::GetDoneState() const {
     return std::get<TDoneState>(State_);
 }
 
+const TPausedState& TReplicationDescription::GetPausedState() const {
+    return std::get<TPausedState>(State_);
+}
+
 TDescribeReplicationResult::TDescribeReplicationResult(TStatus&& status, Ydb::Replication::DescribeReplicationResult&& desc)
     : NScheme::TDescribePathResult(std::move(status), desc.self())
     , ReplicationDescription_(desc)