Moved commit "Add few auto partitioning fields to describe and SDK" from ydb repo

Author: niksaveliev

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

@@ -145,14 +145,21 @@ class TPartitionInfo {
     const std::optional<TPartitionConsumerStats>& GetPartitionConsumerStats() const;
     const std::optional<TPartitionLocation>& GetPartitionLocation() const;
 
+    const std::optional<std::string>& GetFromBound() const;
+    const std::optional<std::string>& GetToBound() const;
+
 private:
     uint64_t PartitionId_;
     bool Active_;
     std::vector<uint64_t> ChildPartitionIds_;
     std::vector<uint64_t> ParentPartitionIds_;
+
     std::optional<TPartitionStats> PartitionStats_;
     std::optional<TPartitionConsumerStats> PartitionConsumerStats_;
     std::optional<TPartitionLocation> PartitionLocation_;
+
+    std::optional<std::string> FromBound_;
+    std::optional<std::string> ToBound_;
 };
 
 struct TAlterPartitioningSettings;
@@ -187,8 +194,8 @@ friend struct TAutoPartitioningSettingsBuilder;
 
 struct TAlterAutoPartitioningSettings {
     using TSelf = TAlterAutoPartitioningSettings;
-    public:
-        TAlterAutoPartitioningSettings(TAlterPartitioningSettings& parent): Parent_(parent) {}
+public:
+    TAlterAutoPartitioningSettings(TAlterPartitioningSettings& parent): Parent_(parent) {}
 
     FLUENT_SETTING_OPTIONAL(EAutoPartitioningStrategy, Strategy);
     FLUENT_SETTING_OPTIONAL(TDuration, StabilizationWindow);
@@ -197,8 +204,8 @@ struct TAlterAutoPartitioningSettings {
 
     TAlterPartitioningSettings& EndAlterAutoPartitioningSettings() { return Parent_; };
 
-    private:
-        TAlterPartitioningSettings& Parent_;
+private:
+    TAlterPartitioningSettings& Parent_;
 };
 
 class TPartitioningSettings {
@@ -207,11 +214,11 @@ class TPartitioningSettings {
 public:
     TPartitioningSettings() : MinActivePartitions_(0), MaxActivePartitions_(0), PartitionCountLimit_(0), AutoPartitioningSettings_(){}
     TPartitioningSettings(const Ydb::Topic::PartitioningSettings& settings);
-    TPartitioningSettings(ui64 minActivePartitions, ui64 maxActivePartitions, TAutoPartitioningSettings autoscalingSettings = {})
+    TPartitioningSettings(uint64_t minActivePartitions, uint64_t maxActivePartitions, TAutoPartitioningSettings autoPartitioning = {})
         : MinActivePartitions_(minActivePartitions)
         , MaxActivePartitions_(maxActivePartitions)
         , PartitionCountLimit_(0)
-        , AutoPartitioningSettings_(autoscalingSettings)
+        , AutoPartitioningSettings_(autoPartitioning)
     {
     }
 
@@ -460,6 +467,11 @@ struct TConsumerSettings {
         return *this;
     }
 
+    TConsumerSettings& SetImportant(bool isImportant) {
+        Important_ = isImportant;
+        return *this;
+    }
+
     TSettings& EndAddConsumer() { return Parent_; };
 
 private:

src/client/topic/impl/topic.cpp

@@ -395,13 +395,22 @@ TPartitionInfo::TPartitionInfo(const Ydb::Topic::DescribeTopicResult::PartitionI
     for (const auto& partId : partitionInfo.parent_partition_ids()) {
         ParentPartitionIds_.push_back(partId);
     }
+
     if (partitionInfo.has_partition_stats()) {
         PartitionStats_ = TPartitionStats{partitionInfo.partition_stats()};
     }
 
     if (partitionInfo.has_partition_location()) {
         PartitionLocation_ = TPartitionLocation{partitionInfo.partition_location()};
     }
+
+    if (partitionInfo.has_key_range() && partitionInfo.key_range().has_from_bound()) {
+        FromBound_ = std::string{partitionInfo.key_range().from_bound()};
+    }
+
+    if (partitionInfo.has_key_range() && partitionInfo.key_range().has_to_bound()) {
+        ToBound_ = std::string{partitionInfo.key_range().to_bound()};
+    }
 }
 
 TPartitionInfo::TPartitionInfo(const Ydb::Topic::DescribeConsumerResult::PartitionInfo& partitionInfo)
@@ -437,6 +446,14 @@ const std::optional<TPartitionLocation>& TPartitionInfo::GetPartitionLocation()
     return PartitionLocation_;
 }
 
+const std::vector<uint64_t> TPartitionInfo::GetChildPartitionIds() const {
+    return ChildPartitionIds_;
+}
+
+const std::vector<uint64_t> TPartitionInfo::GetParentPartitionIds() const {
+    return ParentPartitionIds_;
+}
+
 bool TPartitionInfo::GetActive() const {
     return Active_;
 }
@@ -445,6 +462,14 @@ uint64_t TPartitionInfo::GetPartitionId() const {
     return PartitionId_;
 }
 
+const std::optional<std::string>& TPartitionInfo::GetFromBound() const {
+    return FromBound_;
+}
+
+const std::optional<std::string>& TPartitionInfo::GetToBound() const {
+    return ToBound_;
+}
+
 ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
 // TTopicClient