aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authoryuryalekseev <yuryalekseev@yandex-team.com>2023-08-09 10:55:35 +0300
committeryuryalekseev <yuryalekseev@yandex-team.com>2023-08-09 11:59:55 +0300
commitbc6863b0191920feab54c82e2799cdaf0f395d69 (patch)
tree5f308b1c6b78645f75adaff2a33ad94f95a76b1a
parentf317e875044612f5945fb0251fb711d1124508cc (diff)
downloadydb-bc6863b0191920feab54c82e2799cdaf0f395d69.tar.gz
YT-17268: Add missing bus_certs_dir to TTcpDispatcherDynamicConfig.
-rw-r--r--yt/yt/core/bus/tcp/config.cpp4
-rw-r--r--yt/yt/core/bus/tcp/config.h3
2 files changed, 7 insertions, 0 deletions
diff --git a/yt/yt/core/bus/tcp/config.cpp b/yt/yt/core/bus/tcp/config.cpp
index 380ff36cba..8b3f715a99 100644
--- a/yt/yt/core/bus/tcp/config.cpp
+++ b/yt/yt/core/bus/tcp/config.cpp
@@ -44,6 +44,7 @@ TTcpDispatcherConfigPtr TTcpDispatcherConfig::ApplyDynamic(
UpdateYsonStructField(mergedConfig->ThreadPoolSize, dynamicConfig->ThreadPoolSize);
UpdateYsonStructField(mergedConfig->Networks, dynamicConfig->Networks);
UpdateYsonStructField(mergedConfig->MultiplexingBands, dynamicConfig->MultiplexingBands);
+ UpdateYsonStructField(mergedConfig->BusCertsDir, dynamicConfig->BusCertsDir);
mergedConfig->Postprocess();
return mergedConfig;
}
@@ -64,6 +65,9 @@ void TTcpDispatcherDynamicConfig::Register(TRegistrar registrar)
registrar.Parameter("multiplexing_bands", &TThis::MultiplexingBands)
.Optional();
+
+ registrar.Parameter("bus_certs_dir", &TThis::BusCertsDir)
+ .Default();
}
////////////////////////////////////////////////////////////////////////////////
diff --git a/yt/yt/core/bus/tcp/config.h b/yt/yt/core/bus/tcp/config.h
index 25786783d5..a5257d5b90 100644
--- a/yt/yt/core/bus/tcp/config.h
+++ b/yt/yt/core/bus/tcp/config.h
@@ -66,6 +66,9 @@ public:
std::optional<TEnumIndexedVector<EMultiplexingBand, TMultiplexingBandConfigPtr>> MultiplexingBands;
+ //! Used to store TLS/SSL certificate files.
+ std::optional<TString> BusCertsDir;
+
REGISTER_YSON_STRUCT(TTcpDispatcherDynamicConfig);
static void Register(TRegistrar registrar);