diff options
author | hiddenpath <hiddenpath@yandex-team.com> | 2025-03-28 15:13:18 +0300 |
---|---|---|
committer | hiddenpath <hiddenpath@yandex-team.com> | 2025-03-28 15:27:38 +0300 |
commit | a3709f79ab2678b16c3b2b57e43dd977d08bf7bf (patch) | |
tree | a6042a873e660425108a6e1cc703a359b163a4b3 /yt/cpp | |
parent | 29180864663beb174b1d7bc9c08958a966a75038 (diff) | |
download | ydb-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.cpp | 1 | ||||
-rw-r--r-- | yt/cpp/mapreduce/http/context.cpp | 3 | ||||
-rw-r--r-- | yt/cpp/mapreduce/http/context.h | 1 | ||||
-rw-r--r-- | yt/cpp/mapreduce/interface/client_method_options.h | 4 |
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); }; /// |