aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorazevaykin <azevaykin@yandex-team.com>2023-07-06 13:50:58 +0300
committerazevaykin <azevaykin@yandex-team.com>2023-07-06 13:50:58 +0300
commit047078a0b267f9511823cfd780ea14573dc0af56 (patch)
tree5d57b210c46eaa1f83cbb2e36875e1db47cf1f82
parent6224485996e3928236bca24e1e526a91d492f569 (diff)
downloadydb-047078a0b267f9511823cfd780ea14573dc0af56.tar.gz
remove obsolete macro
-rw-r--r--ydb/services/persqueue_v1/ut/test_utils.h22
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) {