Secure (GRPC-based) pull/offsets replacement

2 files changed, 20 insertions, 0 deletions

diff --git a/ydb/public/sdk/cpp/client/ydb_topic/impl/topic.cpp b/ydb/public/sdk/cpp/client/ydb_topic/impl/topic.cpp
index 4b02afae62c..25414309966 100644
--- a/ydb/public/sdk/cpp/client/ydb_topic/impl/topic.cpp
+++ b/ydb/public/sdk/cpp/client/ydb_topic/impl/topic.cpp
@@ -284,12 +284,26 @@ ui64 TPartitionStats::GetBytesWrittenPerDay() const {
 
 TPartitionConsumerStats::TPartitionConsumerStats(const Ydb::Topic::DescribeConsumerResult::PartitionConsumerStats& partitionStats)
     : CommittedOffset_(partitionStats.committed_offset())
+    , LastReadOffset_(partitionStats.last_read_offset())
+    , ReaderName_(partitionStats.reader_name())
+    , ReadSessionId_(partitionStats.read_session_id())
 {}
 
 ui64 TPartitionConsumerStats::GetCommittedOffset() const {
     return CommittedOffset_;
 }
 
+ui64 TPartitionConsumerStats::GetLastReadOffset() const {
+    return LastReadOffset_;
+}
+
+TString TPartitionConsumerStats::GetReaderName() const {
+    return ReaderName_;
+}
+
+TString TPartitionConsumerStats::GetReadSessionId() const {
+    return ReadSessionId_;
+}
 
 
 TPartitionInfo::TPartitionInfo(const Ydb::Topic::DescribeTopicResult::PartitionInfo& partitionInfo)
diff --git a/ydb/public/sdk/cpp/client/ydb_topic/topic.h b/ydb/public/sdk/cpp/client/ydb_topic/topic.h
index 4ca694b04cd..40ba536e48b 100644
--- a/ydb/public/sdk/cpp/client/ydb_topic/topic.h
+++ b/ydb/public/sdk/cpp/client/ydb_topic/topic.h
@@ -113,9 +113,15 @@ class TPartitionConsumerStats {
 public:
     TPartitionConsumerStats(const Ydb::Topic::DescribeConsumerResult::PartitionConsumerStats& partitionStats);
     ui64 GetCommittedOffset() const;
+    ui64 GetLastReadOffset() const;
+    TString GetReaderName() const;
+    TString GetReadSessionId() const;
 
 private:
     ui64 CommittedOffset_;
+    i64 LastReadOffset_;
+    TString ReaderName_;
+    TString ReadSessionId_;
 };
 
 class TPartitionInfo {