diff options
author | Alexander Rutkovsky <alexander.rutkovsky@gmail.com> | 2022-05-06 15:12:30 +0300 |
---|---|---|
committer | Alexander Rutkovsky <alexander.rutkovsky@gmail.com> | 2022-05-06 15:12:30 +0300 |
commit | 8db3cc37187f35d7768f073b5880e559b6767bdf (patch) | |
tree | a44226f7989460934dab7997d4495608298c0057 | |
parent | 1dc834e40542d19fdea6d90bd58b5ce5c2a2c956 (diff) | |
download | ydb-8db3cc37187f35d7768f073b5880e559b6767bdf.tar.gz |
Remove duplicate tablet type names KIKIMR-14867
ref:8758126ab796d30d75f9d4d2e99de4564c238650
56 files changed, 222 insertions, 252 deletions
diff --git a/ydb/core/base/blobstorage.h b/ydb/core/base/blobstorage.h index d7cd026c81..105d4399a7 100644 --- a/ydb/core/base/blobstorage.h +++ b/ydb/core/base/blobstorage.h @@ -315,7 +315,7 @@ public: // TTabletStorageInfo() : TabletID(Max<ui64>()) - , TabletType(TTabletTypes::TYPE_INVALID) + , TabletType(TTabletTypes::TypeInvalid) , Version(0) {} TTabletStorageInfo(ui64 tabletId, TTabletTypes::EType tabletType) diff --git a/ydb/core/base/tablet_types.h b/ydb/core/base/tablet_types.h index f585819299..f48a0eaf87 100644 --- a/ydb/core/base/tablet_types.h +++ b/ydb/core/base/tablet_types.h @@ -12,36 +12,6 @@ namespace NKikimr { //////////////////////////////////////////// struct TTabletTypes : NKikimrTabletBase::TTabletTypes { public: - static constexpr EType USER_TYPE_START = UserTypeStart; - static constexpr EType TYPE_INVALID = TypeInvalid; - static constexpr EType FLAT_SCHEMESHARD = SchemeShard; - static constexpr EType FLAT_DATASHARD = DataShard; - static constexpr EType COLUMNSHARD = ColumnShard; - static constexpr EType KEYVALUEFLAT = KeyValue; - static constexpr EType PERSQUEUE = PersQueue; - static constexpr EType PERSQUEUE_READ_BALANCER = PersQueueReadBalancer; - static constexpr EType TX_DUMMY = Dummy; - static constexpr EType FLAT_TX_COORDINATOR = Coordinator; - static constexpr EType TX_MEDIATOR = Mediator; - static constexpr EType FLAT_HIVE = Hive; - static constexpr EType FLAT_BS_CONTROLLER = BSController; - static constexpr EType TX_ALLOCATOR = TxAllocator; - static constexpr EType NODE_BROKER = NodeBroker; - static constexpr EType CMS = Cms; - static constexpr EType RTMR_PARTITION = RTMRPartition; - static constexpr EType BLOCKSTORE_VOLUME = BlockStoreVolume; - static constexpr EType BLOCKSTORE_PARTITION = BlockStorePartition; - static constexpr EType BLOCKSTORE_PARTITION2 = BlockStorePartition2; - static constexpr EType BLOCKSTORE_DISK_REGISTRY = BlockStoreDiskRegistry; - static constexpr EType TENANT_SLOT_BROKER = TenantSlotBroker; - static constexpr EType CONSOLE = Console; - static constexpr EType KESUS = Kesus; - static constexpr EType SYS_VIEW_PROCESSOR = SysViewProcessor; - static constexpr EType FILESTORE = FileStore; - static constexpr EType TESTSHARD = TestShard; - static constexpr EType SEQUENCESHARD = SequenceShard; - static constexpr EType REPLICATION_CONTROLLER = ReplicationController; - static const char* TypeToStr(EType t) { return EType_Name(t).c_str(); } diff --git a/ydb/core/blobstorage/nodewarden/blobstorage_node_warden_ut.cpp b/ydb/core/blobstorage/nodewarden/blobstorage_node_warden_ut.cpp index e3c74cce7b..8a781afe8c 100644 --- a/ydb/core/blobstorage/nodewarden/blobstorage_node_warden_ut.cpp +++ b/ydb/core/blobstorage/nodewarden/blobstorage_node_warden_ut.cpp @@ -257,7 +257,7 @@ void SetupServices(TTestActorRuntime &runtime, TString extraPath, TIntrusivePtr< ui64 defaultStateStorageGroup = runtime.GetAppData(0).DomainsInfo->GetDefaultStateStorageGroup(DOMAIN_ID); CreateTestBootstrapper(runtime, CreateTestTabletInfo(MakeBSControllerID(defaultStateStorageGroup), - TTabletTypes::FLAT_BS_CONTROLLER, TBlobStorageGroupType::ErasureMirror3, groupId), + TTabletTypes::BSController, TBlobStorageGroupType::ErasureMirror3, groupId), &CreateFlatBsController); SetupBoxAndStoragePool(runtime, runtime.AllocateEdgeActor(), domainId); diff --git a/ydb/core/blobstorage/nodewarden/ut_sequence/dsproxy_config_retrieval.cpp b/ydb/core/blobstorage/nodewarden/ut_sequence/dsproxy_config_retrieval.cpp index 040411e06c..7aca70b068 100644 --- a/ydb/core/blobstorage/nodewarden/ut_sequence/dsproxy_config_retrieval.cpp +++ b/ydb/core/blobstorage/nodewarden/ut_sequence/dsproxy_config_retrieval.cpp @@ -79,7 +79,7 @@ void SetupServices(TTestBasicRuntime& runtime) { runtime.Initialize(app.Unwrap()); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(MakeBSControllerID(0), TTabletTypes::FLAT_BS_CONTROLLER), &CreateFlatBsController); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(MakeBSControllerID(0), TTabletTypes::BSController), &CreateFlatBsController); // setup box and storage pool for testing { diff --git a/ydb/core/blobstorage/ut_blobstorage/lib/env.h b/ydb/core/blobstorage/ut_blobstorage/lib/env.h index 685594fa4c..3aef0e6fcd 100644 --- a/ydb/core/blobstorage/ut_blobstorage/lib/env.h +++ b/ydb/core/blobstorage/ut_blobstorage/lib/env.h @@ -276,7 +276,7 @@ struct TEnvironmentSetup { void SetupTablet() { Runtime->CreateTestBootstrapper( - TTestActorSystem::CreateTestTabletInfo(TabletId, TTabletTypes::FLAT_BS_CONTROLLER, Settings.Erasure.GetErasure(), GroupId), + TTestActorSystem::CreateTestTabletInfo(TabletId, TTabletTypes::BSController, Settings.Erasure.GetErasure(), GroupId), &CreateFlatBsController, Settings.ControllerNodeId); diff --git a/ydb/core/client/client_ut.cpp b/ydb/core/client/client_ut.cpp index b94c722588..849a20f874 100644 --- a/ydb/core/client/client_ut.cpp +++ b/ydb/core/client/client_ut.cpp @@ -2064,7 +2064,7 @@ Y_UNIT_TEST_SUITE(TClientTest) { TTestActorRuntime &runtime = *server.GetRuntime(); const ui64 tabletId = ChangeStateStorage(DummyTablet1, settings.Domain); - TIntrusivePtr<TTabletStorageInfo> tabletInfo = CreateTestTabletInfo(tabletId, TTabletTypes::TX_DUMMY); + TIntrusivePtr<TTabletStorageInfo> tabletInfo = CreateTestTabletInfo(tabletId, TTabletTypes::Dummy); TIntrusivePtr<TTabletSetupInfo> setupInfo = new TTabletSetupInfo(&CreateFlatDummyTablet, TMailboxType::Simple, 0, TMailboxType::Simple, 0); const TActorId edge = runtime.AllocateEdgeActor(); @@ -2144,7 +2144,7 @@ Y_UNIT_TEST_SUITE(TClientTest) { TTestActorRuntime &runtime = *server.GetRuntime(); const ui64 tabletId = ChangeStateStorage(DummyTablet1, settings.Domain); - TIntrusivePtr<TTabletStorageInfo> tabletInfo = CreateTestTabletInfo(tabletId, TTabletTypes::TX_DUMMY); + TIntrusivePtr<TTabletStorageInfo> tabletInfo = CreateTestTabletInfo(tabletId, TTabletTypes::Dummy); TIntrusivePtr<TTabletSetupInfo> setupInfo = new TTabletSetupInfo(&CreateFlatDummyTablet, TMailboxType::Simple, 0, TMailboxType::Simple, 0); const TActorId edge = runtime.AllocateEdgeActor(); @@ -2195,7 +2195,7 @@ Y_UNIT_TEST_SUITE(TClientTest) { TTestActorRuntime &runtime = *server.GetRuntime(); const ui64 tabletId = ChangeStateStorage(DummyTablet1, settings.Domain); - TIntrusivePtr<TTabletStorageInfo> tabletInfo = CreateTestTabletInfo(tabletId, TTabletTypes::TX_DUMMY); + TIntrusivePtr<TTabletStorageInfo> tabletInfo = CreateTestTabletInfo(tabletId, TTabletTypes::Dummy); TIntrusivePtr<TTabletSetupInfo> setupInfo = new TTabletSetupInfo(&CreateFlatDummyTablet, TMailboxType::Simple, 0, TMailboxType::Simple, 0); const TActorId edge = runtime.AllocateEdgeActor(); @@ -2318,7 +2318,7 @@ Y_UNIT_TEST_SUITE(TClientTest) { TTestActorRuntime &runtime = *server.GetRuntime(); const ui64 tabletId = ChangeStateStorage(DummyTablet1, settings.Domain); - TIntrusivePtr<TTabletStorageInfo> tabletInfo = CreateTestTabletInfo(tabletId, TTabletTypes::TX_DUMMY); + TIntrusivePtr<TTabletStorageInfo> tabletInfo = CreateTestTabletInfo(tabletId, TTabletTypes::Dummy); TIntrusivePtr<TTabletSetupInfo> setupInfo = new TTabletSetupInfo(&CreateFlatDummyTablet, TMailboxType::Simple, 0, TMailboxType::Simple, 0); const TActorId edge = runtime.AllocateEdgeActor(); @@ -2509,7 +2509,7 @@ Y_UNIT_TEST_SUITE(TClientTest) { TTestActorRuntime &runtime = *server.GetRuntime(); const ui64 tabletId = ChangeStateStorage(DummyTablet1, settings.Domain); - TIntrusivePtr<TTabletStorageInfo> tabletInfo = CreateTestTabletInfo(tabletId, TTabletTypes::TX_DUMMY); + TIntrusivePtr<TTabletStorageInfo> tabletInfo = CreateTestTabletInfo(tabletId, TTabletTypes::Dummy); TIntrusivePtr<TTabletSetupInfo> setupInfo = new TTabletSetupInfo(&CreateFlatDummyTablet, TMailboxType::Simple, 0, TMailboxType::Simple, 0); // Start leader on node 1 @@ -2670,7 +2670,7 @@ Y_UNIT_TEST_SUITE(TClientTest) { TTestActorRuntime &runtime = *server.GetRuntime(); const ui64 tabletId = ChangeStateStorage(DummyTablet1, settings.Domain); - TIntrusivePtr<TTabletStorageInfo> tabletInfo = CreateTestTabletInfo(tabletId, TTabletTypes::TX_DUMMY); + TIntrusivePtr<TTabletStorageInfo> tabletInfo = CreateTestTabletInfo(tabletId, TTabletTypes::Dummy); TIntrusivePtr<TTabletSetupInfo> setupInfo = new TTabletSetupInfo(&CreateFlatDummyTablet, TMailboxType::Simple, 0, TMailboxType::Simple, 0); const TActorId leaderEdge = runtime.AllocateEdgeActor(); @@ -2768,7 +2768,7 @@ Y_UNIT_TEST_SUITE(TClientTest) { TTestActorRuntime &runtime = *server.GetRuntime(); const ui64 tabletId = ChangeStateStorage(DummyTablet1, settings.Domain); - TIntrusivePtr<TTabletStorageInfo> tabletInfo = CreateTestTabletInfo(tabletId, TTabletTypes::TX_DUMMY); + TIntrusivePtr<TTabletStorageInfo> tabletInfo = CreateTestTabletInfo(tabletId, TTabletTypes::Dummy); TIntrusivePtr<TTabletSetupInfo> setupInfo = new TTabletSetupInfo(&CreateFlatDummyTablet, TMailboxType::Simple, 0, TMailboxType::Simple, 0); const TActorId edge = runtime.AllocateEdgeActor(); diff --git a/ydb/core/client/server/msgbus_server_pq_metarequest_ut.cpp b/ydb/core/client/server/msgbus_server_pq_metarequest_ut.cpp index 0cdd5583c7..b064b0f54d 100644 --- a/ydb/core/client/server/msgbus_server_pq_metarequest_ut.cpp +++ b/ydb/core/client/server/msgbus_server_pq_metarequest_ut.cpp @@ -126,7 +126,7 @@ protected: TActorId StartBalancer(ui64 balancerTabletId) { TActorId id = CreateTestBootstrapper(*Runtime, - CreateTestTabletInfo(balancerTabletId, TTabletTypes::PERSQUEUE_READ_BALANCER, TErasureType::ErasureNone), + CreateTestTabletInfo(balancerTabletId, TTabletTypes::PersQueueReadBalancer, TErasureType::ErasureNone), &CreatePersQueueReadBalancer); TDispatchOptions options; @@ -184,7 +184,7 @@ protected: TActorId StartPQTablet(ui64 tabletId) { TActorId id = CreateTestBootstrapper(*Runtime, - CreateTestTabletInfo(tabletId, TTabletTypes::PERSQUEUE, TErasureType::ErasureNone), + CreateTestTabletInfo(tabletId, TTabletTypes::PersQueue, TErasureType::ErasureNone), &CreatePersQueue); TDispatchOptions options; diff --git a/ydb/core/cms/cms_ut_common.cpp b/ydb/core/cms/cms_ut_common.cpp index 7883923eb9..7141476370 100644 --- a/ydb/core/cms/cms_ut_common.cpp +++ b/ydb/core/cms/cms_ut_common.cpp @@ -426,10 +426,10 @@ static void SetupServices(TTestActorRuntime &runtime, runtime.DispatchEvents(options); } - CreateTestBootstrapper(runtime, CreateTestTabletInfo(MakeBSControllerID(0), TTabletTypes::FLAT_BS_CONTROLLER), + CreateTestBootstrapper(runtime, CreateTestTabletInfo(MakeBSControllerID(0), TTabletTypes::BSController), &CreateFlatBsController); - auto aid = CreateTestBootstrapper(runtime, CreateTestTabletInfo(MakeCmsID(0), TTabletTypes::CMS), &CreateCms); + auto aid = CreateTestBootstrapper(runtime, CreateTestTabletInfo(MakeCmsID(0), TTabletTypes::Cms), &CreateCms); runtime.EnableScheduleForActor(aid, true); } diff --git a/ydb/core/cms/console/console_ut_configs.cpp b/ydb/core/cms/console/console_ut_configs.cpp index 8bf533a4c5..b9afd5c3ad 100644 --- a/ydb/core/cms/console/console_ut_configs.cpp +++ b/ydb/core/cms/console/console_ut_configs.cpp @@ -2423,7 +2423,7 @@ const ui64 CONFIG_PROXY_TABLET_ID = 0x0000000000840103; void StartConfigProxy(TTenantTestRuntime &runtime) { - auto info = CreateTestTabletInfo(CONFIG_PROXY_TABLET_ID, TTabletTypes::TX_DUMMY, TErasureType::ErasureNone); + auto info = CreateTestTabletInfo(CONFIG_PROXY_TABLET_ID, TTabletTypes::Dummy, TErasureType::ErasureNone); TActorId actorId = CreateTestBootstrapper(runtime, info, [&runtime](const TActorId &tablet, TTabletStorageInfo *info) -> IActor* { return new TConfigProxy(tablet, info, runtime.Sender); }); diff --git a/ydb/core/driver_lib/run/kikimr_services_initializers.cpp b/ydb/core/driver_lib/run/kikimr_services_initializers.cpp index 832869da7e..c99a4713d4 100644 --- a/ydb/core/driver_lib/run/kikimr_services_initializers.cpp +++ b/ydb/core/driver_lib/run/kikimr_services_initializers.cpp @@ -1317,7 +1317,7 @@ static TIntrusivePtr<TTabletSetupInfo> CreateTablet( tabletSetup = MakeTabletSetupInfo(tabletType, workPoolId, appData->SystemPoolId); - if (tabletInfo->TabletType == TTabletTypes::TYPE_INVALID) { + if (tabletInfo->TabletType == TTabletTypes::TypeInvalid) { tabletInfo->TabletType = tabletType; } diff --git a/ydb/core/kesus/proxy/ut_helpers.cpp b/ydb/core/kesus/proxy/ut_helpers.cpp index 74580d10f7..0e984c380d 100644 --- a/ydb/core/kesus/proxy/ut_helpers.cpp +++ b/ydb/core/kesus/proxy/ut_helpers.cpp @@ -4,7 +4,7 @@ namespace NKikimr { namespace NKesus { TTestContext::TTestContext() - : TabletType(TTabletTypes::KESUS) + : TabletType(TTabletTypes::Kesus) , TabletId(MakeTabletID(0, 0, 1)) {} diff --git a/ydb/core/kesus/tablet/ut_helpers.cpp b/ydb/core/kesus/tablet/ut_helpers.cpp index f559800a76..0e032afde5 100644 --- a/ydb/core/kesus/tablet/ut_helpers.cpp +++ b/ydb/core/kesus/tablet/ut_helpers.cpp @@ -66,7 +66,7 @@ NActors::TActorId CreateFakeMetering(NActors::TTestActorRuntime &runtime) { } TTestContext::TTestContext() - : TabletType(TTabletTypes::KESUS) + : TabletType(TTabletTypes::Kesus) , TabletId(MakeTabletID(0, 0, 1)) {} diff --git a/ydb/core/keyvalue/keyvalue_collector_ut.cpp b/ydb/core/keyvalue/keyvalue_collector_ut.cpp index 4456a82380..4c7b59b4af 100644 --- a/ydb/core/keyvalue/keyvalue_collector_ut.cpp +++ b/ydb/core/keyvalue/keyvalue_collector_ut.cpp @@ -48,7 +48,7 @@ public: TIntrusivePtr<TTabletStorageInfo> MakeTabletInfo() { TIntrusivePtr<TTabletStorageInfo> x(new TTabletStorageInfo()); x->TabletID = MakeTabletID(0, 0, 1); - x->TabletType = TTabletTypes::KEYVALUEFLAT; + x->TabletType = TTabletTypes::KeyValue; x->Channels.resize(4); for (ui64 channel = 0; channel < x->Channels.size(); ++channel) { x->Channels[channel].Channel = channel; diff --git a/ydb/core/keyvalue/keyvalue_ut.cpp b/ydb/core/keyvalue/keyvalue_ut.cpp index 021e3353bd..2b5eb69c82 100644 --- a/ydb/core/keyvalue/keyvalue_ut.cpp +++ b/ydb/core/keyvalue/keyvalue_ut.cpp @@ -77,7 +77,7 @@ struct TTestContext { TActorId Edge; TTestContext() { - TabletType = TTabletTypes::KEYVALUEFLAT; + TabletType = TTabletTypes::KeyValue; TabletId = MakeTabletID(0, 0, 1); TabletIds.push_back(TabletId); } diff --git a/ydb/core/mind/bscontroller/ut_bscontroller/main.cpp b/ydb/core/mind/bscontroller/ut_bscontroller/main.cpp index 87f7b18fb3..277efd7b66 100644 --- a/ydb/core/mind/bscontroller/ut_bscontroller/main.cpp +++ b/ydb/core/mind/bscontroller/ut_bscontroller/main.cpp @@ -230,7 +230,7 @@ struct TEnvironmentSetup { void SetupTablet() { const TActorId bootstrapper = CreateTestBootstrapper(*Runtime, - CreateTestTabletInfo(TabletId, TTabletTypes::FLAT_BS_CONTROLLER, TErasureType::ErasureNone, GroupId), + CreateTestTabletInfo(TabletId, TTabletTypes::BSController, TErasureType::ErasureNone, GroupId), &CreateFlatBsController, NodeId); Runtime->EnableScheduleForActor(bootstrapper); { diff --git a/ydb/core/mind/bscontroller/ut_selfheal/env.h b/ydb/core/mind/bscontroller/ut_selfheal/env.h index e79bf914a1..3799f7bcef 100644 --- a/ydb/core/mind/bscontroller/ut_selfheal/env.h +++ b/ydb/core/mind/bscontroller/ut_selfheal/env.h @@ -179,7 +179,7 @@ struct TEnvironmentSetup { void SetupTablet() { Runtime->CreateTestBootstrapper( - TTestActorSystem::CreateTestTabletInfo(TabletId, TTabletTypes::FLAT_BS_CONTROLLER, TErasureType::ErasureNone, GroupId), + TTestActorSystem::CreateTestTabletInfo(TabletId, TTabletTypes::BSController, TErasureType::ErasureNone, GroupId), &CreateFlatBsController, NodeId); diff --git a/ydb/core/mind/bscontroller/ut_selfheal/self_heal_actor_ut.cpp b/ydb/core/mind/bscontroller/ut_selfheal/self_heal_actor_ut.cpp index d4205abea8..07da54d7a3 100644 --- a/ydb/core/mind/bscontroller/ut_selfheal/self_heal_actor_ut.cpp +++ b/ydb/core/mind/bscontroller/ut_selfheal/self_heal_actor_ut.cpp @@ -14,7 +14,7 @@ void RunTestCase(TCallback&& callback) { TTestActorSystem runtime(1); runtime.Start(); const TActorId& parentId = runtime.AllocateEdgeActor(1); - TBlobStorageController Controller({}, new TTabletStorageInfo(1, TTabletTypes::FLAT_BS_CONTROLLER)); + TBlobStorageController Controller({}, new TTabletStorageInfo(1, TTabletTypes::BSController)); const TActorId& selfHealId = runtime.Register(Controller.CreateSelfHealActor(), parentId, {}, {}, 1); callback(selfHealId, parentId, runtime); runtime.Stop(); diff --git a/ydb/core/mind/configured_tablet_bootstrapper.cpp b/ydb/core/mind/configured_tablet_bootstrapper.cpp index 008acd2b40..d36ba5d099 100644 --- a/ydb/core/mind/configured_tablet_bootstrapper.cpp +++ b/ydb/core/mind/configured_tablet_bootstrapper.cpp @@ -73,7 +73,7 @@ class TConfiguredTabletBootstrapper : public TActorBootstrapped<TConfiguredTable // extract from kikimr_services_initializer const TTabletTypes::EType tabletType = BootstrapperTypeToTabletType(config.GetType()); - if (storageInfo->TabletType == TTabletTypes::TYPE_INVALID) + if (storageInfo->TabletType == TTabletTypes::TypeInvalid) storageInfo->TabletType = tabletType; TIntrusivePtr<TTabletSetupInfo> tabletSetupInfo = MakeTabletSetupInfo(tabletType, appData->UserPoolId, appData->SystemPoolId); @@ -127,42 +127,42 @@ public: TTabletTypes::EType BootstrapperTypeToTabletType(ui32 type) { switch (type) { case NKikimrConfig::TBootstrap::TX_DUMMY: - return TTabletTypes::TX_DUMMY; + return TTabletTypes::Dummy; case NKikimrConfig::TBootstrap::HIVE: case NKikimrConfig::TBootstrap::FLAT_HIVE: - return TTabletTypes::FLAT_HIVE; + return TTabletTypes::Hive; case NKikimrConfig::TBootstrap::TX_COORDINATOR: case NKikimrConfig::TBootstrap::FLAT_TX_COORDINATOR: - return TTabletTypes::FLAT_TX_COORDINATOR; + return TTabletTypes::Coordinator; case NKikimrConfig::TBootstrap::TX_MEDIATOR: - return TTabletTypes::TX_MEDIATOR; + return TTabletTypes::Mediator; case NKikimrConfig::TBootstrap::BS_DOMAINCONTROLLER: case NKikimrConfig::TBootstrap::FLAT_BS_CONTROLLER: - return TTabletTypes::FLAT_BS_CONTROLLER; + return TTabletTypes::BSController; case NKikimrConfig::TBootstrap::DATASHARD: case NKikimrConfig::TBootstrap::FAKE_DATASHARD: - return TTabletTypes::FLAT_DATASHARD; + return TTabletTypes::DataShard; case NKikimrConfig::TBootstrap::SCHEMESHARD: case NKikimrConfig::TBootstrap::FLAT_SCHEMESHARD: - return TTabletTypes::FLAT_SCHEMESHARD; + return TTabletTypes::SchemeShard; case NKikimrConfig::TBootstrap::KEYVALUEFLAT: - return TTabletTypes::KEYVALUEFLAT; + return TTabletTypes::KeyValue; case NKikimrConfig::TBootstrap::TX_PROXY: case NKikimrConfig::TBootstrap::FLAT_TX_PROXY: case NKikimrConfig::TBootstrap::TX_ALLOCATOR: - return TTabletTypes::TX_ALLOCATOR; + return TTabletTypes::TxAllocator; case NKikimrConfig::TBootstrap::CMS: - return TTabletTypes::CMS; + return TTabletTypes::Cms; case NKikimrConfig::TBootstrap::NODE_BROKER: - return TTabletTypes::NODE_BROKER; + return TTabletTypes::NodeBroker; case NKikimrConfig::TBootstrap::TENANT_SLOT_BROKER: - return TTabletTypes::TENANT_SLOT_BROKER; + return TTabletTypes::TenantSlotBroker; case NKikimrConfig::TBootstrap::CONSOLE: - return TTabletTypes::CONSOLE; + return TTabletTypes::Console; default: Y_FAIL("unknown tablet type"); } - return TTabletTypes::TYPE_INVALID; + return TTabletTypes::TypeInvalid; } TIntrusivePtr<TTabletSetupInfo> MakeTabletSetupInfo( @@ -196,7 +196,7 @@ TIntrusivePtr<TTabletSetupInfo> MakeTabletSetupInfo( case TTabletTypes::KeyValue: createFunc = &CreateKeyValueFlat; break; - case TTabletTypes::CMS: + case TTabletTypes::Cms: createFunc = &NCms::CreateCms; break; case TTabletTypes::NodeBroker: diff --git a/ydb/core/mind/hive/hive_ut.cpp b/ydb/core/mind/hive/hive_ut.cpp index 1bf3502a96..567993e9d7 100644 --- a/ydb/core/mind/hive/hive_ut.cpp +++ b/ydb/core/mind/hive/hive_ut.cpp @@ -286,7 +286,7 @@ namespace { runtime.DispatchEvents(options); } - CreateTestBootstrapper(runtime, CreateTestTabletInfo(MakeBSControllerID(0), TTabletTypes::FLAT_BS_CONTROLLER), + CreateTestBootstrapper(runtime, CreateTestTabletInfo(MakeBSControllerID(0), TTabletTypes::BSController), &CreateFlatBsController); } @@ -800,7 +800,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { Setup(runtime, true); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); MakeSureTabletIsUp(runtime, hiveTablet, 0); TTabletTypes::EType tabletType = TTabletTypes::Dummy; ui64 tabletId = SendCreateTestTablet(runtime, hiveTablet, testerTablet, MakeHolder<TEvHive::TEvCreateTablet>(testerTablet, 0, tabletType, BINDED_CHANNELS), 0, true); @@ -812,7 +812,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { Setup(runtime, true); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); MakeSureTabletIsUp(runtime, hiveTablet, 0); TTabletTypes::EType tabletType = TTabletTypes::Dummy; ui64 tabletId = SendCreateTestTablet(runtime, hiveTablet, testerTablet, MakeHolder<TEvHive::TEvCreateTablet>(testerTablet, 0, tabletType, BINDED_CHANNELS), 0, true); @@ -835,7 +835,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { Setup(runtime, true); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); MakeSureTabletIsUp(runtime, hiveTablet, 0); TTabletTypes::EType tabletType = TTabletTypes::Dummy; TVector<TTabletId> tablets; @@ -861,7 +861,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { Setup(runtime, true); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); { TDispatchOptions options; options.FinalEvents.emplace_back(TEvLocal::EvStatus, NUM_NODES); @@ -1661,7 +1661,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { Setup(runtime, true); setup(runtime); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TAutoPtr<TEvHive::TEvCreateTablet> ev(new TEvHive::TEvCreateTablet(testerTablet, 0, TTabletTypes::Dummy, BINDED_CHANNELS)); const bool doWaitForResult = false; @@ -1688,7 +1688,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TTabletTypes::EType tabletType = TTabletTypes::Dummy; TAutoPtr<TEvHive::TEvCreateTablet> ev(new TEvHive::TEvCreateTablet(testerTablet, 0, tabletType, BINDED_CHANNELS)); @@ -1717,7 +1717,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); CreateLocal(runtime, 0); TTabletTypes::EType tabletType = TTabletTypes::Dummy; @@ -1761,7 +1761,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); CreateLocal(runtime, 0); TTabletTypes::EType tabletType = TTabletTypes::Dummy; @@ -1848,7 +1848,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); CreateLocal(runtime, 0); TTabletTypes::EType tabletType = TTabletTypes::Dummy; @@ -1889,7 +1889,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TActorId sender = runtime.AllocateEdgeActor(); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TTabletTypes::EType tabletType = TTabletTypes::Dummy; const ui64 tabletId = SendCreateTestTablet(runtime, hiveTablet, testerTablet, MakeHolder<TEvHive::TEvCreateTablet>(testerTablet, 0, tabletType, BINDED_CHANNELS), 0, false); { @@ -1916,7 +1916,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TActorId sender = runtime.AllocateEdgeActor(); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TTabletTypes::EType tabletType = TTabletTypes::Dummy; const ui64 tabletId = SendCreateTestTablet(runtime, hiveTablet, testerTablet, MakeHolder<TEvHive::TEvCreateTablet>(testerTablet, 0, tabletType, BINDED_CHANNELS), 0, false); { @@ -1945,7 +1945,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TActorId sender = runtime.AllocateEdgeActor(); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TTabletTypes::EType tabletType = TTabletTypes::Dummy; const ui64 count = 100; TSet<ui64> tabletIds; @@ -1971,7 +1971,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { Setup(runtime, true); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TTabletTypes::EType tabletType = TTabletTypes::Dummy; THolder<TEvHive::TEvCreateTablet> ev(new TEvHive::TEvCreateTablet(testerTablet, 100500, tabletType, BINDED_CHANNELS)); auto* followerGroup = ev->Record.AddFollowerGroups(); @@ -2006,7 +2006,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TActorId sender = runtime.AllocateEdgeActor(); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = 1; - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TTabletTypes::EType tabletType = TTabletTypes::Dummy; const ui64 tabletId = SendCreateTestTablet(runtime, hiveTablet, testerTablet, MakeHolder<TEvHive::TEvCreateTablet>(testerTablet, 0, tabletType, BINDED_CHANNELS), 0, true); MakeSureTabletIsUp(runtime, tabletId, 0); @@ -2031,7 +2031,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TActorId sender = runtime.AllocateEdgeActor(); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TTabletTypes::EType tabletType = TTabletTypes::Dummy; runtime.SendToPipe(hiveTablet, sender, new TEvHive::TEvCreateTablet(testerTablet, 0, tabletType, BINDED_CHANNELS), 0, GetPipeConfigWithRetries()); @@ -2073,7 +2073,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TActorId sender = runtime.AllocateEdgeActor(); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TTabletTypes::EType tabletType = TTabletTypes::Dummy; { @@ -2112,7 +2112,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TActorId sender = runtime.AllocateEdgeActor(); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TTabletTypes::EType tabletType = TTabletTypes::Dummy; ui32 nodeIndex = 0; @@ -2153,7 +2153,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { setup(runtime); TActorId sender = runtime.AllocateEdgeActor(); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TDispatchOptions options; options.FinalEvents.push_back(TDispatchOptions::TFinalEventCondition(TEvTablet::EvBoot)); runtime.DispatchEvents(options); @@ -2192,7 +2192,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TVector<ui64> tabletIds; const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); ui32 nodeIndex = 0; TTabletTypes::EType tabletType = TTabletTypes::Dummy; @@ -2213,7 +2213,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { //TAutoPtr<ITabletScheduledEventsGuard> guard = CreateTabletScheduledEventsGuard(tabletIds, runtime, sender); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TTabletTypes::EType tabletType = TTabletTypes::Dummy; THolder<TEvHive::TEvCreateTablet> ev(new TEvHive::TEvCreateTablet(testerTablet, 100500, tabletType, BINDED_CHANNELS)); @@ -2246,7 +2246,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TVector<ui64> tabletIds; const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); // Kill local on node 1 SendKillLocal(runtime, 1); @@ -2273,7 +2273,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TVector<ui64> tabletIds; const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); // creating tablet ui32 nodeIndex = 0; @@ -2324,7 +2324,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TVector<ui64> tabletIds; const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); // Kill local on node 1 SendKillLocal(runtime, 1); @@ -2346,7 +2346,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { Setup(runtime, true); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TTabletTypes::EType tabletType = TTabletTypes::Dummy; ui64 tabletId = SendCreateTestTablet(runtime, hiveTablet, testerTablet, @@ -2361,7 +2361,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { Setup(runtime, true); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TTabletTypes::EType tabletType = TTabletTypes::Dummy; TChannelsBindings channlesBinds = {GetDefaultChannelBind("NoExistStoragePool"), @@ -2391,7 +2391,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { Setup(runtime, true, 3); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TTabletTypes::EType tabletType = TTabletTypes::Dummy; ui64 tabletId = SendCreateTestTablet(runtime, hiveTablet, testerTablet, @@ -2413,7 +2413,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { Setup(runtime, true, 3); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TTabletTypes::EType tabletType = TTabletTypes::Dummy; ui64 tabletId = SendCreateTestTablet(runtime, hiveTablet, testerTablet, @@ -2476,7 +2476,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TActorId sender = runtime.AllocateEdgeActor(); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TTabletTypes::EType tabletType = TTabletTypes::Dummy; ui64 tabletId = SendCreateTestTablet(runtime, @@ -2545,7 +2545,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { setup(runtime); TActorId sender = runtime.AllocateEdgeActor(); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TDispatchOptions options; options.FinalEvents.push_back(TDispatchOptions::TFinalEventCondition(TEvTablet::EvBoot)); runtime.DispatchEvents(options); @@ -2593,7 +2593,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { // CreatePDiskAndGroup(runtime, sender); // const ui64 hiveTablet = MakeDefaultHiveID(0); // const ui64 testerTablet = MakeDefaultHiveID(1); -// CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); +// CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); // ui32 tabletType = 0; // ui64 tabletId = SendCreateTestTablet(runtime, hiveTablet, testerTablet, @@ -2624,7 +2624,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TActorId sender = runtime.AllocateEdgeActor(); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TTabletTypes::EType tabletType = TTabletTypes::Dummy; ui64 tabletId = SendCreateTestTablet(runtime, hiveTablet, testerTablet, @@ -2646,7 +2646,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TAutoPtr<ITabletScheduledEventsGuard> guard = CreateTabletScheduledEventsGuard(tabletIds, runtime, sender); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TTabletTypes::EType tabletType = TTabletTypes::Dummy; ui64 tabletId = SendCreateTestTablet(runtime, hiveTablet, testerTablet, @@ -2670,7 +2670,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TAutoPtr<ITabletScheduledEventsGuard> guard = CreateTabletScheduledEventsGuard(tabletIds, runtime, senderA); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); // Kill local on node 1 SendKillLocal(runtime, 1); @@ -2696,7 +2696,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TVector<ui64> tabletIds; const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TTabletTypes::EType tabletType = TTabletTypes::Dummy; THolder<TEvHive::TEvCreateTablet> ev(new TEvHive::TEvCreateTablet(testerTablet, 100500, tabletType, BINDED_CHANNELS)); @@ -2723,7 +2723,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { //TAutoPtr<ITabletScheduledEventsGuard> guard = CreateTabletScheduledEventsGuard(tabletIds, runtime, senderA); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TTabletTypes::EType tabletType = TTabletTypes::Dummy; THolder<TEvHive::TEvCreateTablet> ev(new TEvHive::TEvCreateTablet(testerTablet, 100500, tabletType, BINDED_CHANNELS)); @@ -2770,7 +2770,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TVector<ui64> tabletIds; const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); { TDispatchOptions options; options.FinalEvents.emplace_back(TEvLocal::EvSyncTablets, runtime.GetNodeCount()); @@ -2841,7 +2841,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TActorId senderA = runtime.AllocateEdgeActor(); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); { TDispatchOptions options; options.FinalEvents.emplace_back(TEvLocal::EvSyncTablets, runtime.GetNodeCount()); @@ -2881,7 +2881,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { Setup(runtime, true); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TTabletTypes::EType tabletType = TTabletTypes::Dummy; ui64 tabletId = SendCreateTestTablet(runtime, hiveTablet, testerTablet, MakeHolder<TEvHive::TEvCreateTablet>(testerTablet, 0, tabletType, BINDED_CHANNELS), 0, false); @@ -2911,7 +2911,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TActorId senderA = runtime.AllocateEdgeActor(); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); { TDispatchOptions options; options.FinalEvents.emplace_back(TEvLocal::EvStatus, NUM_NODES); @@ -3055,7 +3055,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TActorId senderA = runtime.AllocateEdgeActor(); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); { TDispatchOptions options; options.FinalEvents.emplace_back(TEvLocal::EvStatus, NUM_NODES); @@ -3120,7 +3120,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TActorId senderA = runtime.AllocateEdgeActor(); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); { TDispatchOptions options; options.FinalEvents.emplace_back(TEvLocal::EvStatus, NUM_NODES); @@ -3186,7 +3186,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TActorId senderA = runtime.AllocateEdgeActor(); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); { TDispatchOptions options; options.FinalEvents.emplace_back(TEvLocal::EvStatus, NUM_NODES); @@ -3231,7 +3231,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TActorId senderA = runtime.AllocateEdgeActor(); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); MakeSureTabletIsUp(runtime, hiveTablet, 0); // create NUM_TABLETS tablets @@ -3356,7 +3356,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TActorId senderA = runtime.AllocateEdgeActor(); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); { TDispatchOptions options; options.FinalEvents.emplace_back(TEvLocal::EvStatus, NUM_NODES); @@ -3408,7 +3408,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TVector<ui64> tabletIds; const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); { TDispatchOptions options; options.FinalEvents.emplace_back(TEvLocal::EvSyncTablets, runtime.GetNodeCount()); @@ -3469,7 +3469,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TVector<ui64> tabletIds; const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); { TDispatchOptions options; options.FinalEvents.emplace_back(TEvLocal::EvSyncTablets, runtime.GetNodeCount()); @@ -3617,7 +3617,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TVector<ui64> tabletIds; const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); { TDispatchOptions options; options.FinalEvents.emplace_back(TEvLocal::EvSyncTablets, runtime.GetNodeCount()); @@ -3668,7 +3668,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TVector<ui64> tabletIds; const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); { TDispatchOptions options; options.FinalEvents.emplace_back(TEvLocal::EvSyncTablets, runtime.GetNodeCount()); @@ -3770,7 +3770,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TVector<ui64> tabletIds; const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive, 0); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive, 0); { TDispatchOptions options; options.FinalEvents.emplace_back(TEvLocal::EvSyncTablets, runtime.GetNodeCount()); @@ -3868,7 +3868,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { Setup(runtime, true); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TTabletTypes::EType tabletType = TTabletTypes::Dummy; THolder<TEvHive::TEvCreateTablet> ev(new TEvHive::TEvCreateTablet(testerTablet, 0, tabletType, BINDED_CHANNELS)); @@ -3882,7 +3882,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { Setup(runtime, true); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TTabletTypes::EType tabletType = TTabletTypes::Dummy; THolder<TEvHive::TEvCreateTablet> ev(new TEvHive::TEvCreateTablet(testerTablet, 0, tabletType, BINDED_CHANNELS)); @@ -3905,7 +3905,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { Setup(runtime, true); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TTabletTypes::EType tabletType = TTabletTypes::Dummy; THolder<TEvHive::TEvCreateTablet> ev(new TEvHive::TEvCreateTablet(testerTablet, 0, tabletType, BINDED_CHANNELS)); @@ -3925,7 +3925,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { Setup(runtime, true); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); // Block group assignment runtime.SetObserverFunc([](TTestActorRuntimeBase& runtime, TAutoPtr<IEventHandle>& event) { @@ -4003,7 +4003,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { CreateLocal(runtime, 0); // only the 1st node has local running const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TTabletTypes::EType tabletType = TTabletTypes::Dummy; THolder<TEvHive::TEvCreateTablet> ev(new TEvHive::TEvCreateTablet(testerTablet, 0, tabletType, BINDED_CHANNELS)); @@ -4027,7 +4027,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { CreateLocal(runtime, 0); // only the 1st node has local running const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TTabletTypes::EType tabletType = TTabletTypes::Dummy; THolder<TEvHive::TEvCreateTablet> ev(new TEvHive::TEvCreateTablet(testerTablet, 0, tabletType, BINDED_CHANNELS)); @@ -4046,7 +4046,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { CreateLocal(runtime, 0); // only the 1st node has local running const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - const TActorId hiveActor = CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + const TActorId hiveActor = CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); runtime.EnableScheduleForActor(hiveActor); TTabletTypes::EType tabletType = TTabletTypes::Dummy; @@ -4075,7 +4075,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { CreateLocal(runtime, 0); // only the 1st node has local running const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - const TActorId hiveActor = CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + const TActorId hiveActor = CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); runtime.EnableScheduleForActor(hiveActor); TTabletTypes::EType tabletType = TTabletTypes::Dummy; @@ -4105,7 +4105,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { TActorId sender = runtime.AllocateEdgeActor(); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - const TActorId hiveActor = CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + const TActorId hiveActor = CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); runtime.EnableScheduleForActor(hiveActor); TTabletTypes::EType tabletType = TTabletTypes::Dummy; @@ -4140,7 +4140,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { CreateLocal(runtime, 0); // only the 1st node has local running const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - const TActorId hiveActor = CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + const TActorId hiveActor = CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); runtime.EnableScheduleForActor(hiveActor); TTabletTypes::EType tabletType = TTabletTypes::Dummy; @@ -4208,7 +4208,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { CreateLocal(runtime, 0); // only the 1st node has local running const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - const TActorId hiveActor = CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + const TActorId hiveActor = CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); runtime.EnableScheduleForActor(hiveActor); TTabletTypes::EType tabletType = TTabletTypes::Dummy; @@ -4237,7 +4237,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { CreateLocal(runtime, 0); // only the 1st node has local running const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - const TActorId hiveActor = CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + const TActorId hiveActor = CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); runtime.EnableScheduleForActor(hiveActor); TTabletTypes::EType tabletType = TTabletTypes::Dummy; @@ -4263,7 +4263,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { CreateLocal(runtime, 0); // only the 1st node has local running const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - const TActorId hiveActor = CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + const TActorId hiveActor = CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); runtime.EnableScheduleForActor(hiveActor); TTabletTypes::EType tabletType = TTabletTypes::Dummy; @@ -4312,7 +4312,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { CreateLocal(runtime, 0); // only the 1st node has local running const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TTabletTypes::EType tabletType = TTabletTypes::Dummy; THolder<TEvHive::TEvCreateTablet> ev(new TEvHive::TEvCreateTablet(testerTablet, 0, tabletType, BINDED_CHANNELS)); @@ -4333,7 +4333,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { CreateLocal(runtime, 0); // only the 1st node has local running const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TTabletTypes::EType tabletType = TTabletTypes::Dummy; THolder<TEvHive::TEvCreateTablet> ev(new TEvHive::TEvCreateTablet(testerTablet, 0, tabletType, BINDED_CHANNELS)); @@ -4358,7 +4358,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { CreateLocal(runtime, 0); // only the 1st node has local running const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TTabletTypes::EType tabletType = TTabletTypes::Dummy; THolder<TEvHive::TEvCreateTablet> ev(new TEvHive::TEvCreateTablet(testerTablet, 0, tabletType, BINDED_CHANNELS)); @@ -4383,7 +4383,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { CreateLocal(runtime, 0); // only the 1st node has local running const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); TAutoPtr<TEvHive::TEvCreateTablet> ev = new TEvHive::TEvCreateTablet(testerTablet, 0, TTabletTypes::Dummy, BINDED_CHANNELS); ev->Record.SetTabletBootMode(NKikimrHive::ETabletBootMode::TABLET_BOOT_MODE_EXTERNAL); @@ -4409,7 +4409,7 @@ Y_UNIT_TEST_SUITE(THiveTest) { Setup(runtime, true); const ui64 hiveTablet = MakeDefaultHiveID(0); const ui64 testerTablet = MakeDefaultHiveID(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::FLAT_HIVE), &CreateDefaultHive); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(hiveTablet, TTabletTypes::Hive), &CreateDefaultHive); THolder<TEvHive::TEvCreateTablet> ev(new TEvHive::TEvCreateTablet(testerTablet, 0, TTabletTypes::Dummy, BINDED_CHANNELS)); ui64 tabletId = SendCreateTestTablet(runtime, hiveTablet, testerTablet, std::move(ev), 0, true); diff --git a/ydb/core/mind/hive/leader_tablet_info.h b/ydb/core/mind/hive/leader_tablet_info.h index f5e833efb0..7ae56f6c00 100644 --- a/ydb/core/mind/hive/leader_tablet_info.h +++ b/ydb/core/mind/hive/leader_tablet_info.h @@ -56,7 +56,7 @@ public: : TTabletInfo(ETabletRole::Leader, hive) , Id(id) , State(ETabletState::Unknown) - , Type(TTabletTypes::TYPE_INVALID) + , Type(TTabletTypes::TypeInvalid) , ObjectId(0) , ChannelProfileReassignReason(NKikimrHive::TEvReassignTablet::HIVE_REASSIGN_REASON_NO) , KnownGeneration(0) diff --git a/ydb/core/mind/hive/monitoring.cpp b/ydb/core/mind/hive/monitoring.cpp index 6d482f1ac6..64ca3864c3 100644 --- a/ydb/core/mind/hive/monitoring.cpp +++ b/ydb/core/mind/hive/monitoring.cpp @@ -2116,7 +2116,7 @@ public: TAutoPtr<NMon::TEvRemoteHttpInfo> Event; const TActorId Source; TTabletId TabletId = 0; - TTabletTypes::EType TabletType = TTabletTypes::TYPE_INVALID; + TTabletTypes::EType TabletType = TTabletTypes::TypeInvalid; TVector<ui32> TabletChannels; ui32 GroupId = 0; TVector<ui32> ForcedGroupIds; @@ -2169,7 +2169,7 @@ public: if (tablet != nullptr) { tablets.push_back(tablet); } - } else if (TabletType != TTabletTypes::TYPE_INVALID) { + } else if (TabletType != TTabletTypes::TypeInvalid) { for (auto& pr : Self->Tablets) { if (pr.second.Type == TabletType) { tablets.push_back(&pr.second); @@ -2641,7 +2641,7 @@ public: THolder<NMon::TEvRemoteHttpInfo> Event; const TActorId Source; TTabletId TabletId = 0; - TTabletTypes::EType TabletType = TTabletTypes::TYPE_INVALID; + TTabletTypes::EType TabletType = TTabletTypes::TypeInvalid; ui32 ChannelFrom = 0; ui32 ChannelTo = 255; ui32 GroupId = 0; @@ -2687,7 +2687,7 @@ public: if (tablet != nullptr) { tablets.push_back(tablet); } - } else if (TabletType != TTabletTypes::TYPE_INVALID) { + } else if (TabletType != TTabletTypes::TypeInvalid) { for (auto& pr : Self->Tablets) { if (pr.second.Type == TabletType) { tablets.push_back(&pr.second); diff --git a/ydb/core/mind/node_broker_ut.cpp b/ydb/core/mind/node_broker_ut.cpp index 0d9498ddcd..d3186b5a6f 100644 --- a/ydb/core/mind/node_broker_ut.cpp +++ b/ydb/core/mind/node_broker_ut.cpp @@ -156,7 +156,7 @@ void SetupServices(TTestActorRuntime &runtime, runtime.DispatchEvents(options); } - auto aid = CreateTestBootstrapper(runtime, CreateTestTabletInfo(MakeNodeBrokerID(0), TTabletTypes::NODE_BROKER), &CreateNodeBroker); + auto aid = CreateTestBootstrapper(runtime, CreateTestTabletInfo(MakeNodeBrokerID(0), TTabletTypes::NodeBroker), &CreateNodeBroker); runtime.EnableScheduleForActor(aid, true); } diff --git a/ydb/core/mind/ut_fat/blobstorage_node_warden_ut_fat.cpp b/ydb/core/mind/ut_fat/blobstorage_node_warden_ut_fat.cpp index 011f03d93c..d1165b3ce4 100644 --- a/ydb/core/mind/ut_fat/blobstorage_node_warden_ut_fat.cpp +++ b/ydb/core/mind/ut_fat/blobstorage_node_warden_ut_fat.cpp @@ -230,7 +230,7 @@ void SetupServices(TTestActorRuntime &runtime) { ui64 defaultStateStorageGroup = runtime.GetAppData(0).DomainsInfo->GetDefaultStateStorageGroup(DOMAIN_ID); CreateTestBootstrapper(runtime, CreateTestTabletInfo(MakeBSControllerID(defaultStateStorageGroup), - TTabletTypes::FLAT_BS_CONTROLLER, TBlobStorageGroupType::ErasureMirror3, groupId), + TTabletTypes::BSController, TBlobStorageGroupType::ErasureMirror3, groupId), &CreateFlatBsController); } diff --git a/ydb/core/persqueue/pq_impl.cpp b/ydb/core/persqueue/pq_impl.cpp index 4e0b24eb99..67c10e58eb 100644 --- a/ydb/core/persqueue/pq_impl.cpp +++ b/ydb/core/persqueue/pq_impl.cpp @@ -949,7 +949,7 @@ void TPersQueue::AggregateAndSendLabeledCountersFor(const TString& group, const TActorId countersAggregator = MakeTabletCountersAggregatorID(ctx.SelfID.NodeId()); ctx.Send(countersAggregator, new TEvTabletCounters::TEvTabletAddLabeledCounters( - CounterEventsInflight[group], TabletID(), TTabletTypes::PERSQUEUE, aggr)); + CounterEventsInflight[group], TabletID(), TTabletTypes::PersQueue, aggr)); } } diff --git a/ydb/core/persqueue/pq_ut.cpp b/ydb/core/persqueue/pq_ut.cpp index 93185458f5..9704d5819e 100644 --- a/ydb/core/persqueue/pq_ut.cpp +++ b/ydb/core/persqueue/pq_ut.cpp @@ -489,7 +489,7 @@ Y_UNIT_TEST(TestCheckACL) { void CheckLabeledCountersResponse(ui32 count, TTestContext& tc, TVector<TString> mustHave = {}) { - IActor* actor = CreateClusterLabeledCountersAggregatorActor(tc.Edge, TTabletTypes::PERSQUEUE); + IActor* actor = CreateClusterLabeledCountersAggregatorActor(tc.Edge, TTabletTypes::PersQueue); tc.Runtime->Register(actor); TAutoPtr<IEventHandle> handle; diff --git a/ydb/core/persqueue/pq_ut.h b/ydb/core/persqueue/pq_ut.h index 0d50bf3984..218fb327f0 100644 --- a/ydb/core/persqueue/pq_ut.h +++ b/ydb/core/persqueue/pq_ut.h @@ -99,7 +99,7 @@ struct TTestContext { TTestContext() { - TabletType = TTabletTypes::PERSQUEUE; + TabletType = TTabletTypes::PersQueue; TabletId = MakeTabletID(0, 0, 1); TabletIds.push_back(TabletId); @@ -152,7 +152,7 @@ struct TTestContext { Runtime->DispatchEvents(options); CreateTestBootstrapper(*Runtime, - CreateTestTabletInfo(BalancerTabletId, TTabletTypes::PERSQUEUE_READ_BALANCER, TErasureType::ErasureNone), + CreateTestTabletInfo(BalancerTabletId, TTabletTypes::PersQueueReadBalancer, TErasureType::ErasureNone), &CreatePersQueueReadBalancer); options.FinalEvents.push_back(TDispatchOptions::TFinalEventCondition(TEvTablet::EvBoot)); @@ -179,7 +179,7 @@ struct TTestContext { Runtime->DispatchEvents(options); CreateTestBootstrapper(*Runtime, - CreateTestTabletInfo(BalancerTabletId, TTabletTypes::PERSQUEUE_READ_BALANCER, TErasureType::ErasureNone), + CreateTestTabletInfo(BalancerTabletId, TTabletTypes::PersQueueReadBalancer, TErasureType::ErasureNone), &CreatePersQueueReadBalancer); options.FinalEvents.push_back(TDispatchOptions::TFinalEventCondition(TEvTablet::EvBoot)); diff --git a/ydb/core/tablet/bootstrapper.cpp b/ydb/core/tablet/bootstrapper.cpp index d2e5dd8b7f..17653b92d8 100644 --- a/ydb/core/tablet/bootstrapper.cpp +++ b/ydb/core/tablet/bootstrapper.cpp @@ -563,7 +563,7 @@ public: , RoundCounter(0xdeadbeefdeadbeefull) , SelfSeed(0xdeadbeefdeadbeefull) { - Y_VERIFY(TTabletTypes::TYPE_INVALID != TabletInfo->TabletType); + Y_VERIFY(TTabletTypes::TypeInvalid != TabletInfo->TabletType); } TAutoPtr<IEventHandle> AfterRegister(const TActorId &selfId, const TActorId &parentId) override { diff --git a/ydb/core/tablet/tablet_counters_aggregator.cpp b/ydb/core/tablet/tablet_counters_aggregator.cpp index ce470e1bbe..1ba4f32798 100644 --- a/ydb/core/tablet/tablet_counters_aggregator.cpp +++ b/ydb/core/tablet/tablet_counters_aggregator.cpp @@ -1448,7 +1448,7 @@ private: TCountersByTabletType& countersByTabletType) { auto datashard = FindCountersByTabletType( - TTabletTypes::FLAT_DATASHARD, countersByTabletType); + TTabletTypes::DataShard, countersByTabletType); if (datashard && !RowUpdates) { auto datashardGroup = counters->GetSubgroup("type", "DataShard"); @@ -1475,7 +1475,7 @@ private: } auto schemeshard = FindCountersByTabletType( - TTabletTypes::FLAT_SCHEMESHARD, countersByTabletType); + TTabletTypes::SchemeShard, countersByTabletType); if (schemeshard && !DiskSpaceTablesTotalBytes) { auto schemeshardGroup = counters->GetSubgroup("type", "SchemeShard"); @@ -1940,7 +1940,7 @@ TTabletCountersAggregatorActor::HandleWork(NMon::TEvHttpInfo::TPtr &ev, const TA TString reqTabletType = ev->Get()->Request.GetParams().Get("type"); ui32 workers = 0; TryFromString(ev->Get()->Request.GetParams().Get("workers"), workers); - for (ui32 tabletType = 0; tabletType < TTabletTypes::USER_TYPE_START; ++tabletType) { + for (ui32 tabletType = 0; tabletType < TTabletTypes::UserTypeStart; ++tabletType) { if (!NKikimrTabletBase::TTabletTypes::EType_IsValid(tabletType)) continue; TString tabletTypeStr = TTabletTypes::TypeToStr((TTabletTypes::EType)tabletType); diff --git a/ydb/core/tablet/tablet_counters_aggregator_ut.cpp b/ydb/core/tablet/tablet_counters_aggregator_ut.cpp index 68897a5b99..b73a410612 100644 --- a/ydb/core/tablet/tablet_counters_aggregator_ut.cpp +++ b/ydb/core/tablet/tablet_counters_aggregator_ut.cpp @@ -251,7 +251,7 @@ Y_UNIT_TEST_SUITE(TTabletCountersAggregator) { std::unique_ptr<TTabletCountersBase> AppCountersBaseline; public: - static constexpr TTabletTypes::EType TabletType = TTabletTypes::FLAT_DATASHARD; + static constexpr TTabletTypes::EType TabletType = TTabletTypes::DataShard; static constexpr TTabletPercentileCounter::TRangeDef RangeDefs1[] = { {0, "0"} diff --git a/ydb/core/tablet/tablet_pipe_ut.cpp b/ydb/core/tablet/tablet_pipe_ut.cpp index 2a528070fb..c5ca50c2ac 100644 --- a/ydb/core/tablet/tablet_pipe_ut.cpp +++ b/ydb/core/tablet/tablet_pipe_ut.cpp @@ -405,10 +405,10 @@ Y_UNIT_TEST_SUITE(TTabletPipeTest) { SetupTabletServices(runtime); TActorId sender = runtime.AllocateEdgeActor(); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TProducerTablet(tablet, info); }); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TConsumerTablet(tablet, info); }); @@ -445,10 +445,10 @@ Y_UNIT_TEST_SUITE(TTabletPipeTest) { SetupTabletServices(runtime); TActorId sender = runtime.AllocateEdgeActor(); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TProducerTablet(tablet, info); }); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TConsumerTablet(tablet, info); }); @@ -474,7 +474,7 @@ Y_UNIT_TEST_SUITE(TTabletPipeTest) { runtime.SetLogPriority(NKikimrServices::PIPE_CLIENT, NActors::NLog::PRI_DEBUG); TActorId sender = runtime.AllocateEdgeActor(); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TConsumerTablet(tablet, info); }); @@ -516,10 +516,10 @@ Y_UNIT_TEST_SUITE(TTabletPipeTest) { SetupTabletServices(runtime); TActorId sender = runtime.AllocateEdgeActor(); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TProducerTablet(tablet, info); }); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TConsumerTablet(tablet, info); }); @@ -543,10 +543,10 @@ Y_UNIT_TEST_SUITE(TTabletPipeTest) { SetupTabletServices(runtime); TActorId sender = runtime.AllocateEdgeActor(); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TProducerTablet(tablet, info); }); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TConsumerTablet(tablet, info); }); @@ -581,10 +581,10 @@ Y_UNIT_TEST_SUITE(TTabletPipeTest) { tabletIds.push_back((ui64)TTestTxConfig::TxTablet1); auto guard = CreateTabletScheduledEventsGuard(tabletIds, runtime, sender); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TProducerTablet(tablet, info); }); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TConsumerTablet(tablet, info); }); @@ -626,10 +626,10 @@ Y_UNIT_TEST_SUITE(TTabletPipeTest) { SetupTabletServices(runtime); TActorId sender = runtime.AllocateEdgeActor(); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TProducerTablet(tablet, info); }); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TConsumerTablet(tablet, info); }); @@ -660,10 +660,10 @@ Y_UNIT_TEST_SUITE(TTabletPipeTest) { SetupTabletServices(runtime); TActorId sender = runtime.AllocateEdgeActor(); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TProducerTablet(tablet, info); }); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TConsumerTablet(tablet, info); }); @@ -687,10 +687,10 @@ Y_UNIT_TEST_SUITE(TTabletPipeTest) { SetupTabletServices(runtime); TActorId sender = runtime.AllocateEdgeActor(); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TProducerTablet(tablet, info); }); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TConsumerTabletWithoutAcceptor(tablet, info); }); @@ -726,10 +726,10 @@ Y_UNIT_TEST_SUITE(TTabletPipeTest) { tabletIds.push_back((ui64)TTestTxConfig::TxTablet1); auto guard = CreateTabletScheduledEventsGuard(tabletIds, runtime, sender); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TProducerTablet(tablet, info); }); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TConsumerTabletWithoutAcceptor(tablet, info); }); @@ -771,10 +771,10 @@ Y_UNIT_TEST_SUITE(TTabletPipeTest) { SetupTabletServices(runtime); TActorId sender = runtime.AllocateEdgeActor(); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TProducerTablet(tablet, info); }); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TConsumerTablet(tablet, info); }); @@ -798,10 +798,10 @@ Y_UNIT_TEST_SUITE(TTabletPipeTest) { SetupTabletServices(runtime); TActorId sender1 = runtime.AllocateEdgeActor(0); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TProducerTablet(tablet, info); }, 0); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TConsumerTablet(tablet, info); }, 1); @@ -831,10 +831,10 @@ Y_UNIT_TEST_SUITE(TTabletPipeTest) { SetupTabletServices(runtime); TActorId sender1 = runtime.AllocateEdgeActor(0); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TProducerTablet(tablet, info); }, 0); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TConsumerTablet(tablet, info); }, 1); @@ -883,7 +883,7 @@ Y_UNIT_TEST_SUITE(TTabletPipeTest) { tabletIds.push_back((ui64)TTestTxConfig::TxTablet1); auto scheduledEventsGuard = CreateTabletScheduledEventsGuard(tabletIds, runtime, sender); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TProducerTablet(tablet, info); }); @@ -912,7 +912,7 @@ Y_UNIT_TEST_SUITE(TTabletPipeTest) { runtime.DispatchEvents(options); } - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TConsumerTablet(tablet, info); }); @@ -936,10 +936,10 @@ Y_UNIT_TEST_SUITE(TTabletPipeTest) { SetupTabletServices(runtime); TActorId sender1 = runtime.AllocateEdgeActor(0); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TProducerTablet(tablet, info); }, 0); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TConsumerTablet(tablet, info); }, 1); @@ -993,10 +993,10 @@ Y_UNIT_TEST_SUITE(TTabletPipeTest) { tabletIds.push_back((ui64)TTestTxConfig::TxTablet1); auto guard = CreateTabletScheduledEventsGuard(tabletIds, runtime, sender1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TProducerTablet(tablet, info); }, 0); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet1, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TConsumerTablet(tablet, info); }, 1); @@ -1135,7 +1135,7 @@ Y_UNIT_TEST_SUITE(TTabletPipeTest) { TActorId sender1 = runtime.AllocateEdgeActor(0); TActorId sender2 = runtime.AllocateEdgeActor(1); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::TX_DUMMY), [](const TActorId & tablet, TTabletStorageInfo* info) { + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::Dummy), [](const TActorId & tablet, TTabletStorageInfo* info) { return new TEchoTablet(tablet, info); }); diff --git a/ydb/core/tablet/tablet_pipecache_ut.cpp b/ydb/core/tablet/tablet_pipecache_ut.cpp index e59fbd4a18..15997a4553 100644 --- a/ydb/core/tablet/tablet_pipecache_ut.cpp +++ b/ydb/core/tablet/tablet_pipecache_ut.cpp @@ -65,7 +65,7 @@ Y_UNIT_TEST_SUITE(TPipeCacheTest) { TTestBasicRuntime runtime; SetupTabletServices(runtime); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::TX_DUMMY), + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::Dummy), [](const TActorId& tablet, TTabletStorageInfo* info) { return new TCustomTablet(tablet, info); }); @@ -117,7 +117,7 @@ Y_UNIT_TEST_SUITE(TPipeCacheTest) { UNIT_ASSERT_VALUES_EQUAL(ev1->Get()->TabletId, TTestTxConfig::TxTablet0); UNIT_ASSERT_VALUES_EQUAL(ev1->Get()->NodeId, 0); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::TX_DUMMY), + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::Dummy), [](const TActorId& tablet, TTabletStorageInfo* info) { return new TCustomTablet(tablet, info); }); diff --git a/ydb/core/tablet/tablet_req_blockbs_ut.cpp b/ydb/core/tablet/tablet_req_blockbs_ut.cpp index 186a3e84d6..20c4408d6d 100644 --- a/ydb/core/tablet/tablet_req_blockbs_ut.cpp +++ b/ydb/core/tablet/tablet_req_blockbs_ut.cpp @@ -12,7 +12,7 @@ Y_UNIT_TEST_SUITE(TBlockBlobStorageTest) { SetupTabletServices(runtime); THashSet<ui32> groups; - TIntrusivePtr<TTabletStorageInfo> info = CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::TX_DUMMY); + TIntrusivePtr<TTabletStorageInfo> info = CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::Dummy); for (size_t channel = 0; channel < info->Channels.size(); ++channel) { // use non-existant groups for all channels >= 2 if (channel >= 2) { diff --git a/ydb/core/tablet/tablet_sys.cpp b/ydb/core/tablet/tablet_sys.cpp index 4537a4af91..19ddb68ea4 100644 --- a/ydb/core/tablet/tablet_sys.cpp +++ b/ydb/core/tablet/tablet_sys.cpp @@ -1850,7 +1850,7 @@ TTablet::TTablet(const TActorId &launcher, TTabletStorageInfo *info, TTabletSetu , TxCacheQuota(txCacheQuota) { Y_VERIFY(!info->Channels.empty() && !info->Channels[0].History.empty()); - Y_VERIFY(TTabletTypes::TYPE_INVALID != info->TabletType); + Y_VERIFY(TTabletTypes::TypeInvalid != info->TabletType); } TAutoPtr<IEventHandle> TTablet::AfterRegister(const TActorId &self, const TActorId& parentId) { diff --git a/ydb/core/tablet_flat/flat_executor_leases_ut.cpp b/ydb/core/tablet_flat/flat_executor_leases_ut.cpp index 3761f4fcd0..039d78cce3 100644 --- a/ydb/core/tablet_flat/flat_executor_leases_ut.cpp +++ b/ydb/core/tablet_flat/flat_executor_leases_ut.cpp @@ -228,7 +228,7 @@ Y_UNIT_TEST_SUITE(TFlatExecutorLeases) { const ui64 tabletId = TTestTxConfig::TxTablet0; auto boot1 = CreateTestBootstrapper(runtime, - CreateTestTabletInfo(tabletId, TTabletTypes::TX_DUMMY), + CreateTestTabletInfo(tabletId, TTabletTypes::Dummy), [enableInitialLease](const TActorId & tablet, TTabletStorageInfo* info) { return new TLeasesTablet(tablet, info, enableInitialLease); }); @@ -281,7 +281,7 @@ Y_UNIT_TEST_SUITE(TFlatExecutorLeases) { auto prevObserver = runtime.SetObserverFunc(observerFunc); auto boot2 = CreateTestBootstrapper(runtime, - CreateTestTabletInfo(tabletId, TTabletTypes::TX_DUMMY), + CreateTestTabletInfo(tabletId, TTabletTypes::Dummy), [enableInitialLease](const TActorId & tablet, TTabletStorageInfo* info) { return new TLeasesTablet(tablet, info, enableInitialLease); }, diff --git a/ydb/core/tablet_flat/tablet_flat_executor.h b/ydb/core/tablet_flat/tablet_flat_executor.h index f628f6cd42..3c18a9ba87 100644 --- a/ydb/core/tablet_flat/tablet_flat_executor.h +++ b/ydb/core/tablet_flat/tablet_flat_executor.h @@ -462,7 +462,7 @@ namespace NFlatExecutorSetup { : TabletActorID(tablet) , TabletInfo(info) { - Y_VERIFY(TTabletTypes::TYPE_INVALID != TabletInfo->TabletType); + Y_VERIFY(TTabletTypes::TypeInvalid != TabletInfo->TabletType); } TActorId ExecutorActorID; diff --git a/ydb/core/tablet_flat/test/libs/exec/helper.h b/ydb/core/tablet_flat/test/libs/exec/helper.h index 09fe4e0f54..cfae180937 100644 --- a/ydb/core/tablet_flat/test/libs/exec/helper.h +++ b/ydb/core/tablet_flat/test/libs/exec/helper.h @@ -28,7 +28,7 @@ namespace NFake { auto *info = new TStorageInfo; info->TabletID = tablet; - info->TabletType = TTabletTypes::TX_DUMMY; + info->TabletType = TTabletTypes::Dummy; info->Channels.resize(4); for (auto num: xrange(info->Channels.size())) { diff --git a/ydb/core/tablet_flat/test/libs/exec/owner.h b/ydb/core/tablet_flat/test/libs/exec/owner.h index f3e3d7363c..492d2541c5 100644 --- a/ydb/core/tablet_flat/test/libs/exec/owner.h +++ b/ydb/core/tablet_flat/test/libs/exec/owner.h @@ -31,7 +31,7 @@ namespace NFake { , Limit(Max(ui32(1), limit)) , FollowerId(followerId) { - Y_VERIFY(TTabletTypes::TYPE_INVALID != Info->TabletType); + Y_VERIFY(TTabletTypes::TypeInvalid != Info->TabletType); } private: diff --git a/ydb/core/testlib/fake_coordinator.cpp b/ydb/core/testlib/fake_coordinator.cpp index 0be35b3bcf..a10002f434 100644 --- a/ydb/core/testlib/fake_coordinator.cpp +++ b/ydb/core/testlib/fake_coordinator.cpp @@ -4,7 +4,7 @@ namespace NKikimr { void BootFakeCoordinator(TTestActorRuntime& runtime, ui64 coordinatorId, TFakeCoordinator::TState::TPtr state) { - CreateTestBootstrapper(runtime, CreateTestTabletInfo(coordinatorId, TTabletTypes::FLAT_TX_COORDINATOR), + CreateTestBootstrapper(runtime, CreateTestTabletInfo(coordinatorId, TTabletTypes::Coordinator), [=](const TActorId & tablet, TTabletStorageInfo* info) { return new TFakeCoordinator(tablet, info, state); }); diff --git a/ydb/core/testlib/tenant_runtime.cpp b/ydb/core/testlib/tenant_runtime.cpp index daade7f5a9..9e94fb853d 100644 --- a/ydb/core/testlib/tenant_runtime.cpp +++ b/ydb/core/testlib/tenant_runtime.cpp @@ -852,15 +852,15 @@ void TTenantTestRuntime::Setup(bool createTenantPools) for (auto &pr : GetAppData().DomainsInfo->Domains) { auto &domain = pr.second; for (auto id : domain->TxAllocators) { - auto aid = CreateTestBootstrapper(*this, CreateTestTabletInfo(id, TTabletTypes::TX_ALLOCATOR), &CreateTxAllocator); + auto aid = CreateTestBootstrapper(*this, CreateTestTabletInfo(id, TTabletTypes::TxAllocator), &CreateTxAllocator); EnableScheduleForActor(aid, true); } for (auto id : domain->Coordinators) { - auto aid = CreateTestBootstrapper(*this, CreateTestTabletInfo(id, TTabletTypes::FLAT_TX_COORDINATOR), &CreateFlatTxCoordinator); + auto aid = CreateTestBootstrapper(*this, CreateTestTabletInfo(id, TTabletTypes::Coordinator), &CreateFlatTxCoordinator); EnableScheduleForActor(aid, true); } for (auto id : domain->Mediators) { - auto aid = CreateTestBootstrapper(*this, CreateTestTabletInfo(id, TTabletTypes::TX_MEDIATOR), &CreateTxMediator); + auto aid = CreateTestBootstrapper(*this, CreateTestTabletInfo(id, TTabletTypes::Mediator), &CreateTxMediator); EnableScheduleForActor(aid, true); } } @@ -879,13 +879,13 @@ void TTenantTestRuntime::Setup(bool createTenantPools) subdomains.push_back(std::make_pair(subDomain, key.GetPathId())); } - auto info = CreateTestTabletInfo(domain.SchemeShardId, TTabletTypes::TX_DUMMY, TErasureType::ErasureNone); + auto info = CreateTestTabletInfo(domain.SchemeShardId, TTabletTypes::Dummy, TErasureType::ErasureNone); TActorId actorId = CreateTestBootstrapper(*this, info, [sender=Sender, subdomains](const TActorId &tablet, TTabletStorageInfo *info) -> IActor* { return new TFakeSchemeShard(tablet, info, sender, subdomains); }); EnableScheduleForActor(actorId, true); } else { - auto info = CreateTestTabletInfo(domain.SchemeShardId, TTabletTypes::FLAT_SCHEMESHARD, TErasureType::ErasureNone); + auto info = CreateTestTabletInfo(domain.SchemeShardId, TTabletTypes::SchemeShard, TErasureType::ErasureNone); TActorId actorId = CreateTestBootstrapper(*this, info, [](const TActorId &tablet, TTabletStorageInfo *info) -> IActor* { return CreateFlatTxSchemeShard(tablet, info); }); @@ -952,7 +952,7 @@ void TTenantTestRuntime::Setup(bool createTenantPools) // Create Hive. { - auto info = CreateTestTabletInfo(Config.HiveId, TTabletTypes::TX_DUMMY, TErasureType::ErasureNone); + auto info = CreateTestTabletInfo(Config.HiveId, TTabletTypes::Dummy, TErasureType::ErasureNone); TActorId actorId = CreateTestBootstrapper(*this, info, [this](const TActorId &tablet, TTabletStorageInfo *info) -> IActor* { return new TFakeHive(tablet, info, Sender, Config.HiveId, SubDomainKeys); }); @@ -961,7 +961,7 @@ void TTenantTestRuntime::Setup(bool createTenantPools) // Create BS Controller. { - auto info = CreateTestTabletInfo(MakeBSControllerID(0), TTabletTypes::FLAT_BS_CONTROLLER); + auto info = CreateTestTabletInfo(MakeBSControllerID(0), TTabletTypes::BSController); TActorId actorId = CreateTestBootstrapper(*this, info, [](const TActorId &tablet, TTabletStorageInfo *info) -> IActor* { //return new TFakeBSController(tablet, info); return CreateFlatBsController(tablet, info); @@ -1031,7 +1031,7 @@ void TTenantTestRuntime::Setup(bool createTenantPools) // Create Console { - auto info = CreateTestTabletInfo(MakeConsoleID(0), TTabletTypes::CONSOLE, TErasureType::ErasureNone); + auto info = CreateTestTabletInfo(MakeConsoleID(0), TTabletTypes::Console, TErasureType::ErasureNone); TActorId actorId = CreateTestBootstrapper(*this, info, [](const TActorId &tablet, TTabletStorageInfo *info) -> IActor* { return CreateConsole(tablet, info); }); @@ -1098,7 +1098,7 @@ void TTenantTestRuntime::Setup(bool createTenantPools) // Create Tenant Slot Broker { - auto info = CreateTestTabletInfo(MakeTenantSlotBrokerID(0), TTabletTypes::TENANT_SLOT_BROKER, TErasureType::ErasureNone); + auto info = CreateTestTabletInfo(MakeTenantSlotBrokerID(0), TTabletTypes::TenantSlotBroker, TErasureType::ErasureNone); TActorId actorId = CreateTestBootstrapper(*this, info, [&config=this->Config](const TActorId &tablet, TTabletStorageInfo *info) -> IActor* { if (config.FakeTenantSlotBroker) return new TFakeTenantSlotBroker(tablet, info); diff --git a/ydb/core/testlib/test_client.cpp b/ydb/core/testlib/test_client.cpp index 9ee263e649..82fe54e237 100644 --- a/ydb/core/testlib/test_client.cpp +++ b/ydb/core/testlib/test_client.cpp @@ -364,17 +364,17 @@ namespace Tests { void TServer::CreateBootstrapTablets() { const ui32 domainId = Settings->Domain; Y_VERIFY(TDomainsInfo::MakeTxAllocatorIDFixed(domainId, 1) == ChangeStateStorage(TxAllocator, domainId)); - CreateTestBootstrapper(*Runtime, CreateTestTabletInfo(ChangeStateStorage(TxAllocator, domainId), TTabletTypes::TX_ALLOCATOR), &CreateTxAllocator); + CreateTestBootstrapper(*Runtime, CreateTestTabletInfo(ChangeStateStorage(TxAllocator, domainId), TTabletTypes::TxAllocator), &CreateTxAllocator); Y_VERIFY(TDomainsInfo::MakeTxCoordinatorIDFixed(domainId, 1) == ChangeStateStorage(Coordinator, domainId)); - CreateTestBootstrapper(*Runtime, CreateTestTabletInfo(ChangeStateStorage(Coordinator, domainId), TTabletTypes::FLAT_TX_COORDINATOR), &CreateFlatTxCoordinator); + CreateTestBootstrapper(*Runtime, CreateTestTabletInfo(ChangeStateStorage(Coordinator, domainId), TTabletTypes::Coordinator), &CreateFlatTxCoordinator); Y_VERIFY(TDomainsInfo::MakeTxMediatorIDFixed(domainId, 1) == ChangeStateStorage(Mediator, domainId)); - CreateTestBootstrapper(*Runtime, CreateTestTabletInfo(ChangeStateStorage(Mediator, domainId), TTabletTypes::TX_MEDIATOR), &CreateTxMediator); - CreateTestBootstrapper(*Runtime, CreateTestTabletInfo(ChangeStateStorage(SchemeRoot, domainId), TTabletTypes::FLAT_SCHEMESHARD), &CreateFlatTxSchemeShard); - CreateTestBootstrapper(*Runtime, CreateTestTabletInfo(ChangeStateStorage(Hive, domainId), TTabletTypes::FLAT_HIVE), &CreateDefaultHive); - CreateTestBootstrapper(*Runtime, CreateTestTabletInfo(MakeBSControllerID(domainId), TTabletTypes::FLAT_BS_CONTROLLER), &CreateFlatBsController); - CreateTestBootstrapper(*Runtime, CreateTestTabletInfo(MakeTenantSlotBrokerID(domainId), TTabletTypes::TENANT_SLOT_BROKER), &NTenantSlotBroker::CreateTenantSlotBroker); + CreateTestBootstrapper(*Runtime, CreateTestTabletInfo(ChangeStateStorage(Mediator, domainId), TTabletTypes::Mediator), &CreateTxMediator); + CreateTestBootstrapper(*Runtime, CreateTestTabletInfo(ChangeStateStorage(SchemeRoot, domainId), TTabletTypes::SchemeShard), &CreateFlatTxSchemeShard); + CreateTestBootstrapper(*Runtime, CreateTestTabletInfo(ChangeStateStorage(Hive, domainId), TTabletTypes::Hive), &CreateDefaultHive); + CreateTestBootstrapper(*Runtime, CreateTestTabletInfo(MakeBSControllerID(domainId), TTabletTypes::BSController), &CreateFlatBsController); + CreateTestBootstrapper(*Runtime, CreateTestTabletInfo(MakeTenantSlotBrokerID(domainId), TTabletTypes::TenantSlotBroker), &NTenantSlotBroker::CreateTenantSlotBroker); if (Settings->EnableConsole) - CreateTestBootstrapper(*Runtime, CreateTestTabletInfo(MakeConsoleID(domainId), TTabletTypes::CONSOLE), &NConsole::CreateConsole); + CreateTestBootstrapper(*Runtime, CreateTestTabletInfo(MakeConsoleID(domainId), TTabletTypes::Console), &NConsole::CreateConsole); } void TServer::SetupStorage() { @@ -857,8 +857,8 @@ namespace Tests { if (!Runtime) ythrow TWithBackTrace<yexception>() << "Server is redirected"; - CreateTestBootstrapper(*Runtime, CreateTestTabletInfo(ChangeStateStorage(DummyTablet1, Settings->Domain), TTabletTypes::TX_DUMMY), &CreateFlatDummyTablet); - CreateTestBootstrapper(*Runtime, CreateTestTabletInfo(ChangeStateStorage(DummyTablet2, Settings->Domain), TTabletTypes::TX_DUMMY), &CreateFlatDummyTablet); + CreateTestBootstrapper(*Runtime, CreateTestTabletInfo(ChangeStateStorage(DummyTablet1, Settings->Domain), TTabletTypes::Dummy), &CreateFlatDummyTablet); + CreateTestBootstrapper(*Runtime, CreateTestTabletInfo(ChangeStateStorage(DummyTablet2, Settings->Domain), TTabletTypes::Dummy), &CreateFlatDummyTablet); } TTestActorRuntime* TServer::GetRuntime() const { diff --git a/ydb/core/tx/columnshard/ut_columnshard_read_write.cpp b/ydb/core/tx/columnshard/ut_columnshard_read_write.cpp index e2723fafb9..8b0b920629 100644 --- a/ydb/core/tx/columnshard/ut_columnshard_read_write.cpp +++ b/ydb/core/tx/columnshard/ut_columnshard_read_write.cpp @@ -140,7 +140,7 @@ void TestWriteImpl(const TVector<std::pair<TString, TTypeId>>& ydbSchema) { TTester::Setup(runtime); TActorId sender = runtime.AllocateEdgeActor(); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::COLUMNSHARD), &CreateColumnShard); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::ColumnShard), &CreateColumnShard); TDispatchOptions options; options.FinalEvents.push_back(TDispatchOptions::TFinalEventCondition(TEvTablet::EvBoot)); @@ -226,7 +226,7 @@ void TestWriteReadImpl(bool reboots, const TVector<std::pair<TString, TTypeId>>& runtime.SetLogPriority(NKikimrServices::BLOB_CACHE, NActors::NLog::PRI_DEBUG); TActorId sender = runtime.AllocateEdgeActor(); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::COLUMNSHARD), &CreateColumnShard); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::ColumnShard), &CreateColumnShard); TDispatchOptions options; options.FinalEvents.push_back(TDispatchOptions::TFinalEventCondition(TEvTablet::EvBoot)); @@ -664,7 +664,7 @@ void TestCompactionInGranuleImpl(bool reboots) { TTester::Setup(runtime); TActorId sender = runtime.AllocateEdgeActor(); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::COLUMNSHARD), &CreateColumnShard); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::ColumnShard), &CreateColumnShard); TDispatchOptions options; options.FinalEvents.push_back(TDispatchOptions::TFinalEventCondition(TEvTablet::EvBoot)); @@ -802,7 +802,7 @@ void TestReadWithProgramImpl() TTester::Setup(runtime); TActorId sender = runtime.AllocateEdgeActor(); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::COLUMNSHARD), &CreateColumnShard); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::ColumnShard), &CreateColumnShard); TDispatchOptions options; options.FinalEvents.push_back(TDispatchOptions::TFinalEventCondition(TEvTablet::EvBoot)); @@ -906,7 +906,7 @@ Y_UNIT_TEST_SUITE(TColumnShardTestReadWrite) { TTester::Setup(runtime); TActorId sender = runtime.AllocateEdgeActor(); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::COLUMNSHARD), &CreateColumnShard); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::ColumnShard), &CreateColumnShard); TDispatchOptions options; options.FinalEvents.push_back(TDispatchOptions::TFinalEventCondition(TEvTablet::EvBoot)); @@ -1156,7 +1156,7 @@ Y_UNIT_TEST_SUITE(TColumnShardTestReadWrite) { TTester::Setup(runtime); TActorId sender = runtime.AllocateEdgeActor(); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::COLUMNSHARD), &CreateColumnShard); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::ColumnShard), &CreateColumnShard); TDispatchOptions options; options.FinalEvents.push_back(TDispatchOptions::TFinalEventCondition(TEvTablet::EvBoot)); @@ -1245,7 +1245,7 @@ Y_UNIT_TEST_SUITE(TColumnShardTestReadWrite) { runtime.SetLogPriority(NKikimrServices::BLOB_CACHE, NActors::NLog::PRI_DEBUG); TActorId sender = runtime.AllocateEdgeActor(); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::COLUMNSHARD), &CreateColumnShard); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::ColumnShard), &CreateColumnShard); TDispatchOptions options; options.FinalEvents.push_back(TDispatchOptions::TFinalEventCondition(TEvTablet::EvBoot)); diff --git a/ydb/core/tx/columnshard/ut_columnshard_schema.cpp b/ydb/core/tx/columnshard/ut_columnshard_schema.cpp index 4f4462ef30..2614ae561c 100644 --- a/ydb/core/tx/columnshard/ut_columnshard_schema.cpp +++ b/ydb/core/tx/columnshard/ut_columnshard_schema.cpp @@ -106,7 +106,7 @@ void TestTtl(bool reboots, bool internal, TTestSchema::TTableSpecials spec = {}, TActorId sender = runtime.AllocateEdgeActor(); CreateTestBootstrapper(runtime, - CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::COLUMNSHARD), + CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::ColumnShard), &CreateColumnShard); TDispatchOptions options; @@ -273,7 +273,7 @@ TestTiers(bool reboots, const std::vector<TString>& blobs, const std::vector<TTe TActorId sender = runtime.AllocateEdgeActor(); CreateTestBootstrapper(runtime, - CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::COLUMNSHARD), + CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::ColumnShard), &CreateColumnShard); TDispatchOptions options; @@ -471,7 +471,7 @@ void TestDrop(bool reboots) { TActorId sender = runtime.AllocateEdgeActor(); CreateTestBootstrapper(runtime, - CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::COLUMNSHARD), + CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::ColumnShard), &CreateColumnShard); TDispatchOptions options; diff --git a/ydb/core/tx/datashard/datashard_ut_common.cpp b/ydb/core/tx/datashard/datashard_ut_common.cpp index e83a657ad8..01aac96a5c 100644 --- a/ydb/core/tx/datashard/datashard_ut_common.cpp +++ b/ydb/core/tx/datashard/datashard_ut_common.cpp @@ -67,8 +67,8 @@ TTester::TTester(ESchema schema, const TOptions& opts) Sender = Runtime.AllocateEdgeActor(); // Schemeshard is only used to receive notifications - CreateTestBootstrapper(Runtime, CreateTestTabletInfo(FAKE_SCHEMESHARD_TABLET_ID, TTabletTypes::FLAT_SCHEMESHARD), &CreateFlatTxSchemeShard); - CreateTestBootstrapper(Runtime, CreateTestTabletInfo(FAKE_TX_ALLOCATOR_TABLET_ID, TTabletTypes::TX_ALLOCATOR), &CreateTxAllocator); + CreateTestBootstrapper(Runtime, CreateTestTabletInfo(FAKE_SCHEMESHARD_TABLET_ID, TTabletTypes::SchemeShard), &CreateFlatTxSchemeShard); + CreateTestBootstrapper(Runtime, CreateTestTabletInfo(FAKE_TX_ALLOCATOR_TABLET_ID, TTabletTypes::TxAllocator), &CreateTxAllocator); CreateSchema(schema, opts); } @@ -86,8 +86,8 @@ TTester::TTester(ESchema schema, const TString& dispatchName, std::function<void DispatchName = dispatchName; // Schemeshard is only used to receive notifications - CreateTestBootstrapper(Runtime, CreateTestTabletInfo(FAKE_SCHEMESHARD_TABLET_ID, TTabletTypes::FLAT_SCHEMESHARD), &CreateFlatTxSchemeShard); - CreateTestBootstrapper(Runtime, CreateTestTabletInfo(FAKE_TX_ALLOCATOR_TABLET_ID, TTabletTypes::TX_ALLOCATOR), &CreateTxAllocator); + CreateTestBootstrapper(Runtime, CreateTestTabletInfo(FAKE_SCHEMESHARD_TABLET_ID, TTabletTypes::SchemeShard), &CreateFlatTxSchemeShard); + CreateTestBootstrapper(Runtime, CreateTestTabletInfo(FAKE_TX_ALLOCATOR_TABLET_ID, TTabletTypes::TxAllocator), &CreateTxAllocator); CreateSchema(schema, opts); } @@ -148,7 +148,7 @@ TTester::TKeyResolver TTester::GetKeyResolver() const { } void TTester::CreateDataShard(TFakeMiniKQLProxy& proxy, ui64 tabletId, const TString& schemeText, bool withRegister) { - TActorId actorId = CreateTestBootstrapper(Runtime, CreateTestTabletInfo(tabletId, TTabletTypes::FLAT_DATASHARD), + TActorId actorId = CreateTestBootstrapper(Runtime, CreateTestTabletInfo(tabletId, TTabletTypes::DataShard), &::NKikimr::CreateDataShard); Y_UNUSED(actorId); diff --git a/ydb/core/tx/datashard/datashard_ut_init.cpp b/ydb/core/tx/datashard/datashard_ut_init.cpp index 818e30ab0c..ac15dc35de 100644 --- a/ydb/core/tx/datashard/datashard_ut_init.cpp +++ b/ydb/core/tx/datashard/datashard_ut_init.cpp @@ -99,7 +99,7 @@ Y_UNIT_TEST_SUITE(TTxDataShardTestInit) { TTester::Setup(runtime); TActorId sender = runtime.AllocateEdgeActor(); - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::FLAT_DATASHARD), &CreateDataShard); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TTestTxConfig::TxTablet0, TTabletTypes::DataShard), &CreateDataShard); TDispatchOptions options; options.FinalEvents.push_back(TDispatchOptions::TFinalEventCondition(TEvTablet::EvBoot)); diff --git a/ydb/core/tx/scheme_board/ut_helpers.h b/ydb/core/tx/scheme_board/ut_helpers.h index 1f2e4d5e9b..03de1fb2d5 100644 --- a/ydb/core/tx/scheme_board/ut_helpers.h +++ b/ydb/core/tx/scheme_board/ut_helpers.h @@ -209,7 +209,7 @@ class TTestWithSchemeshard: public NUnitTest::TTestBase { static void BootSchemeShard(TTestActorRuntime& runtime, ui64 tabletId) { using namespace NSchemeShard; - CreateTestBootstrapper(runtime, CreateTestTabletInfo(tabletId, TTabletTypes::FLAT_SCHEMESHARD), &CreateFlatTxSchemeShard); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(tabletId, TTabletTypes::SchemeShard), &CreateFlatTxSchemeShard); const TActorId edge = runtime.AllocateEdgeActor(); @@ -223,7 +223,7 @@ class TTestWithSchemeshard: public NUnitTest::TTestBase { } static void BootTxAllocator(TTestActorRuntime& runtime, ui64 tabletId) { - CreateTestBootstrapper(runtime, CreateTestTabletInfo(tabletId, TTabletTypes::TX_ALLOCATOR), &CreateTxAllocator); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(tabletId, TTabletTypes::TxAllocator), &CreateTxAllocator); } void BootCoordinator(TTestActorRuntime& runtime, ui64 tabletId) { diff --git a/ydb/core/tx/schemeshard/schemeshard__operation_alter_extsubdomain.cpp b/ydb/core/tx/schemeshard/schemeshard__operation_alter_extsubdomain.cpp index bcf5a3bc89..dd3ad4bfe4 100644 --- a/ydb/core/tx/schemeshard/schemeshard__operation_alter_extsubdomain.cpp +++ b/ydb/core/tx/schemeshard/schemeshard__operation_alter_extsubdomain.cpp @@ -402,12 +402,12 @@ public: txState.State = TTxState::CreateParts; if (!wasSharedTxSupported && setSupportSharedTx) { - DeclareShards(txState, OperationId.GetTxId(), subDomain->PathId, settings.GetCoordinators(), TTabletTypes::FLAT_TX_COORDINATOR, channelBindings, context.SS); - DeclareShards(txState, OperationId.GetTxId(), subDomain->PathId, settings.GetMediators(), TTabletTypes::TX_MEDIATOR, channelBindings, context.SS); + DeclareShards(txState, OperationId.GetTxId(), subDomain->PathId, settings.GetCoordinators(), TTabletTypes::Coordinator, channelBindings, context.SS); + DeclareShards(txState, OperationId.GetTxId(), subDomain->PathId, settings.GetMediators(), TTabletTypes::Mediator, channelBindings, context.SS); } if (addExternalSchemeShard) { - DeclareShards(txState, OperationId.GetTxId(), subDomain->PathId, 1, TTabletTypes::FLAT_SCHEMESHARD, channelBindings, context.SS); + DeclareShards(txState, OperationId.GetTxId(), subDomain->PathId, 1, TTabletTypes::SchemeShard, channelBindings, context.SS); } if (addExternalHive) { diff --git a/ydb/core/tx/schemeshard/schemeshard__operation_alter_subdomain.cpp b/ydb/core/tx/schemeshard/schemeshard__operation_alter_subdomain.cpp index 85f432738f..6e977dc4f6 100644 --- a/ydb/core/tx/schemeshard/schemeshard__operation_alter_subdomain.cpp +++ b/ydb/core/tx/schemeshard/schemeshard__operation_alter_subdomain.cpp @@ -332,8 +332,8 @@ public: txState.State = TTxState::CreateParts; if (!wasSharedTxSupported && setSupportSharedTx) { - DeclareShards(txState, OperationId.GetTxId(), subDomain->PathId, settings.GetCoordinators(), TTabletTypes::FLAT_TX_COORDINATOR, channelBindings, context.SS); - DeclareShards(txState, OperationId.GetTxId(), subDomain->PathId, settings.GetMediators(), TTabletTypes::TX_MEDIATOR, channelBindings, context.SS); + DeclareShards(txState, OperationId.GetTxId(), subDomain->PathId, settings.GetCoordinators(), TTabletTypes::Coordinator, channelBindings, context.SS); + DeclareShards(txState, OperationId.GetTxId(), subDomain->PathId, settings.GetMediators(), TTabletTypes::Mediator, channelBindings, context.SS); for (auto& shard: txState.Shards) { alterData->AddPrivateShard(shard.Idx); diff --git a/ydb/core/tx/schemeshard/schemeshard__operation_create_subdomain.cpp b/ydb/core/tx/schemeshard/schemeshard__operation_create_subdomain.cpp index 04714d4c8a..8aa1ad7de0 100644 --- a/ydb/core/tx/schemeshard/schemeshard__operation_create_subdomain.cpp +++ b/ydb/core/tx/schemeshard/schemeshard__operation_create_subdomain.cpp @@ -313,8 +313,8 @@ public: alter->AddStoragePool(pool); } - DeclareShards(txState, OperationId.GetTxId(), newNode->PathId, settings.GetCoordinators(), TTabletTypes::FLAT_TX_COORDINATOR, channelBindings, context.SS); - DeclareShards(txState, OperationId.GetTxId(), newNode->PathId, settings.GetMediators(), TTabletTypes::TX_MEDIATOR, channelBindings, context.SS); + DeclareShards(txState, OperationId.GetTxId(), newNode->PathId, settings.GetCoordinators(), TTabletTypes::Coordinator, channelBindings, context.SS); + DeclareShards(txState, OperationId.GetTxId(), newNode->PathId, settings.GetMediators(), TTabletTypes::Mediator, channelBindings, context.SS); for (auto& shard: txState.Shards) { alter->AddPrivateShard(shard.Idx); diff --git a/ydb/core/tx/schemeshard/ut_helpers/test_env.cpp b/ydb/core/tx/schemeshard/ut_helpers/test_env.cpp index 4aaefe81b8..48ba58ea0b 100644 --- a/ydb/core/tx/schemeshard/ut_helpers/test_env.cpp +++ b/ydb/core/tx/schemeshard/ut_helpers/test_env.cpp @@ -525,7 +525,7 @@ NSchemeShardUT_Private::TTestEnv::TTestEnv(TTestActorRuntime& runtime, const TTe } TActorId sender = runtime.AllocateEdgeActor(); - //CreateTestBootstrapper(runtime, CreateTestTabletInfo(MakeBSControllerID(TTestTxConfig::DomainUid), TTabletTypes::FLAT_BS_CONTROLLER), &CreateFlatBsController); + //CreateTestBootstrapper(runtime, CreateTestTabletInfo(MakeBSControllerID(TTestTxConfig::DomainUid), TTabletTypes::BSController), &CreateFlatBsController); BootSchemeShard(runtime, schemeRoot); BootTxAllocator(runtime, txAllocator); BootFakeCoordinator(runtime, coordinator, CoordinatorState); @@ -834,11 +834,11 @@ void NSchemeShardUT_Private::TTestEnv::InitRootStoragePools(NActors::TTestActorR void NSchemeShardUT_Private::TTestEnv::BootSchemeShard(NActors::TTestActorRuntime &runtime, ui64 schemeRoot) { - CreateTestBootstrapper(runtime, CreateTestTabletInfo(schemeRoot, TTabletTypes::FLAT_SCHEMESHARD), SchemeShardFactory); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(schemeRoot, TTabletTypes::SchemeShard), SchemeShardFactory); } void NSchemeShardUT_Private::TTestEnv::BootTxAllocator(NActors::TTestActorRuntime &runtime, ui64 tabletId) { - CreateTestBootstrapper(runtime, CreateTestTabletInfo(tabletId, TTabletTypes::TX_ALLOCATOR), &CreateTxAllocator); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(tabletId, TTabletTypes::TxAllocator), &CreateTxAllocator); } NSchemeShardUT_Private::TTestWithReboots::TTestWithReboots(bool killOnCommit, NSchemeShardUT_Private::TTestEnv::TSchemeShardFactory ssFactory) diff --git a/ydb/core/tx/sequenceshard/ut_helpers.h b/ydb/core/tx/sequenceshard/ut_helpers.h index d8845e078d..f0274f2309 100644 --- a/ydb/core/tx/sequenceshard/ut_helpers.h +++ b/ydb/core/tx/sequenceshard/ut_helpers.h @@ -13,7 +13,7 @@ namespace NKikimr { namespace NSequenceShard { struct TTestContext { - TTabletTypes::EType TabletType = TTabletTypes::SEQUENCESHARD; + TTabletTypes::EType TabletType = TTabletTypes::SequenceShard; ui64 TabletId = MakeTabletID(0, 0, 1); THolder<TTestActorRuntime> Runtime; TActorId ClientId; diff --git a/ydb/core/tx/tx_allocator/txallocator_ut_helpers.cpp b/ydb/core/tx/tx_allocator/txallocator_ut_helpers.cpp index 95566493b6..7d67a8843c 100644 --- a/ydb/core/tx/tx_allocator/txallocator_ut_helpers.cpp +++ b/ydb/core/tx/tx_allocator/txallocator_ut_helpers.cpp @@ -59,7 +59,7 @@ void AllocateAndCheck(NActors::TTestActorRuntime &runtime, ui64 size, TResultSta } void TTestEnv::Boot(TTestActorRuntime &runtime) { - CreateTestBootstrapper(runtime, CreateTestTabletInfo(TxAllocatorTablet, TTabletTypes::TX_ALLOCATOR), &CreateTxAllocator); + CreateTestBootstrapper(runtime, CreateTestTabletInfo(TxAllocatorTablet, TTabletTypes::TxAllocator), &CreateTxAllocator); TDispatchOptions options; options.FinalEvents.push_back(TDispatchOptions::TFinalEventCondition(TEvTablet::EvBoot)); diff --git a/ydb/core/tx/tx_allocator_client/ut_helpers.cpp b/ydb/core/tx/tx_allocator_client/ut_helpers.cpp index 53b25a9bc2..ec2ddcce26 100644 --- a/ydb/core/tx/tx_allocator_client/ut_helpers.cpp +++ b/ydb/core/tx/tx_allocator_client/ut_helpers.cpp @@ -42,7 +42,7 @@ void TTestEnv::AsyncAllocate(ui64 size) { } void TTestEnv::Boot() { - CreateTestBootstrapper(Runtime, CreateTestTabletInfo(TxAllocatorTablet, TTabletTypes::TX_ALLOCATOR), &CreateTxAllocator); + CreateTestBootstrapper(Runtime, CreateTestTabletInfo(TxAllocatorTablet, TTabletTypes::TxAllocator), &CreateTxAllocator); TDispatchOptions options; options.FinalEvents.push_back(TDispatchOptions::TFinalEventCondition(TEvTablet::EvBoot)); diff --git a/ydb/core/tx/tx_proxy/proxy_ut.cpp b/ydb/core/tx/tx_proxy/proxy_ut.cpp index eba78928c5..cd7f697c10 100644 --- a/ydb/core/tx/tx_proxy/proxy_ut.cpp +++ b/ydb/core/tx/tx_proxy/proxy_ut.cpp @@ -117,7 +117,7 @@ Y_UNIT_TEST_SUITE(TSubDomainTest) { ui64 owner = THash<TString>()("CreateTablet"); ui64 index = 1; TAutoPtr<NMsgBusProxy::TBusResponse> resp = env.GetClient().HiveCreateTablet( - env.GetSettings().Domain, owner, index, TTabletTypes::TX_DUMMY, {}, {}); + env.GetSettings().Domain, owner, index, TTabletTypes::Dummy, {}, {}); NKikimrClient::TResponse& record = resp->Record; UNIT_ASSERT_VALUES_EQUAL(record.CreateTabletResultSize(), 1); @@ -143,7 +143,7 @@ Y_UNIT_TEST_SUITE(TSubDomainTest) { allowed_domains.push_back(TSubDomainKey(999, 999)); TAutoPtr<NMsgBusProxy::TBusResponse> resp = env.GetClient().HiveCreateTablet( - env.GetSettings().Domain, owner, index, TTabletTypes::TX_DUMMY, {}, allowed_domains); + env.GetSettings().Domain, owner, index, TTabletTypes::Dummy, {}, allowed_domains); NKikimrClient::TResponse& record = resp->Record; UNIT_ASSERT_VALUES_EQUAL(record.CreateTabletResultSize(), 1); diff --git a/ydb/core/tx/tx_proxy/proxy_ut_helpers.cpp b/ydb/core/tx/tx_proxy/proxy_ut_helpers.cpp index b87837acc8..80a768c43a 100644 --- a/ydb/core/tx/tx_proxy/proxy_ut_helpers.cpp +++ b/ydb/core/tx/tx_proxy/proxy_ut_helpers.cpp @@ -365,7 +365,7 @@ ui64 CreateSubDomainAndTabletInside(TBaseTestEnv &env, const TString &name, ui64 TAutoPtr<NMsgBusProxy::TBusResponse> resp = env.GetClient().HiveCreateTablet( env.GetSettings().Domain, owner, shard_index, - TTabletTypes::TX_DUMMY, + TTabletTypes::Dummy, {}, {key}, channelBindings); diff --git a/ydb/core/viewer/json_labeledcounters.h b/ydb/core/viewer/json_labeledcounters.h index 00fbc7467f..7db53ed4e2 100644 --- a/ydb/core/viewer/json_labeledcounters.h +++ b/ydb/core/viewer/json_labeledcounters.h @@ -66,7 +66,7 @@ public: Groups = topic; } } - CreateClusterLabeledCountersAggregator(ctx.SelfID, TTabletTypes::PERSQUEUE, ctx, Version, Version >= 2 ? Groups : TString()); + CreateClusterLabeledCountersAggregator(ctx.SelfID, TTabletTypes::PersQueue, ctx, Version, Version >= 2 ? Groups : TString()); Become(&TThis::StateRequestedTopicInfo, ctx, TDuration::MilliSeconds(Timeout), new TEvents::TEvWakeup()); } diff --git a/ydb/core/viewer/json_topicinfo.h b/ydb/core/viewer/json_topicinfo.h index 78df6b4b1f..292f55a298 100644 --- a/ydb/core/viewer/json_topicinfo.h +++ b/ydb/core/viewer/json_topicinfo.h @@ -47,7 +47,7 @@ public: if (pos != TString::npos) Topic = Topic.substr(pos + 1); //proxy is not used - CreateClusterLabeledCountersAggregator(ctx.SelfID, TTabletTypes::PERSQUEUE, ctx); + CreateClusterLabeledCountersAggregator(ctx.SelfID, TTabletTypes::PersQueue, ctx); Become(&TThis::StateRequestedTopicInfo, ctx, TDuration::MilliSeconds(Timeout), new TEvents::TEvWakeup()); } |