diff options
author | apachee <apachee@yandex-team.com> | 2024-05-24 16:21:41 +0300 |
---|---|---|
committer | apachee <apachee@yandex-team.com> | 2024-05-24 16:31:03 +0300 |
commit | e2ba2fb36e917cd56f8dd9006d4b6f081a1939ac (patch) | |
tree | bf72832d784543986e62e5e486f5b77df018d220 /yt/yt_proto | |
parent | 17b724c0bfc83bc671073210ba805e7e833f29d8 (diff) | |
download | ydb-e2ba2fb36e917cd56f8dd9006d4b6f081a1939ac.tar.gz |
[queues] YT-21355: Implement commands for creating and removing producer sessions
Implements client methods create_queue_producer_session and remove_queue_producer_session
a1fc793b8bae6faf8aca0772969d36247e5f9545
Diffstat (limited to 'yt/yt_proto')
-rw-r--r-- | yt/yt_proto/yt/client/api/rpc_proxy/proto/api_service.proto | 29 |
1 files changed, 29 insertions, 0 deletions
diff --git a/yt/yt_proto/yt/client/api/rpc_proxy/proto/api_service.proto b/yt/yt_proto/yt/client/api/rpc_proxy/proto/api_service.proto index 789f83cb99..c9c593f22a 100644 --- a/yt/yt_proto/yt/client/api/rpc_proxy/proto/api_service.proto +++ b/yt/yt_proto/yt/client/api/rpc_proxy/proto/api_service.proto @@ -760,6 +760,35 @@ message TRspListQueueConsumerRegistrations //////////////////////////////////////////////////////////////////////////////// +message TReqCreateQueueProducerSession +{ + optional string producer_path = 1; + optional string queue_path = 2; + optional string session_id = 3; + optional bytes user_meta = 4; // YSON +} + +message TRspCreateQueueProducerSession +{ + optional uint64 sequence_number = 1; + optional uint64 epoch = 2; + optional bytes user_meta = 3; // YSON +} + +//////////////////////////////////////////////////////////////////////////////// + +message TReqRemoveQueueProducerSession +{ + optional string producer_path = 1; + optional string queue_path = 2; + optional string session_id = 3; +} + +message TRspRemoveQueueProducerSession +{ } + +//////////////////////////////////////////////////////////////////////////////// + message TReqExplainQuery { required string query = 1; |