Moved commit "Add more fields in describe consumer in cpp sdk" from ydb repo

Author: alexnick88

include/ydb-cpp-sdk/client/topic/control_plane.h

@@ -108,12 +108,18 @@ class TPartitionConsumerStats {
     uint64_t GetLastReadOffset() const;
     std::string GetReaderName() const;
     std::string GetReadSessionId() const;
+    const TInstant& GetLastReadTime() const;
+    const TDuration& GetMaxReadTimeLag() const;
+    const TDuration& GetMaxWriteTimeLag() const;
 
 private:
     uint64_t CommittedOffset_;
     int64_t LastReadOffset_;
     std::string ReaderName_;
     std::string ReadSessionId_;
+    TInstant LastReadTime_;
+    TDuration MaxReadTimeLag_;
+    TDuration MaxWriteTimeLag_;
 };
 
 // Topic partition location

src/client/topic/impl/topic.cpp

@@ -351,6 +351,9 @@ TPartitionConsumerStats::TPartitionConsumerStats(const Ydb::Topic::DescribeConsu
     , LastReadOffset_(partitionStats.last_read_offset())
     , ReaderName_(partitionStats.reader_name())
     , ReadSessionId_(partitionStats.read_session_id())
+    , LastReadTime_(TInstant::Seconds(partitionStats.last_read_time().seconds()))
+    , MaxReadTimeLag_(TDuration::Seconds(partitionStats.max_read_time_lag().seconds()))
+    , MaxWriteTimeLag_(TDuration::Seconds(partitionStats.max_write_time_lag().seconds()))
 {}
 
 uint64_t TPartitionConsumerStats::GetCommittedOffset() const {
@@ -369,6 +372,18 @@ std::string TPartitionConsumerStats::GetReadSessionId() const {
     return ReadSessionId_;
 }
 
+const TInstant& TPartitionConsumerStats::GetLastReadTime() const {
+    return LastReadTime_;
+}
+
+const TDuration& TPartitionConsumerStats::GetMaxReadTimeLag() const {
+    return MaxReadTimeLag_;
+}
+
+const TDuration& TPartitionConsumerStats::GetMaxWriteTimeLag() const {
+    return MaxWriteTimeLag_;
+}
+
 TPartitionLocation::TPartitionLocation(const Ydb::Topic::PartitionLocation& partitionLocation)
     : NodeId_(partitionLocation.node_id())
     , Generation_(partitionLocation.generation())

src/client/topic/ut/describe_topic_ut.cpp

@@ -146,6 +146,7 @@ namespace NYdb::NTopic::NTests {
                         UNIT_ASSERT_GT(consumerStats->GetCommittedOffset(), 0);
                         UNIT_ASSERT_GE(TString{consumerStats->GetReadSessionId()}, 0);
                         UNIT_ASSERT_VALUES_EQUAL(consumerStats->GetReaderName(), "");
+                        UNIT_ASSERT_GE(consumerStats->GetMaxWriteTimeLag(), TDuration::Seconds(100));
                     } else {
                         UNIT_ASSERT_VALUES_EQUAL(stats->GetStartOffset(), 0);
                         UNIT_ASSERT_VALUES_EQUAL(consumerStats->GetLastReadOffset(), 0);
@@ -284,7 +285,7 @@ namespace NYdb::NTopic::NTests {
                 std::string message(32_MB, 'x');
 
                 for(size_t i = 0; i < messagesCount; ++i) {
-                    UNIT_ASSERT(writeSession->Write(message));
+                    UNIT_ASSERT(writeSession->Write(message, {}, TInstant::Now() - TDuration::Seconds(100)));
                 }
                 writeSession->Close();
             }
@@ -326,7 +327,21 @@ namespace NYdb::NTopic::NTests {
                 }
             }
 
+            // Additional write
+            {
+                auto writeSettings = TWriteSessionSettings().Path(TEST_TOPIC).MessageGroupId(TEST_MESSAGE_GROUP_ID).Codec(ECodec::RAW);
+                auto writeSession = client.CreateSimpleBlockingWriteSession(writeSettings);
+                std::string message(32, 'x');
+
+                for(size_t i = 0; i < messagesCount; ++i) {
+                    UNIT_ASSERT(writeSession->Write(message));
+                }
+                writeSession->Close();
+            }
+            Sleep(TDuration::Seconds(3));
+
             // Get non-empty description
+
             DescribeTopic(setup, client, true, true, false, false);
             DescribeConsumer(setup, client, true, true, false, false);
             DescribePartition(setup, client, true, true, false, false);