aboutsummaryrefslogtreecommitdiffstats
path: root/yt/yt_proto
diff options
context:
space:
mode:
authorarkady-e1ppa <arkady-e1ppa@yandex-team.com>2024-12-27 21:15:39 +0300
committerarkady-e1ppa <arkady-e1ppa@yandex-team.com>2024-12-27 21:32:56 +0300
commit53beb43a8ca2431f7a260c3b26555f2272eb75db (patch)
tree0d3f8f4de24352258ca3071aeb78af0b227bbaf2 /yt/yt_proto
parentb0be24b640ceac2a1d571fcc5a84d043b05ef87a (diff)
downloadydb-53beb43a8ca2431f7a260c3b26555f2272eb75db.tar.gz
YT-22307: Rework distributed write to support signatures
commit_hash:85ce68163df979408ed6b9047a9b2346628ba98d
Diffstat (limited to 'yt/yt_proto')
-rw-r--r--yt/yt_proto/yt/client/api/rpc_proxy/proto/api_service.proto13
1 files changed, 8 insertions, 5 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 723a63b639..457a28b0f5 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
@@ -3426,20 +3426,23 @@ message TRspGetQueryTrackerInfo
message TReqStartDistributedWriteSession
{
required string path = 1;
+ required int32 cookie_count = 2;
optional TTransactionalOptions transactional_options = 100;
}
message TRspStartDistributedWriteSession
{
- required bytes session = 1; // YSON-serialized TDistributedWriteSession
+ required bytes signed_session = 1; // YSON-serialized TSignedDistributedWriteSessionPtr
+ repeated bytes signed_cookies = 2; // vector of YSON-serialized TSignedDistributedWriteCookiePtr
}
message TReqFinishDistributedWriteSession
{
- required bytes session = 1; // YSON-serialized TDistributedWriteSession
+ required bytes signed_session = 1; // YSON-serialized TSignedDistributedWriteSessionPtr
+ repeated bytes signed_write_results = 2; // vector of YSON-serialized TSignedWriteFragmentResultPtr
- required int32 max_children_per_attach_request = 2;
+ required int32 max_children_per_attach_request = 3;
}
message TRspFinishDistributedWriteSession
@@ -3452,12 +3455,12 @@ message TReqWriteTableFragment
optional bytes format = 2; // YSON-serialized TFormat
- required bytes cookie = 3; // YSON-serialized TFragmentWriteCookie
+ required bytes signed_cookie = 3; // YSON-serialized TSignedWriteFragmentCookiePtr
}
message TRspWriteTableFragment
{
- required bytes cookie = 1; // YSON-serialized TFragmentWriteCookie
+ required bytes signed_write_result = 1; // YSON-serialized TSignedWriteFragmentResultPtr
}
///////////////////////////////////////////////////////////////////////////////