aboutsummaryrefslogtreecommitdiffstats
path: root/yt/yt_proto
diff options
context:
space:
mode:
authorapachee <apachee@yandex-team.com>2024-05-24 16:21:41 +0300
committerapachee <apachee@yandex-team.com>2024-05-24 16:31:03 +0300
commite2ba2fb36e917cd56f8dd9006d4b6f081a1939ac (patch)
treebf72832d784543986e62e5e486f5b77df018d220 /yt/yt_proto
parent17b724c0bfc83bc671073210ba805e7e833f29d8 (diff)
downloadydb-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.proto29
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;