diff options
| author | alexnick <[email protected]> | 2022-05-13 23:03:12 +0300 |
|---|---|---|
| committer | alexnick <[email protected]> | 2022-05-13 23:03:12 +0300 |
| commit | cd40f4da96f099064e9348f9cabb8ef63f5af5e8 (patch) | |
| tree | 9ce5727c962145dc7ef1a845e9b4c9de132b4ddc | |
| parent | 1ec4d0895a23113092860fdb9fb687378e2e9792 (diff) | |
internal mirroring via remote mirroring
ref:611c139768955eed240fcb791b1c40c645079816
| -rw-r--r-- | ydb/core/testlib/CMakeLists.txt | 1 | ||||
| -rw-r--r-- | ydb/core/testlib/test_client.cpp | 1 | ||||
| -rw-r--r-- | ydb/core/testlib/test_client.h | 3 |
3 files changed, 4 insertions, 1 deletions
diff --git a/ydb/core/testlib/CMakeLists.txt b/ydb/core/testlib/CMakeLists.txt index 0587bcb18ea..badfce03637 100644 --- a/ydb/core/testlib/CMakeLists.txt +++ b/ydb/core/testlib/CMakeLists.txt @@ -46,6 +46,7 @@ target_link_libraries(ydb-core-testlib PUBLIC core-mind-hive ydb-core-node_whiteboard ydb-core-protos + ydb-core-persqueue ydb-core-security core-sys_view-processor core-sys_view-service diff --git a/ydb/core/testlib/test_client.cpp b/ydb/core/testlib/test_client.cpp index 82fe54e2379..e54505f33f2 100644 --- a/ydb/core/testlib/test_client.cpp +++ b/ydb/core/testlib/test_client.cpp @@ -218,6 +218,7 @@ namespace Tests { Runtime->GetAppData(nodeIdx).DomainsConfig.MergeFrom(Settings->AppConfig.GetDomainsConfig()); Runtime->GetAppData(nodeIdx).PersQueueGetReadSessionsInfoWorkerFactory = Settings->PersQueueGetReadSessionsInfoWorkerFactory.get(); Runtime->GetAppData(nodeIdx).DataStreamsAuthFactory = Settings->DataStreamsAuthFactory.get(); + Runtime->GetAppData(nodeIdx).PersQueueMirrorReaderFactory = Settings->PersQueueMirrorReaderFactory.get(); SetupConfigurators(nodeIdx); SetupProxies(nodeIdx); diff --git a/ydb/core/testlib/test_client.h b/ydb/core/testlib/test_client.h index 960272c4784..0ecd068a231 100644 --- a/ydb/core/testlib/test_client.h +++ b/ydb/core/testlib/test_client.h @@ -24,6 +24,7 @@ #include <ydb/core/kesus/tablet/events.h> #include <ydb/core/security/ticket_parser.h> #include <ydb/core/base/grpc_service_factory.h> +#include <ydb/core/persqueue/actor_persqueue_client_iface.h> #include <ydb/core/yq/libs/shared_resources/interface/shared_resources.h> #include <ydb/core/http_proxy/auth_factory.h> @@ -125,7 +126,7 @@ namespace Tests { ui64 DomainPlanResolution = 0; std::shared_ptr<NKikimr::NMsgBusProxy::IPersQueueGetReadSessionsInfoWorkerFactory> PersQueueGetReadSessionsInfoWorkerFactory; std::shared_ptr<NKikimr::NHttpProxy::IAuthFactory> DataStreamsAuthFactory; - + std::shared_ptr<NKikimr::NPQ::TPersQueueMirrorReaderFactory> PersQueueMirrorReaderFactory = std::make_shared<NKikimr::NPQ::TPersQueueMirrorReaderFactory>(); bool EnableMetering = false; TString MeteringFilePath; |