Skip to content

Commit 2e728fd

Browse files
CyberROFLGazizonoki
authored andcommitted
Moved "Add source_changefeed_name to DescribeReplicationResult" commit from ydb repo
1 parent 300ae7b commit 2e728fd

File tree

3 files changed

+6
-0
lines changed

3 files changed

+6
-0
lines changed

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

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,8 @@
33
#include <ydb-cpp-sdk/client/scheme/scheme.h>
44
#include <ydb-cpp-sdk/client/driver/driver.h>
55

6+
#include <optional>
7+
68
namespace Ydb::Replication {
79
class ConnectionParams;
810
class DescribeReplicationResult;
@@ -74,6 +76,7 @@ class TReplicationDescription {
7476
struct TItem {
7577
std::string SrcPath;
7678
std::string DstPath;
79+
std::optional<std::string> SrcChangefeedName;
7780
};
7881

7982
enum class EState {

src/api/protos/draft/ydb_replication.proto

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -43,6 +43,7 @@ message DescribeReplicationResult {
4343
message Item {
4444
string source_path = 1;
4545
string destination_path = 2;
46+
optional string source_changefeed_name = 3;
4647
}
4748

4849
message RunningState {

src/client/draft/ydb_replication.cpp

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -92,6 +92,8 @@ TReplicationDescription::TReplicationDescription(const Ydb::Replication::Describ
9292
Items_.push_back(TItem{
9393
.SrcPath = item.source_path(),
9494
.DstPath = item.destination_path(),
95+
.SrcChangefeedName = item.has_source_changefeed_name()
96+
? std::make_optional(item.source_changefeed_name()) : std::nullopt,
9597
});
9698
}
9799

0 commit comments

Comments
 (0)