Skip to content

Commit 7a70b5c

Browse files
committed
Moved commit "Add PAUSED strategy for autopartitioning of the topic" from ydb repo
1 parent f012456 commit 7a70b5c

File tree

3 files changed

+5
-0
lines changed

3 files changed

+5
-0
lines changed

include/ydb-cpp-sdk/client/datastreams/datastreams.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -106,6 +106,7 @@ namespace NYdb::NDataStreams::V1 {
106106
Disabled = 1,
107107
ScaleUp = 2,
108108
ScaleUpAndDown = 3,
109+
Paused = 4,
109110
};
110111

111112
struct TCreateStreamSettings;

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,7 @@ enum class EAutoPartitioningStrategy: uint32_t {
3333
Disabled = 1,
3434
ScaleUp = 2,
3535
ScaleUpAndDown = 3,
36+
Paused = 4,
3637
};
3738

3839
class TConsumer {

src/client/datastreams/datastreams.cpp

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -35,6 +35,9 @@ namespace NYdb::NDataStreams::V1 {
3535
case EAutoPartitioningStrategy::ScaleUpAndDown:
3636
strategy = ::Ydb::DataStreams::V1::AutoPartitioningStrategy::AUTO_PARTITIONING_STRATEGY_SCALE_UP_AND_DOWN;
3737
break;
38+
case EAutoPartitioningStrategy::Paused:
39+
strategy = ::Ydb::DataStreams::V1::AutoPartitioningStrategy::AUTO_PARTITIONING_STRATEGY_PAUSED;
40+
break;
3841
}
3942

4043
pt->mutable_auto_partitioning_settings()->set_strategy(strategy);

0 commit comments

Comments
 (0)