diff options
| author | achains <[email protected]> | 2025-11-13 10:43:43 +0300 |
|---|---|---|
| committer | achains <[email protected]> | 2025-11-13 11:03:19 +0300 |
| commit | 7b74fa8fc7cc82d96a0cba57d21b772fd1400a0a (patch) | |
| tree | f36d72a389c6413e56a065295c05c505f953be8c /yt/cpp/mapreduce/interface | |
| parent | 1c9f50a532cbec8d3be39d0cf6a008edb60929b3 (diff) | |
YT-26425: RPC support distributed API
* Changelog entry
Type: feature
Component: cpp-sdk
Support Distributed write API methods for RPC proxies in C\+\+ client.
commit_hash:1b1247f95c77a2de02d16f56dcc3291e772be2f2
Diffstat (limited to 'yt/cpp/mapreduce/interface')
| -rw-r--r-- | yt/cpp/mapreduce/interface/distributed_session.h | 20 |
1 files changed, 20 insertions, 0 deletions
diff --git a/yt/cpp/mapreduce/interface/distributed_session.h b/yt/cpp/mapreduce/interface/distributed_session.h index 70cf4db0b5d..2e6e23ce91a 100644 --- a/yt/cpp/mapreduce/interface/distributed_session.h +++ b/yt/cpp/mapreduce/interface/distributed_session.h @@ -11,6 +11,8 @@ #include <library/cpp/yt/misc/strong_typedef.h> +#include <util/datetime/base.h> + namespace NYT { //////////////////////////////////////////////////////////////////////////////// @@ -64,7 +66,16 @@ struct TDistributedWriteTableSessionWithCookies struct TStartDistributedWriteTableOptions { + /// @cond Doxygen_Suppress using TSelf = TStartDistributedWriteTableOptions; + /// @endcond + + /// + /// @brief How long session lives after last ping. + /// + /// If server doesn't receive any pings for session transaction for this time + /// session will be aborted. By default timeout is 15 seconds. + FLUENT_FIELD_OPTION(TDuration, Timeout); }; struct TPingDistributedWriteTableOptions @@ -90,7 +101,16 @@ struct TDistributedWriteFileSessionWithCookies struct TStartDistributedWriteFileOptions { + /// @cond Doxygen_Suppress using TSelf = TStartDistributedWriteFileOptions; + /// @endcond + + /// + /// @brief How long session lives after last ping. + /// + /// If server doesn't receive any pings for session transaction for this time + /// session will be aborted. By default timeout is 15 seconds. + FLUENT_FIELD_OPTION(TDuration, Timeout); }; struct TPingDistributedWriteFileOptions |