aboutsummaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/interface
diff options
context:
space:
mode:
authorhiddenpath <hiddenpath@yandex-team.com>2024-12-12 15:42:31 +0300
committerhiddenpath <hiddenpath@yandex-team.com>2024-12-12 16:16:32 +0300
commit33b0eb2c8e449c6bf0b1d09020ac16823a04c808 (patch)
tree4896aefe651c0d564419b95f75eec656d12b357a /yt/cpp/mapreduce/interface
parent488068b0d84538afd45ca9c7b805b06981eb0d84 (diff)
downloadydb-33b0eb2c8e449c6bf0b1d09020ac16823a04c808.tar.gz
yt/cpp/mapreduce: Move Set operation to THttpRawClient
commit_hash:3c4bb23f8331162e4667c907c007bc859cc2fc76
Diffstat (limited to 'yt/cpp/mapreduce/interface')
-rw-r--r--yt/cpp/mapreduce/interface/fwd.h8
-rw-r--r--yt/cpp/mapreduce/interface/raw_client.h25
2 files changed, 33 insertions, 0 deletions
diff --git a/yt/cpp/mapreduce/interface/fwd.h b/yt/cpp/mapreduce/interface/fwd.h
index 485b45129a..162a6ee3e9 100644
--- a/yt/cpp/mapreduce/interface/fwd.h
+++ b/yt/cpp/mapreduce/interface/fwd.h
@@ -150,6 +150,7 @@ namespace NYT {
// common.h
////////////////////////////////////////////////////////////////////////////////
+ using TMutationId = TGUID;
using TTransactionId = TGUID;
using TNodeId = TGUID;
using TLockId = TGUID;
@@ -396,5 +397,12 @@ namespace NYT {
struct TRetryConfig;
class IRetryConfigProvider;
using IRetryConfigProviderPtr = ::TIntrusivePtr<IRetryConfigProvider>;
+
+ ////////////////////////////////////////////////////////////////////////////////
+ // raw_client.h
+ ////////////////////////////////////////////////////////////////////////////////
+
+ class IRawClient;
+ using IRawClientPtr = ::TIntrusivePtr<IRawClient>;
}
/// @endcond
diff --git a/yt/cpp/mapreduce/interface/raw_client.h b/yt/cpp/mapreduce/interface/raw_client.h
new file mode 100644
index 0000000000..b1d244ad78
--- /dev/null
+++ b/yt/cpp/mapreduce/interface/raw_client.h
@@ -0,0 +1,25 @@
+#pragma once
+
+#include "client_method_options.h"
+
+namespace NYT {
+
+////////////////////////////////////////////////////////////////////////////////
+
+class IRawClient
+ : public virtual TThrRefBase
+{
+public:
+ // Cypress
+
+ virtual void Set(
+ TMutationId& mutationId,
+ const TTransactionId& transactionId,
+ const TYPath& path,
+ const TNode& value,
+ const TSetOptions& options = {}) = 0;
+};
+
+////////////////////////////////////////////////////////////////////////////////
+
+} // namespace NYT