Use empty message instead of bool

ydb-platform · May 22, 2024 · 3b1f52c · 3b1f52c
1 parent 2d63f85
commit 3b1f52c
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/ydb/core/protos/flat_scheme_op.proto b/ydb/core/protos/flat_scheme_op.proto
@@ -828,7 +828,7 @@ message TCreateCdcStream {
     optional uint64 RetentionPeriodSeconds = 3 [default = 86400]; // 1d by default
     optional uint32 TopicPartitions = 4;
     oneof IndexMode {
-        bool AllIndexes = 5; // Create topic per each index
+        google.protobuf.Empty AllIndexes = 5; // Create topic per each index
         string IndexName = 6;
     }
 }

diff --git a/ydb/core/tx/schemeshard/schemeshard__operation_create_cdc_stream.cpp b/ydb/core/tx/schemeshard/schemeshard__operation_create_cdc_stream.cpp
@@ -979,7 +979,7 @@ TVector<ISubOperation::TPtr> CreateNewCdcStream(TOperationId opId, const TTxTran
 
     std::vector<TString> candidates;
 
-    if (op.GetIndexModeCase() == NKikimrSchemeOp::TCreateCdcStream::kAllIndexes && op.GetAllIndexes()) {
+    if (op.GetIndexModeCase() == NKikimrSchemeOp::TCreateCdcStream::kAllIndexes) {
         candidates.reserve(tablePath->GetChildren().size());
         for (const auto& child : tablePath->GetChildren()) {
             candidates.emplace_back(child.first);

diff --git a/ydb/core/tx/schemeshard/ut_cdc_stream_reboots/ut_cdc_stream_reboots.cpp b/ydb/core/tx/schemeshard/ut_cdc_stream_reboots/ut_cdc_stream_reboots.cpp
@@ -61,7 +61,7 @@ Y_UNIT_TEST_SUITE(TCdcStreamWithRebootsTests) {
             TestCreateCdcStream(runtime, ++t.TxId, "/MyRoot", Sprintf(R"(
                 TableName: "Table"
                 StreamDescription { %s }
-                AllIndexes: true
+                AllIndexes {}
             )", strDesc.c_str()));
             t.TestEnv->TestWaitNotification(runtime, t.TxId);