Moved commit "Report & show replication lag" from ydb repo

Author: CyberROFL

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

@@ -5,6 +5,8 @@
 
 #include <optional>
 
+#include <util/datetime/base.h>
+
 namespace Ydb::Replication {
     class ConnectionParams;
     class DescribeReplicationResult;
@@ -56,7 +58,17 @@ class TConnectionParams: private TCommonClientSettings {
     > Credentials_;
 };
 
-struct TRunningState {};
+struct TRunningState {
+public:
+    TRunningState() = default;
+    explicit TRunningState(const std::optional<TDuration>& lag);
+
+    const std::optional<TDuration>& GetLag() const;
+
+private:
+    std::optional<TDuration> Lag_;
+};
+
 struct TDoneState {};
 
 class TErrorState {

src/client/draft/ydb_replication.cpp

@@ -10,6 +10,7 @@
 #include <src/client/common_client/impl/client.h>
 #include <ydb-cpp-sdk/client/proto/accessor.h>
 
+#include <google/protobuf/util/time_util.h>
 #include <google/protobuf/repeated_field.h>
 
 namespace NYdb {
@@ -58,6 +59,15 @@ const TOAuthCredentials& TConnectionParams::GetOAuthCredentials() const {
     return std::get<TOAuthCredentials>(Credentials_);
 }
 
+TRunningState::TRunningState(const std::optional<TDuration>& lag)
+    : Lag_(lag)
+{
+}
+
+const std::optional<TDuration>& TRunningState::GetLag() const {
+    return Lag_;
+}
+
 class TErrorState::TImpl {
 public:
     NYql::TIssues Issues;
@@ -77,6 +87,10 @@ const NYql::TIssues& TErrorState::GetIssues() const {
     return Impl_->Issues;
 }
 
+TDuration DurationToDuration(const google::protobuf::Duration& value) {
+    return TDuration::MilliSeconds(google::protobuf::util::TimeUtil::DurationToMilliseconds(value));
+}
+
 template <typename T>
 NYql::TIssues IssuesFromMessage(const ::google::protobuf::RepeatedPtrField<T>& message) {
     NYql::TIssues issues;
@@ -100,7 +114,8 @@ TReplicationDescription::TReplicationDescription(const Ydb::Replication::Describ
 
     switch (desc.state_case()) {
     case Ydb::Replication::DescribeReplicationResult::kRunning:
-        State_ = TRunningState();
+        State_ = TRunningState(desc.running().has_lag()
+            ? std::make_optional(DurationToDuration(desc.running().lag())) : std::nullopt);
         break;
 
     case Ydb::Replication::DescribeReplicationResult::kError: