diff options
author | omgronny <omgronny@yandex-team.com> | 2024-10-11 21:16:54 +0300 |
---|---|---|
committer | omgronny <omgronny@yandex-team.com> | 2024-10-11 21:28:33 +0300 |
commit | c7307fc40d61e2a996fd7c22ee9ef52663897b3b (patch) | |
tree | cf38637a1ef654e984c4847260253dd8195bff66 /yt/cpp/mapreduce/interface/operation.h | |
parent | 1df197e6035ea9826bfedee7d48812e318ba9c7a (diff) | |
download | ydb-c7307fc40d61e2a996fd7c22ee9ef52663897b3b.tar.gz |
YT-21938: Introduce get_job_trace
* Changelog entry\
Type: feature\
Component: proxy
Add the handler that gets the job’s trace events.
commit_hash:c9d1a6d57e886a266967d57065bd3948882808c7
Diffstat (limited to 'yt/cpp/mapreduce/interface/operation.h')
-rw-r--r-- | yt/cpp/mapreduce/interface/operation.h | 64 |
1 files changed, 64 insertions, 0 deletions
diff --git a/yt/cpp/mapreduce/interface/operation.h b/yt/cpp/mapreduce/interface/operation.h index 9a85049886..f2de3ea3bd 100644 --- a/yt/cpp/mapreduce/interface/operation.h +++ b/yt/cpp/mapreduce/interface/operation.h @@ -3048,6 +3048,70 @@ struct TGetFailedJobInfoOptions //////////////////////////////////////////////////////////////////////////////// /// +/// @brief Options for @ref NYT::IClient::GetJobTrace. +struct TGetJobTraceOptions +{ + /// @cond Doxygen_Suppress + using TSelf = TGetJobTraceOptions; + /// @endcond + + /// + /// @brief Id of the job. + FLUENT_FIELD_OPTION(TJobId, JobId); + + /// + /// @brief Id of the trace. + FLUENT_FIELD_OPTION(TJobTraceId, TraceId); + + /// + /// @brief Search for traces with time >= `FromTime`. + FLUENT_FIELD_OPTION(i64, FromTime); + + /// + /// @brief Search for traces with time <= `ToTime`. + FLUENT_FIELD_OPTION(i64, ToTime); + + /// + /// @brief Search for traces with event index >= `FromEventIndex`. + FLUENT_FIELD_OPTION(i64, FromEventIndex); + + /// + /// @brief Search for traces with event index >= `ToEventIndex`. + FLUENT_FIELD_OPTION(i64, ToEventIndex); +}; + +/// +/// @brief Response for @ref NYT::IOperation::GetJobTrace. +struct TJobTraceEvent +{ + /// + /// @brief Id of the operation. + TOperationId OperationId; + + /// + /// @brief Id of the job. + TJobId JobId; + + /// + /// @brief Id of the trace. + TJobTraceId TraceId; + + /// + /// @brief Index of the trace event. + i64 EventIndex; + + /// + /// @brief Raw evenr in json format. + TString Event; + + /// + /// @brief Time of the event. + TInstant EventTime; +}; + +//////////////////////////////////////////////////////////////////////////////// + +/// /// @brief Interface representing an operation. struct IOperation : public TThrRefBase |