aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorazevaykin <azevaykin@yandex-team.com>2023-07-19 13:16:22 +0300
committerazevaykin <azevaykin@yandex-team.com>2023-07-19 13:16:22 +0300
commitd477665e8b529afcf2bd83ccb3dd6fc64dfa128e (patch)
tree2b4a57209bb03825e592043e3e6d939e951f2177
parentc16f99d4716155ca0122eef33dc86556dc3557fc (diff)
downloadydb-d477665e8b529afcf2bd83ccb3dd6fc64dfa128e.tar.gz
Typo
-rw-r--r--ydb/public/sdk/cpp/client/impl/ydb_endpoints/endpoints.h2
-rw-r--r--ydb/public/sdk/cpp/client/impl/ydb_endpoints/endpoints_ut.cpp2
-rw-r--r--ydb/public/sdk/cpp/client/impl/ydb_internal/db_driver_state/endpoint_pool.cpp6
-rw-r--r--ydb/public/sdk/cpp/client/impl/ydb_internal/db_driver_state/endpoint_pool.h2
-rw-r--r--ydb/public/sdk/cpp/client/impl/ydb_internal/rpc_request_settings/settings.h6
-rw-r--r--ydb/public/sdk/cpp/client/ydb_table/impl/table_client.cpp4
-rw-r--r--ydb/public/sdk/cpp/client/ydb_table/impl/table_client.h2
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);