aboutsummaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/http/http.cpp
diff options
context:
space:
mode:
authorVitaly Isaev <vitalyisaev@ydb.tech>2024-12-12 15:39:00 +0000
committerVitaly Isaev <vitalyisaev@ydb.tech>2024-12-12 15:39:00 +0000
commit827b115675004838023427572a7c69f40a86a80a (patch)
treee99c953fe494b9de8d8597a15859d77c81f118c7 /yt/cpp/mapreduce/http/http.cpp
parent42701242eaf5be980cb935631586d0e90b82641c (diff)
parentfab222fd8176d00eee5ddafc6bce8cb95a6e3ab0 (diff)
downloadydb-827b115675004838023427572a7c69f40a86a80a.tar.gz
Merge branch 'rightlib' into rightlib_20241212
Diffstat (limited to 'yt/cpp/mapreduce/http/http.cpp')
-rw-r--r--yt/cpp/mapreduce/http/http.cpp8
1 files changed, 7 insertions, 1 deletions
diff --git a/yt/cpp/mapreduce/http/http.cpp b/yt/cpp/mapreduce/http/http.cpp
index ca243a929a..41ee56f672 100644
--- a/yt/cpp/mapreduce/http/http.cpp
+++ b/yt/cpp/mapreduce/http/http.cpp
@@ -207,7 +207,7 @@ void THttpHeader::AddOperationId(const TOperationId& operationId, bool overwrite
AddParameter("operation_id", GetGuidAsString(operationId), overwrite);
}
-void THttpHeader::AddMutationId()
+TMutationId THttpHeader::AddMutationId()
{
TGUID guid;
@@ -220,6 +220,8 @@ void THttpHeader::AddMutationId()
guid.dw[2] = GetPID() ^ MicroSeconds();
AddParameter("mutation_id", GetGuidAsString(guid), true);
+
+ return guid;
}
bool THttpHeader::HasMutationId() const
@@ -227,6 +229,10 @@ bool THttpHeader::HasMutationId() const
return Parameters_.contains("mutation_id");
}
+void THttpHeader::SetMutationId(TMutationId mutationId) {
+ AddParameter("mutation_id", GetGuidAsString(mutationId), /* overwrite */ true);
+}
+
void THttpHeader::SetToken(const TString& token)
{
Token_ = token;