@@ -54,28 +54,29 @@ class TPersQueueClient::TImpl : public TClientImplCommon<TPersQueueClient::TImpl
54
54
55
55
props.set_partitions_count (settings.PartitionsCount_ );
56
56
57
- bool autoscalingSettingsDefined = false ;
57
+ bool autoPartitioningSettingsDefined = false ;
58
58
if (settings.MaxPartitionsCount_ .Defined ()) {
59
59
props.mutable_auto_partitioning_settings ()->set_max_active_partitions (settings.PartitionsCount_ );
60
- autoscalingSettingsDefined = true ;
60
+ autoPartitioningSettingsDefined = true ;
61
61
}
62
62
if (settings.AutoPartitioningStrategy_ .Defined ()) {
63
63
props.mutable_auto_partitioning_settings ()->set_strategy (*settings.AutoPartitioningStrategy_ );
64
- autoscalingSettingsDefined = true ;
64
+ autoPartitioningSettingsDefined = true ;
65
65
}
66
66
if (settings.DownUtilizationPercent_ .Defined ()) {
67
67
props.mutable_auto_partitioning_settings ()->mutable_partition_write_speed ()->set_down_utilization_percent (*settings.DownUtilizationPercent_ );
68
- autoscalingSettingsDefined = true ;
68
+ autoPartitioningSettingsDefined = true ;
69
69
}
70
70
if (settings.UpUtilizationPercent_ .Defined ()) {
71
71
props.mutable_auto_partitioning_settings ()->mutable_partition_write_speed ()->set_up_utilization_percent (*settings.UpUtilizationPercent_ );
72
- autoscalingSettingsDefined = true ;
72
+ autoPartitioningSettingsDefined = true ;
73
73
}
74
74
if (settings.StabilizationWindow_ .Defined ()) {
75
75
props.mutable_auto_partitioning_settings ()->mutable_partition_write_speed ()->mutable_stabilization_window ()->set_seconds ((*settings.StabilizationWindow_ ).Seconds ());
76
- autoscalingSettingsDefined = true ;
76
+ autoPartitioningSettingsDefined = true ;
77
77
}
78
- if (!autoscalingSettingsDefined) {
78
+
79
+ if (!autoPartitioningSettingsDefined) {
79
80
props.set_partitions_count (settings.PartitionsCount_ );
80
81
} else {
81
82
props.mutable_auto_partitioning_settings ()->set_min_active_partitions (settings.PartitionsCount_ );
0 commit comments