aboutsummaryrefslogtreecommitdiffstats
path: root/yt/cpp
diff options
context:
space:
mode:
authorhiddenpath <hiddenpath@yandex-team.com>2025-03-28 15:13:18 +0300
committerhiddenpath <hiddenpath@yandex-team.com>2025-03-28 15:27:38 +0300
commita3709f79ab2678b16c3b2b57e43dd977d08bf7bf (patch)
treea6042a873e660425108a6e1cc703a359b163a4b3 /yt/cpp
parent29180864663beb174b1d7bc9c08958a966a75038 (diff)
downloadydb-a3709f79ab2678b16c3b2b57e43dd977d08bf7bf.tar.gz
YT-23616: Add ProxyUnixDomainSocket client option
commit_hash:1f6882f7cda53ebe7e544d255f657f027af5b553
Diffstat (limited to 'yt/cpp')
-rw-r--r--yt/cpp/mapreduce/client/client.cpp1
-rw-r--r--yt/cpp/mapreduce/http/context.cpp3
-rw-r--r--yt/cpp/mapreduce/http/context.h1
-rw-r--r--yt/cpp/mapreduce/interface/client_method_options.h4
4 files changed, 8 insertions, 1 deletions
diff --git a/yt/cpp/mapreduce/client/client.cpp b/yt/cpp/mapreduce/client/client.cpp
index 8c6cd72cf7..690580285a 100644
--- a/yt/cpp/mapreduce/client/client.cpp
+++ b/yt/cpp/mapreduce/client/client.cpp
@@ -1561,6 +1561,7 @@ TClientContext CreateClientContext(
context.Config = options.Config_ ? options.Config_ : TConfig::Get();
context.TvmOnly = options.TvmOnly_;
context.ProxyAddress = options.ProxyAddress_;
+ context.ProxyUnixDomainSocket = options.ProxyUnixDomainSocket_;
if (options.UseTLS_) {
context.UseTLS = *options.UseTLS_;
diff --git a/yt/cpp/mapreduce/http/context.cpp b/yt/cpp/mapreduce/http/context.cpp
index 05dbce0a2e..a2e59c0fd8 100644
--- a/yt/cpp/mapreduce/http/context.cpp
+++ b/yt/cpp/mapreduce/http/context.cpp
@@ -14,7 +14,8 @@ bool operator==(const TClientContext& lhs, const TClientContext& rhs)
lhs.UseTLS == rhs.UseTLS &&
lhs.TvmOnly == rhs.TvmOnly &&
lhs.ProxyAddress == rhs.ProxyAddress &&
- lhs.RpcProxyRole == rhs.RpcProxyRole;
+ lhs.RpcProxyRole == rhs.RpcProxyRole &&
+ lhs.ProxyUnixDomainSocket == rhs.ProxyUnixDomainSocket;
}
////////////////////////////////////////////////////////////////////////////////
diff --git a/yt/cpp/mapreduce/http/context.h b/yt/cpp/mapreduce/http/context.h
index 20c8eb55ce..0601b495f1 100644
--- a/yt/cpp/mapreduce/http/context.h
+++ b/yt/cpp/mapreduce/http/context.h
@@ -23,6 +23,7 @@ struct TClientContext
TConfigPtr Config = TConfig::Get();
TMaybe<TString> ProxyAddress;
TMaybe<TString> RpcProxyRole;
+ TMaybe<TString> ProxyUnixDomainSocket;
};
bool operator==(const TClientContext& lhs, const TClientContext& rhs);
diff --git a/yt/cpp/mapreduce/interface/client_method_options.h b/yt/cpp/mapreduce/interface/client_method_options.h
index 807009682e..866f900571 100644
--- a/yt/cpp/mapreduce/interface/client_method_options.h
+++ b/yt/cpp/mapreduce/interface/client_method_options.h
@@ -1118,6 +1118,10 @@ struct TCreateClientOptions
/// @brief Proxy Address to be used for connection
FLUENT_FIELD_OPTION(TString, ProxyAddress);
+
+ /// @brief Specifies the Unix socket used for connection,
+ /// typically when the RPC proxy is enabled within the job proxy.
+ FLUENT_FIELD_OPTION(TString, ProxyUnixDomainSocket);
};
///