Skip to content

Commit 7d6b8d4

Browse files
committed
Brought the transfer back (#18677)
1 parent c71486c commit 7d6b8d4

File tree

21 files changed

+2963
-109
lines changed

21 files changed

+2963
-109
lines changed

ydb/apps/ydbd/main.cpp

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
#include "export.h"
22
#include <ydb/core/driver_lib/run/main.h>
33
#include <ydb/core/security/ticket_parser.h>
4+
#include <ydb/core/transfer/transfer_writer.h>
45
#include <ydb/core/tx/schemeshard/schemeshard_operation_factory.h>
56
#include <ydb/core/ymq/actor/auth_multi_factory.h>
67
#include <ydb/core/ymq/base/events_writer.h>
@@ -23,6 +24,7 @@ int main(int argc, char **argv) {
2324
factories->SqsEventsWriterFactory = std::make_shared<TSqsEventsWriterFactory>();
2425
factories->SchemeOperationFactory.reset(NKikimr::NSchemeShard::DefaultOperationFactory());
2526
factories->ConfigSwissKnife = NKikimr::NYamlConfig::CreateDefaultConfigSwissKnife();
27+
factories->TransferWriterFactory = std::make_shared<NKikimr::NReplication::NTransfer::TTransferWriterFactory>();
2628

2729
return ParameterizedMain(argc, argv, std::move(factories));
2830
}

ydb/core/driver_lib/run/run.cpp

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1126,9 +1126,10 @@ void TKikimrRunner::InitializeAppData(const TKikimrRunConfig& runConfig)
11261126
AppData->IoContextFactory = ModuleFactories ? ModuleFactories->IoContextFactory.get() : nullptr;
11271127
AppData->SchemeOperationFactory = ModuleFactories ? ModuleFactories->SchemeOperationFactory.get() : nullptr;
11281128
AppData->ConfigSwissKnife = ModuleFactories ? ModuleFactories->ConfigSwissKnife.get() : nullptr;
1129-
if (ModuleFactories) {
1130-
AppData->TransferWriterFactory = ModuleFactories->TransferWriterFactory;
1131-
}
1129+
1130+
AppData->TransferWriterFactory = ModuleFactories
1131+
? ModuleFactories->TransferWriterFactory
1132+
: nullptr;
11321133

11331134
AppData->SqsAuthFactory = ModuleFactories
11341135
? ModuleFactories->SqsAuthFactory.get()

ydb/core/driver_lib/run/ya.make

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -102,6 +102,7 @@ PEERDIR(
102102
ydb/core/tablet_flat
103103
ydb/core/test_tablet
104104
ydb/core/tracing
105+
ydb/core/transfer
105106
ydb/core/tx
106107
ydb/core/tx/columnshard
107108
ydb/core/tx/conveyor/service

0 commit comments

Comments
 (0)