diff options
| author | azevaykin <azevaykin@yandex-team.com> | 2023-07-06 13:50:58 +0300 |
|---|---|---|
| committer | azevaykin <azevaykin@yandex-team.com> | 2023-07-06 13:50:58 +0300 |
| commit | 047078a0b267f9511823cfd780ea14573dc0af56 (patch) | |
| tree | 5d57b210c46eaa1f83cbb2e36875e1db47cf1f82 | |
| parent | 6224485996e3928236bca24e1e526a91d492f569 (diff) | |
| download | ydb-047078a0b267f9511823cfd780ea14573dc0af56.tar.gz | |
remove obsolete macro
| -rw-r--r-- | ydb/services/persqueue_v1/ut/test_utils.h | 22 |
1 files changed, 0 insertions, 22 deletions
diff --git a/ydb/services/persqueue_v1/ut/test_utils.h b/ydb/services/persqueue_v1/ut/test_utils.h index 1ce0ee0bb2..91b8272508 100644 --- a/ydb/services/persqueue_v1/ut/test_utils.h +++ b/ydb/services/persqueue_v1/ut/test_utils.h @@ -15,28 +15,6 @@ static constexpr int DEBUG_LOG_LEVEL = 7; using namespace NKikimr::NPersQueueTests; -// TODO: Remove and replace all usage with ApiTestSetup -#define SETUP_API_TEST_PREREQUISITES()\ - const TString topic = "topic1";\ - const TString cluster = "dc1";\ - const TString pqRoot = "/Root/PQ";\ - const TString messageGroupId = "test-message-group-id";\ - TPortManager pm;\ - const ui16 port = pm.GetPort(2134);\ - const ui16 grpc = pm.GetPort(2135);\ - TServerSettings settings = PQSettings(port);\ - TServer server = TServer(settings);\ - server.EnableGRpc(NGrpc::TServerOptions().SetHost("localhost").SetPort(grpc));\ - TFlatMsgBusPQClient client(settings, grpc);\ - client.FullInit();\ - client.CheckClustersList(server->GetRuntime());\ - client.CreateTopic("rt3.dc1--" + TString(topic), 1);\ - EnableLogs(server, { NKikimrServices::PQ_WRITE_PROXY });\ - TPQDataWriter writer(messageGroupId, grpc, client, server.GetRuntime());\ - writer.WaitWritePQServiceInitialization();\ - auto channel = grpc::CreateChannel("localhost:" + ToString(grpc), grpc::InsecureChannelCredentials());\ - auto service = Ydb::PersQueue::V1::PersQueueService::NewStub(channel);\ - template<typename TStream, typename TMessage = google::protobuf::Message> void AssertSuccessfullStreamingOperation(bool ok, std::unique_ptr<TStream>& stream, TMessage* message = nullptr) { if (!ok) { |