diff --git a/.github/import_generation.txt b/.github/import_generation.txt index d6b24041cf0..209e3ef4b62 100644 --- a/.github/import_generation.txt +++ b/.github/import_generation.txt @@ -1 +1 @@ -19 +20 diff --git a/.github/last_commit.txt b/.github/last_commit.txt index 27916a410e8..d9486b7e287 100644 --- a/.github/last_commit.txt +++ b/.github/last_commit.txt @@ -1 +1 @@ -824ceef81947f283a068e13cc46703c70abe0cba +aa02b3d7cea3b9461fe806646f99a51df36d695f diff --git a/include/ydb-cpp-sdk/client/discovery/discovery.h b/include/ydb-cpp-sdk/client/discovery/discovery.h index aed273a512e..53131133768 100644 --- a/include/ydb-cpp-sdk/client/discovery/discovery.h +++ b/include/ydb-cpp-sdk/client/discovery/discovery.h @@ -33,6 +33,7 @@ struct TNodeLocation { std::optional BodyNum; std::optional Body; + std::optional BridgePileName; std::optional DataCenter; std::optional Module; std::optional Rack; @@ -48,7 +49,6 @@ struct TNodeRegistrationSettings : public TSimpleRequestSettings BridgePileId; }; class TNodeRegistrationResult : public TStatus { diff --git a/src/api/protos/draft/persqueue_error_codes.proto b/src/api/protos/draft/persqueue_error_codes.proto index 0e345cbb3ae..9a32a6f00ba 100644 --- a/src/api/protos/draft/persqueue_error_codes.proto +++ b/src/api/protos/draft/persqueue_error_codes.proto @@ -54,6 +54,7 @@ enum EErrorCode { KAFKA_INVALID_PRODUCER_EPOCH = 32; KAFKA_OUT_OF_ORDER_SEQUENCE_NUMBER = 33; + KAFKA_DUPLICATE_SEQUENCE_NUMBER = 34; ERROR = 100; } diff --git a/src/api/protos/draft/ydb_maintenance.proto b/src/api/protos/draft/ydb_maintenance.proto index 1a406c33cc8..39b7c67d325 100644 --- a/src/api/protos/draft/ydb_maintenance.proto +++ b/src/api/protos/draft/ydb_maintenance.proto @@ -46,7 +46,6 @@ message Node { // version defines YDB version for current Node. // For example, 'ydb-stable-24-1'. string version = 9; - uint32 pile_id = 10; } message ListClusterNodesRequest { diff --git a/src/api/protos/ydb_discovery.proto b/src/api/protos/ydb_discovery.proto index 29f429f92e1..3cffe337744 100644 --- a/src/api/protos/ydb_discovery.proto +++ b/src/api/protos/ydb_discovery.proto @@ -69,6 +69,7 @@ message NodeLocation { optional uint32 body_num = 4 [deprecated=true]; optional uint32 body = 100500 [deprecated=true]; // for compatibility with WalleLocation + optional string bridge_pile_name = 5; optional string data_center = 10; optional string module = 20; optional string rack = 30; @@ -83,7 +84,6 @@ message NodeInfo { optional string address = 5; optional NodeLocation location = 6; optional uint64 expire = 7; - optional uint32 bridge_pile_id = 8; } message NodeRegistrationRequest { @@ -95,7 +95,6 @@ message NodeRegistrationRequest { optional string domain_path = 6; optional bool fixed_node_id = 7; optional string path = 8; - optional string bridge_pile_name = 9; } message NodeRegistrationResult { diff --git a/src/client/discovery/discovery.cpp b/src/client/discovery/discovery.cpp index d6e05ed763f..f8326e63675 100644 --- a/src/client/discovery/discovery.cpp +++ b/src/client/discovery/discovery.cpp @@ -63,11 +63,12 @@ TNodeLocation::TNodeLocation(const Ydb::Discovery::NodeLocation& location) , RackNum(location.has_rack_num() ? std::make_optional(location.rack_num()) : std::nullopt) , BodyNum(location.has_body_num() ? std::make_optional(location.body_num()) : std::nullopt) , Body(location.has_body() ? std::make_optional(location.body()) : std::nullopt) + , BridgePileName(location.has_bridge_pile_name() ? std::make_optional(location.bridge_pile_name()) : std::nullopt) , DataCenter(location.has_data_center() ? std::make_optional(location.data_center()) : std::nullopt) , Module(location.has_module() ? std::make_optional(location.module()) : std::nullopt) , Rack(location.has_rack() ? std::make_optional(location.rack()) : std::nullopt) , Unit(location.has_unit() ? std::make_optional(location.unit()) : std::nullopt) - {} +{} TNodeInfo::TNodeInfo(const Ydb::Discovery::NodeInfo& info) : NodeId(info.node_id()) @@ -77,7 +78,6 @@ TNodeInfo::TNodeInfo(const Ydb::Discovery::NodeInfo& info) , Address(info.address()) , Location(info.location()) , Expire(info.expire()) - , BridgePileId(info.has_bridge_pile_id() ? std::make_optional(info.bridge_pile_id()) : std::nullopt) {} TNodeRegistrationResult::TNodeRegistrationResult(TStatus&& status, const Ydb::Discovery::NodeRegistrationResult& proto) @@ -209,13 +209,13 @@ class TDiscoveryClient::TImpl : public TClientImplCommonset_bridge_pile_name(TStringType{location.BridgePileName.value()}); + } if (location.DataCenter) { requestLocation->set_data_center(TStringType{location.DataCenter.value()}); }