diff options
author | yuryalekseev <yuryalekseev@yandex-team.com> | 2023-08-09 10:55:35 +0300 |
---|---|---|
committer | yuryalekseev <yuryalekseev@yandex-team.com> | 2023-08-09 11:59:55 +0300 |
commit | bc6863b0191920feab54c82e2799cdaf0f395d69 (patch) | |
tree | 5f308b1c6b78645f75adaff2a33ad94f95a76b1a | |
parent | f317e875044612f5945fb0251fb711d1124508cc (diff) | |
download | ydb-bc6863b0191920feab54c82e2799cdaf0f395d69.tar.gz |
YT-17268: Add missing bus_certs_dir to TTcpDispatcherDynamicConfig.
-rw-r--r-- | yt/yt/core/bus/tcp/config.cpp | 4 | ||||
-rw-r--r-- | yt/yt/core/bus/tcp/config.h | 3 |
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); |