Fix

Author: niksaveliev

ydb/core/persqueue/ut/common/autoscaling_ut_common.cpp

@@ -124,15 +124,15 @@ std::shared_ptr<ISimpleBlockingWriteSession> CreateWriteSession(TTopicClient& cl
 }
 
 
-TTestReadSession::TTestReadSession(const TString& name, TTopicClient& client, size_t expectedMessagesCount, bool autoCommit, std::set<ui32> partitions, bool autoscalingSupport) {
+TTestReadSession::TTestReadSession(const TString& name, TTopicClient& client, size_t expectedMessagesCount, bool autoCommit, std::set<ui32> partitions, bool autoPartitioningSupport) {
     Impl = std::make_shared<TImpl>(name, autoCommit);
 
     Impl->Acquire();
 
     auto readSettings = TReadSessionSettings()
         .ConsumerName(TEST_CONSUMER)
         .AppendTopics(TEST_TOPIC)
-        .AutoscalingSupport(autoscalingSupport);
+        .AutoPartitioningSupport(autoPartitioningSupport);
     for (auto partitionId : partitions) {
         readSettings.Topics_[0].AppendPartitionIds(partitionId);
     }

ydb/core/persqueue/ut/common/autoscaling_ut_common.h

@@ -42,7 +42,7 @@ struct TTestReadSession {
 
     static constexpr size_t SemCount = 1;
 
-    TTestReadSession(const TString& name, TTopicClient& client, size_t expectedMessagesCount = Max<size_t>(), bool autoCommit = true, std::set<ui32> partitions = {}, bool autoscalingSupport = true);
+    TTestReadSession(const TString& name, TTopicClient& client, size_t expectedMessagesCount = Max<size_t>(), bool autoCommit = true, std::set<ui32> partitions = {}, bool AutoPartitioningSupport = true);
 
     void WaitAllMessages();
 

ydb/public/sdk/cpp/client/ydb_topic/impl/read_session_impl.ipp

@@ -485,7 +485,7 @@ inline void TSingleClusterReadSessionImpl<false>::InitImpl(TDeferredActions<fals
     auto& init = *req.mutable_init_request();
 
     init.set_consumer(Settings.ConsumerName_);
-    init.set_autoscaling_support(Settings.AutoscalingSupport_);
+    init.set_auto_partitioning_support(Settings.AutoPartitioningSupport_);
 
     for (const TTopicReadSettings& topic : Settings.Topics_) {
         auto* topicSettings = init.add_topics_read_settings();

ydb/public/sdk/cpp/client/ydb_topic/include/control_plane.h

@@ -158,7 +158,7 @@ struct TAlterPartitioningSettings;
 struct TAlterTopicSettings;
 
 struct TAutoPartitioningSettings {
-friend struct TAutoscalingSettingsBuilder;
+friend struct TAutoPartitioningSettingsBuilder;
 public:
     TAutoPartitioningSettings()
         : Strategy_(EAutoPartitioningStrategy::Disabled)
@@ -566,10 +566,10 @@ struct TCreateTopicSettings : public TOperationRequestSettings<TCreateTopicSetti
     TPartitioningSettingsBuilder BeginConfigurePartitioningSettings();
 };
 
-struct TAutoscalingSettingsBuilder {
-    using TSelf = TAutoscalingSettingsBuilder;
+struct TAutoPartitioningSettingsBuilder {
+    using TSelf = TAutoPartitioningSettingsBuilder;
 public:
-    TAutoscalingSettingsBuilder(TPartitioningSettingsBuilder& parent, TAutoPartitioningSettings& settings): Parent_(parent), Settings_(settings) {}
+    TAutoPartitioningSettingsBuilder(TPartitioningSettingsBuilder& parent, TAutoPartitioningSettings& settings): Parent_(parent), Settings_(settings) {}
 
     TSelf Strategy(EAutoPartitioningStrategy value) {
         Settings_.Strategy_ = value;
@@ -615,7 +615,7 @@ struct TPartitioningSettingsBuilder {
         return *this;
     }
 
-    TAutoscalingSettingsBuilder BeginConfigureAutoPartitioningSettings() {
+    TAutoPartitioningSettingsBuilder BeginConfigureAutoPartitioningSettings() {
         return {*this, Parent_.PartitioningSettings_.AutoPartitioningSettings_};
     }
 

ydb/public/sdk/cpp/client/ydb_topic/include/read_session.h

@@ -193,8 +193,8 @@ struct TReadSessionSettings: public TRequestSettings<TReadSessionSettings> {
 
     FLUENT_SETTING_DEFAULT(TDuration, ConnectTimeout, TDuration::Seconds(30));
 
-    //! AutoscalingSupport.
-    FLUENT_SETTING_DEFAULT(bool, AutoscalingSupport, false);
+    //! AutoPartitioningSupport.
+    FLUENT_SETTING_DEFAULT(bool, AutoPartitioningSupport, false);
 
     //! Log.
     FLUENT_SETTING_OPTIONAL(TLog, Log);

ydb/services/persqueue_v1/actors/read_session_actor.cpp

@@ -59,7 +59,7 @@ TReadSessionActor<UseMigrationProtocol>::TReadSessionActor(
     , ReadsInfly(0)
     , TopicsHandler(topicsHandler)
     , DirectRead(false)
-    , AutoscalingSupport(false)
+    , AutoPartitioningSupport(false)
 {
     Y_ASSERT(Request);
 }
@@ -758,7 +758,7 @@ void TReadSessionActor<UseMigrationProtocol>::Handle(typename TEvReadInit::TPtr&
         if (init.reader_name()) {
             PeerName = init.reader_name();
         }
-        AutoscalingSupport = init.auto_partitioning_support();
+        AutoPartitioningSupport = init.auto_partitioning_support();
     }
 
     if (MaxTimeLagMs < 0) {
@@ -2327,10 +2327,10 @@ void TReadSessionActor<UseMigrationProtocol>::Handle(TEvPQProxy::TEvReadingFinis
     }
 
     auto& topic = it->second;
-    NTabletPipe::SendData(ctx, topic.PipeClient, new TEvPersQueue::TEvReadingPartitionFinishedRequest(ClientId, msg->PartitionId, AutoscalingSupport, msg->FirstMessage));
+    NTabletPipe::SendData(ctx, topic.PipeClient, new TEvPersQueue::TEvReadingPartitionFinishedRequest(ClientId, msg->PartitionId, AutoPartitioningSupport, msg->FirstMessage));
 
     if constexpr (!UseMigrationProtocol) {
-        if (AutoscalingSupport) {
+        if (AutoPartitioningSupport) {
             TPartitionActorInfo* partitionInfo = nullptr;
             for (auto& [_, p] : Partitions) {
                 if (p.Partition.Partition == msg->PartitionId) {

ydb/services/persqueue_v1/actors/read_session_actor.h

@@ -451,7 +451,7 @@ class TReadSessionActor
     NPersQueue::TTopicsToConverter TopicsList;
 
     bool DirectRead;
-    bool AutoscalingSupport;
+    bool AutoPartitioningSupport;
 };
 
 }