diff options
| author | nadya73 <nadya73@yandex-team.com> | 2024-06-14 19:30:33 +0300 |
|---|---|---|
| committer | nadya73 <nadya73@yandex-team.com> | 2024-06-14 19:44:00 +0300 |
| commit | 89bc5efd2fbad262aa007012978e822fd6a09732 (patch) | |
| tree | 1401a3c187634abd67541473f495f4df7f84b9bc | |
| parent | ba26d2888eb8967fda7ee4ef23d9467d49924ffc (diff) | |
| download | ydb-89bc5efd2fbad262aa007012978e822fd6a09732.tar.gz | |
[queues] YT-21855: Cosmetics for pull queue consumer
Cosmetics for pull queue consumer
3e448bbc389a487b942c1dcd41a5d2cd6c83d4fc
| -rw-r--r-- | yt/yt/client/api/rpc_proxy/api_service_proxy.h | 1 | ||||
| -rw-r--r-- | yt/yt/client/driver/driver.cpp | 1 |
2 files changed, 2 insertions, 0 deletions
diff --git a/yt/yt/client/api/rpc_proxy/api_service_proxy.h b/yt/yt/client/api/rpc_proxy/api_service_proxy.h index 6270a25e6b..0f3f9f0454 100644 --- a/yt/yt/client/api/rpc_proxy/api_service_proxy.h +++ b/yt/yt/client/api/rpc_proxy/api_service_proxy.h @@ -87,6 +87,7 @@ public: // Queues DEFINE_RPC_PROXY_METHOD(NRpcProxy::NProto, AdvanceConsumer); DEFINE_RPC_PROXY_METHOD(NRpcProxy::NProto, PullQueue); + // COMPAT(nadya73): For compatability with old versions of clients. DEFINE_RPC_PROXY_METHOD_GENERIC(PullConsumer, NRpcProxy::NProto::TReqPullQueueConsumer, NRpcProxy::NProto::TRspPullQueueConsumer); DEFINE_RPC_PROXY_METHOD(NRpcProxy::NProto, PullQueueConsumer); DEFINE_RPC_PROXY_METHOD(NRpcProxy::NProto, RegisterQueueConsumer); diff --git a/yt/yt/client/driver/driver.cpp b/yt/yt/client/driver/driver.cpp index 2f9db97950..0d6488193f 100644 --- a/yt/yt/client/driver/driver.cpp +++ b/yt/yt/client/driver/driver.cpp @@ -349,6 +349,7 @@ public: REGISTER (TUnregisterQueueConsumerCommand, "unregister_queue_consumer", Null, Structured, true, false, ApiVersion4); REGISTER (TListQueueConsumerRegistrationsCommand, "list_queue_consumer_registrations", Null, Structured, false, false, ApiVersion4); REGISTER (TPullQueueCommand, "pull_queue", Null, Tabular, false, true , ApiVersion4); + // COMPAT(nadya73): for compatibility with old versions of clients. REGISTER (TPullQueueConsumerCommand, "pull_consumer", Null, Tabular, false, true , ApiVersion4); REGISTER (TPullQueueConsumerCommand, "pull_queue_consumer", Null, Tabular, false, true , ApiVersion4); REGISTER (TAdvanceConsumerCommand, "advance_consumer", Null, Structured, true, false, ApiVersion4); |