diff options
author | abcdef <akotov@ydb.tech> | 2023-10-27 12:21:19 +0300 |
---|---|---|
committer | abcdef <akotov@ydb.tech> | 2023-10-27 12:51:39 +0300 |
commit | 206239ea12d280c0815c5dbdea8a5f42fd5271b2 (patch) | |
tree | 455ae48b835f34b782fe9ea8913cbc605f214bbf | |
parent | 7e5fe6b348ea2b8113bb5b83980dd61fada1d15c (diff) | |
download | ydb-206239ea12d280c0815c5dbdea8a5f42fd5271b2.tar.gz |
default value for the ClusterDiscoveryMode field
по умолчанию поле равно ClusterDiscoveryMode равно Auto
-rw-r--r-- | ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/persqueue_impl.cpp | 5 | ||||
-rw-r--r-- | ydb/public/sdk/cpp/client/ydb_persqueue_core/persqueue.h | 3 |
2 files changed, 2 insertions, 6 deletions
diff --git a/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/persqueue_impl.cpp b/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/persqueue_impl.cpp index 69360cfefa..18aacc8f23 100644 --- a/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/persqueue_impl.cpp +++ b/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/persqueue_impl.cpp @@ -26,7 +26,7 @@ std::shared_ptr<IWriteSession> TPersQueueClient::TImpl::CreateWriteSession( const TWriteSessionSettings& settings ) { TMaybe<TWriteSessionSettings> maybeSettings; - if (!settings.CompressionExecutor_ || !settings.EventHandlers_.HandlersExecutor_ || !settings.ClusterDiscoveryMode_) { + if (!settings.CompressionExecutor_ || !settings.EventHandlers_.HandlersExecutor_) { maybeSettings = settings; with_lock (Lock) { if (!settings.CompressionExecutor_) { @@ -35,9 +35,6 @@ std::shared_ptr<IWriteSession> TPersQueueClient::TImpl::CreateWriteSession( if (!settings.EventHandlers_.HandlersExecutor_) { maybeSettings->EventHandlers_.HandlersExecutor(Settings.DefaultHandlersExecutor_); } - if (!settings.ClusterDiscoveryMode_) { - maybeSettings->ClusterDiscoveryMode(Settings.ClusterDiscoveryMode_); - } } } auto session = std::make_shared<TWriteSession>( diff --git a/ydb/public/sdk/cpp/client/ydb_persqueue_core/persqueue.h b/ydb/public/sdk/cpp/client/ydb_persqueue_core/persqueue.h index dccc09eeab..fc42bead04 100644 --- a/ydb/public/sdk/cpp/client/ydb_persqueue_core/persqueue.h +++ b/ydb/public/sdk/cpp/client/ydb_persqueue_core/persqueue.h @@ -1128,8 +1128,7 @@ struct TWriteSessionSettings : public TRequestSettings<TWriteSessionSettings> { FLUENT_SETTING_DEFAULT(bool, ValidateSeqNo, true); //! Manages cluster discovery mode. - FLUENT_SETTING_OPTIONAL(EClusterDiscoveryMode, ClusterDiscoveryMode); - + FLUENT_SETTING_DEFAULT(EClusterDiscoveryMode, ClusterDiscoveryMode, EClusterDiscoveryMode::Auto); }; //! Read settings for single topic. |