diff options
| author | arkady-e1ppa <arkady-e1ppa@yandex-team.com> | 2024-12-27 21:15:39 +0300 |
|---|---|---|
| committer | arkady-e1ppa <arkady-e1ppa@yandex-team.com> | 2024-12-27 21:32:56 +0300 |
| commit | 53beb43a8ca2431f7a260c3b26555f2272eb75db (patch) | |
| tree | 0d3f8f4de24352258ca3071aeb78af0b227bbaf2 /yt/yt_proto | |
| parent | b0be24b640ceac2a1d571fcc5a84d043b05ef87a (diff) | |
| download | ydb-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.proto | 13 |
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 } /////////////////////////////////////////////////////////////////////////////// |