aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorabcdef <akotov@ydb.tech>2023-10-27 12:21:19 +0300
committerabcdef <akotov@ydb.tech>2023-10-27 12:51:39 +0300
commit206239ea12d280c0815c5dbdea8a5f42fd5271b2 (patch)
tree455ae48b835f34b782fe9ea8913cbc605f214bbf
parent7e5fe6b348ea2b8113bb5b83980dd61fada1d15c (diff)
downloadydb-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.cpp5
-rw-r--r--ydb/public/sdk/cpp/client/ydb_persqueue_core/persqueue.h3
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.