summaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/raw_client/raw_requests.cpp
diff options
context:
space:
mode:
authorhiddenpath <[email protected]>2024-12-13 15:22:36 +0300
committerhiddenpath <[email protected]>2024-12-13 17:04:18 +0300
commit09c88b035d29fac5fd49de2fbc3c71e2d2a80754 (patch)
treea84b5b2de4dcdf85c3b22b9cac7e984aebb8b68d /yt/cpp/mapreduce/raw_client/raw_requests.cpp
parent615edba542d9394b0eae47ef957ec2257549cfdd (diff)
yt/cpp/mapreduce: move Get, TryGet, Exists, MultisetAttributes to THttpRawClient
commit_hash:bd2228f98fa92de408ca850f9bc1608fdf99e7f5
Diffstat (limited to 'yt/cpp/mapreduce/raw_client/raw_requests.cpp')
-rw-r--r--yt/cpp/mapreduce/raw_client/raw_requests.cpp57
1 files changed, 0 insertions, 57 deletions
diff --git a/yt/cpp/mapreduce/raw_client/raw_requests.cpp b/yt/cpp/mapreduce/raw_client/raw_requests.cpp
index d10c818489c..13100a29070 100644
--- a/yt/cpp/mapreduce/raw_client/raw_requests.cpp
+++ b/yt/cpp/mapreduce/raw_client/raw_requests.cpp
@@ -79,35 +79,6 @@ void ExecuteBatch(
}
}
-TNode Get(
- const IRequestRetryPolicyPtr& retryPolicy,
- const TClientContext& context,
- const TTransactionId& transactionId,
- const TYPath& path,
- const TGetOptions& options)
-{
- THttpHeader header("GET", "get");
- header.MergeParameters(SerializeParamsForGet(transactionId, context.Config->Prefix, path, options));
- return NodeFromYsonString(RetryRequestWithPolicy(retryPolicy, context, header).Response);
-}
-
-TNode TryGet(
- const IRequestRetryPolicyPtr& retryPolicy,
- const TClientContext& context,
- const TTransactionId& transactionId,
- const TYPath& path,
- const TGetOptions& options)
-{
- try {
- return Get(retryPolicy, context, transactionId, path, options);
- } catch (const TErrorResponse& error) {
- if (!error.IsResolveError()) {
- throw;
- }
- return TNode();
- }
-}
-
void Set(
const IRequestRetryPolicyPtr& retryPolicy,
const TClientContext& context,
@@ -123,34 +94,6 @@ void Set(
RetryRequestWithPolicy(retryPolicy, context, header, body);
}
-void MultisetAttributes(
- const IRequestRetryPolicyPtr& retryPolicy,
- const TClientContext& context,
- const TTransactionId& transactionId,
- const TYPath& path,
- const TNode::TMapType& value,
- const TMultisetAttributesOptions& options)
-{
- THttpHeader header("PUT", "api/v4/multiset_attributes", false);
- header.AddMutationId();
- header.MergeParameters(SerializeParamsForMultisetAttributes(transactionId, context.Config->Prefix, path, options));
-
- auto body = NodeToYsonString(value);
- RetryRequestWithPolicy(retryPolicy, context, header, body);
-}
-
-bool Exists(
- const IRequestRetryPolicyPtr& retryPolicy,
- const TClientContext& context,
- const TTransactionId& transactionId,
- const TYPath& path,
- const TExistsOptions& options)
-{
- THttpHeader header("GET", "exists");
- header.MergeParameters(SerializeParamsForExists(transactionId, context.Config->Prefix, path, options));
- return ParseBoolFromResponse(RetryRequestWithPolicy(retryPolicy, context, header).Response);
-}
-
TNodeId Create(
const IRequestRetryPolicyPtr& retryPolicy,
const TClientContext& context,