diff options
author | azevaykin <azevaykin@yandex-team.com> | 2023-07-19 13:16:22 +0300 |
---|---|---|
committer | azevaykin <azevaykin@yandex-team.com> | 2023-07-19 13:16:22 +0300 |
commit | d477665e8b529afcf2bd83ccb3dd6fc64dfa128e (patch) | |
tree | 2b4a57209bb03825e592043e3e6d939e951f2177 | |
parent | c16f99d4716155ca0122eef33dc86556dc3557fc (diff) | |
download | ydb-d477665e8b529afcf2bd83ccb3dd6fc64dfa128e.tar.gz |
Typo
7 files changed, 12 insertions, 12 deletions
diff --git a/ydb/public/sdk/cpp/client/impl/ydb_endpoints/endpoints.h b/ydb/public/sdk/cpp/client/impl/ydb_endpoints/endpoints.h index fb79052130..f00dabc744 100644 --- a/ydb/public/sdk/cpp/client/impl/ydb_endpoints/endpoints.h +++ b/ydb/public/sdk/cpp/client/impl/ydb_endpoints/endpoints.h @@ -81,7 +81,7 @@ public: // Allows to get stats void SetStatCollector(const NSdkStats::TStatCollector::TEndpointElectorStatCollector& endpointStatCollector); - // Returns prefered (if presents) or best endpoint + // Returns preferred (if presents) or best endpoint TEndpointRecord GetEndpoint(const TEndpointKey& preferredEndpoint) const; // Move endpoint to the end diff --git a/ydb/public/sdk/cpp/client/impl/ydb_endpoints/endpoints_ut.cpp b/ydb/public/sdk/cpp/client/impl/ydb_endpoints/endpoints_ut.cpp index fe0937e916..4c7f3265bb 100644 --- a/ydb/public/sdk/cpp/client/impl/ydb_endpoints/endpoints_ut.cpp +++ b/ydb/public/sdk/cpp/client/impl/ydb_endpoints/endpoints_ut.cpp @@ -148,7 +148,7 @@ Y_UNIT_TEST_SUITE(EndpointElector) { UNIT_ASSERT(endpoints.find("One_B") != endpoints.end()); elector.SetNewState(TVector<TEndpointRecord>{{"One", 1}}); - // no prefered endpoint, expect avaliable + // no preferred endpoint, expect avaliable UNIT_ASSERT_VALUES_EQUAL(elector.GetEndpoint(TEndpointKey("Three", 0)).Endpoint, "One"); UNIT_ASSERT_VALUES_EQUAL(elector.GetEndpoint(TEndpointKey()).Endpoint, "One"); } diff --git a/ydb/public/sdk/cpp/client/impl/ydb_internal/db_driver_state/endpoint_pool.cpp b/ydb/public/sdk/cpp/client/impl/ydb_internal/db_driver_state/endpoint_pool.cpp index 9924cf3ce1..a427c3d279 100644 --- a/ydb/public/sdk/cpp/client/impl/ydb_internal/db_driver_state/endpoint_pool.cpp +++ b/ydb/public/sdk/cpp/client/impl/ydb_internal/db_driver_state/endpoint_pool.cpp @@ -44,12 +44,12 @@ std::pair<NThreading::TFuture<TEndpointUpdateResult>, bool> TEndpointPool::Updat // Is used to convert float to integer load factor // same integer values will be selected randomly. const float multiplicator = 10.0; - const auto& preferedLocation = GetPreferedLocation(result.Result.self_location()); + const auto& preferredLocation = GetPreferredLocation(result.Result.self_location()); for (const auto& endpoint : result.Result.endpoints()) { i32 loadFactor = (i32)(multiplicator * Min(LoadMax, Max(LoadMin, endpoint.load_factor()))); ui64 nodeId = endpoint.node_id(); if (BalancingSettings_.Policy != EBalancingPolicy::UseAllNodes) { - if (endpoint.location() != preferedLocation) { + if (endpoint.location() != preferredLocation) { // Location missmatch, shift this endpoint loadFactor += GetLocalityShift(); } @@ -170,7 +170,7 @@ constexpr i32 TEndpointPool::GetLocalityShift() { return LoadMax * Multiplicator; } -TStringType TEndpointPool::GetPreferedLocation(const TStringType& selfLocation) { +TStringType TEndpointPool::GetPreferredLocation(const TStringType& selfLocation) { switch (BalancingSettings_.Policy) { case EBalancingPolicy::UseAllNodes: return {}; diff --git a/ydb/public/sdk/cpp/client/impl/ydb_internal/db_driver_state/endpoint_pool.h b/ydb/public/sdk/cpp/client/impl/ydb_internal/db_driver_state/endpoint_pool.h index d61476b95c..a5f6954384 100644 --- a/ydb/public/sdk/cpp/client/impl/ydb_internal/db_driver_state/endpoint_pool.h +++ b/ydb/public/sdk/cpp/client/impl/ydb_internal/db_driver_state/endpoint_pool.h @@ -45,7 +45,7 @@ public: static constexpr i32 GetLocalityShift(); private: - TStringType GetPreferedLocation(const TStringType& selfLocation); + TStringType GetPreferredLocation(const TStringType& selfLocation); private: TListEndpointsResultProvider Provider_; diff --git a/ydb/public/sdk/cpp/client/impl/ydb_internal/rpc_request_settings/settings.h b/ydb/public/sdk/cpp/client/impl/ydb_internal/rpc_request_settings/settings.h index 5be2ac64de..9ad9525572 100644 --- a/ydb/public/sdk/cpp/client/impl/ydb_internal/rpc_request_settings/settings.h +++ b/ydb/public/sdk/cpp/client/impl/ydb_internal/rpc_request_settings/settings.h @@ -10,9 +10,9 @@ struct TRpcRequestSettings { TStringType RequestType; std::vector<std::pair<TStringType, TStringType>> Header; enum class TEndpointPolicy { - UsePreferedEndpoint, + UsePreferredEndpoint, UseDiscoveryEndpoint // Use single discovery endpoint for request - } EndpointPolicy = TEndpointPolicy::UsePreferedEndpoint; + } EndpointPolicy = TEndpointPolicy::UsePreferredEndpoint; bool UseAuth = true; TDuration ClientTimeout; @@ -22,7 +22,7 @@ struct TRpcRequestSettings { rpcSettings.TraceId = settings.TraceId_; rpcSettings.RequestType = settings.RequestType_; rpcSettings.Header = settings.Header_; - rpcSettings.EndpointPolicy = TEndpointPolicy::UsePreferedEndpoint; + rpcSettings.EndpointPolicy = TEndpointPolicy::UsePreferredEndpoint; rpcSettings.UseAuth = true; rpcSettings.ClientTimeout = settings.ClientTimeout_; return rpcSettings; diff --git a/ydb/public/sdk/cpp/client/ydb_table/impl/table_client.cpp b/ydb/public/sdk/cpp/client/ydb_table/impl/table_client.cpp index 52ad90e3f4..4cd1ec054e 100644 --- a/ydb/public/sdk/cpp/client/ydb_table/impl/table_client.cpp +++ b/ydb/public/sdk/cpp/client/ydb_table/impl/table_client.cpp @@ -357,7 +357,7 @@ i64 TTableClient::TImpl::GetCurrentPoolSize() const { } TAsyncCreateSessionResult TTableClient::TImpl::CreateSession(const TCreateSessionSettings& settings, bool standalone, - TString preferedLocation) + TString preferredLocation) { auto request = MakeOperationRequest<Ydb::Table::CreateSessionRequest>(settings); @@ -395,7 +395,7 @@ TAsyncCreateSessionResult TTableClient::TImpl::CreateSession(const TCreateSessio DbDriverState_, INITIAL_DEFERRED_CALL_DELAY, rpcSettings, - TEndpointKey(preferedLocation, 0)); + TEndpointKey(preferredLocation, 0)); std::weak_ptr<TDbDriverState> state = DbDriverState_; diff --git a/ydb/public/sdk/cpp/client/ydb_table/impl/table_client.h b/ydb/public/sdk/cpp/client/ydb_table/impl/table_client.h index 7c07260cf9..73b8ee12d9 100644 --- a/ydb/public/sdk/cpp/client/ydb_table/impl/table_client.h +++ b/ydb/public/sdk/cpp/client/ydb_table/impl/table_client.h @@ -123,7 +123,7 @@ public: i64 GetActiveSessionsLimit() const; i64 GetCurrentPoolSize() const; TAsyncCreateSessionResult CreateSession(const TCreateSessionSettings& settings, bool standalone, - TString preferedLocation = TString()); + TString preferredLocation = TString()); TAsyncKeepAliveResult KeepAlive(const TSession::TImpl* session, const TKeepAliveSettings& settings); TFuture<TStatus> CreateTable(Ydb::Table::CreateTableRequest&& request, const TCreateTableSettings& settings); |