diff --git a/c++/greptime/v1/meta/heartbeat.pb.cc b/c++/greptime/v1/meta/heartbeat.pb.cc index dd66d6bb..b9b45be9 100644 --- a/c++/greptime/v1/meta/heartbeat.pb.cc +++ b/c++/greptime/v1/meta/heartbeat.pb.cc @@ -141,10 +141,21 @@ struct HeartbeatResponseDefaultTypeInternal { }; }; PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 HeartbeatResponseDefaultTypeInternal _HeartbeatResponse_default_instance_; +PROTOBUF_CONSTEXPR GrantedRegion_ExtensionsEntry_DoNotUse::GrantedRegion_ExtensionsEntry_DoNotUse( + ::_pbi::ConstantInitialized) {} +struct GrantedRegion_ExtensionsEntry_DoNotUseDefaultTypeInternal { + PROTOBUF_CONSTEXPR GrantedRegion_ExtensionsEntry_DoNotUseDefaultTypeInternal() + : _instance(::_pbi::ConstantInitialized{}) {} + ~GrantedRegion_ExtensionsEntry_DoNotUseDefaultTypeInternal() {} + union { + GrantedRegion_ExtensionsEntry_DoNotUse _instance; + }; +}; +PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 GrantedRegion_ExtensionsEntry_DoNotUseDefaultTypeInternal _GrantedRegion_ExtensionsEntry_DoNotUse_default_instance_; PROTOBUF_CONSTEXPR GrantedRegion::GrantedRegion( ::_pbi::ConstantInitialized): _impl_{ - /*decltype(_impl_.region_id_)*/uint64_t{0u} - , /*decltype(_impl_.manifest_version_)*/uint64_t{0u} + /*decltype(_impl_.extensions_)*/{::_pbi::ConstantInitialized()} + , /*decltype(_impl_.region_id_)*/uint64_t{0u} , /*decltype(_impl_.role_)*/0 , /*decltype(_impl_._cached_size_)*/{}} {} struct GrantedRegionDefaultTypeInternal { @@ -222,7 +233,7 @@ PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORIT } // namespace meta } // namespace v1 } // namespace greptime -static ::_pb::Metadata file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[13]; +static ::_pb::Metadata file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[14]; static const ::_pb::EnumDescriptor* file_level_enum_descriptors_greptime_2fv1_2fmeta_2fheartbeat_2eproto[1]; static constexpr ::_pb::ServiceDescriptor const** file_level_service_descriptors_greptime_2fv1_2fmeta_2fheartbeat_2eproto = nullptr; @@ -312,6 +323,16 @@ const uint32_t TableStruct_greptime_2fv1_2fmeta_2fheartbeat_2eproto::offsets[] P PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::HeartbeatResponse, _impl_.header_), PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::HeartbeatResponse, _impl_.mailbox_message_), PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::HeartbeatResponse, _impl_.region_lease_), + PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::GrantedRegion_ExtensionsEntry_DoNotUse, _has_bits_), + PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::GrantedRegion_ExtensionsEntry_DoNotUse, _internal_metadata_), + ~0u, // no _extensions_ + ~0u, // no _oneof_case_ + ~0u, // no _weak_field_map_ + ~0u, // no _inlined_string_donated_ + PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::GrantedRegion_ExtensionsEntry_DoNotUse, key_), + PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::GrantedRegion_ExtensionsEntry_DoNotUse, value_), + 0, + 1, ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::GrantedRegion, _internal_metadata_), ~0u, // no _extensions_ @@ -320,7 +341,7 @@ const uint32_t TableStruct_greptime_2fv1_2fmeta_2fheartbeat_2eproto::offsets[] P ~0u, // no _inlined_string_donated_ PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::GrantedRegion, _impl_.region_id_), PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::GrantedRegion, _impl_.role_), - PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::GrantedRegion, _impl_.manifest_version_), + PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::GrantedRegion, _impl_.extensions_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::RegionLease, _internal_metadata_), ~0u, // no _extensions_ @@ -369,11 +390,12 @@ static const ::_pbi::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protode { 58, 66, -1, sizeof(::greptime::v1::meta::FlowStat_FlowLastExecTimeMapEntry_DoNotUse)}, { 68, -1, -1, sizeof(::greptime::v1::meta::FlowStat)}, { 76, -1, -1, sizeof(::greptime::v1::meta::HeartbeatResponse)}, - { 85, -1, -1, sizeof(::greptime::v1::meta::GrantedRegion)}, - { 94, -1, -1, sizeof(::greptime::v1::meta::RegionLease)}, - { 104, -1, -1, sizeof(::greptime::v1::meta::AskLeaderRequest)}, - { 111, -1, -1, sizeof(::greptime::v1::meta::AskLeaderResponse)}, - { 119, -1, -1, sizeof(::greptime::v1::meta::MailboxMessage)}, + { 85, 93, -1, sizeof(::greptime::v1::meta::GrantedRegion_ExtensionsEntry_DoNotUse)}, + { 95, -1, -1, sizeof(::greptime::v1::meta::GrantedRegion)}, + { 104, -1, -1, sizeof(::greptime::v1::meta::RegionLease)}, + { 114, -1, -1, sizeof(::greptime::v1::meta::AskLeaderRequest)}, + { 121, -1, -1, sizeof(::greptime::v1::meta::AskLeaderResponse)}, + { 129, -1, -1, sizeof(::greptime::v1::meta::MailboxMessage)}, }; static const ::_pb::Message* const file_default_instances[] = { @@ -385,6 +407,7 @@ static const ::_pb::Message* const file_default_instances[] = { &::greptime::v1::meta::_FlowStat_FlowLastExecTimeMapEntry_DoNotUse_default_instance_._instance, &::greptime::v1::meta::_FlowStat_default_instance_._instance, &::greptime::v1::meta::_HeartbeatResponse_default_instance_._instance, + &::greptime::v1::meta::_GrantedRegion_ExtensionsEntry_DoNotUse_default_instance_._instance, &::greptime::v1::meta::_GrantedRegion_default_instance_._instance, &::greptime::v1::meta::_RegionLease_default_instance_._instance, &::greptime::v1::meta::_AskLeaderRequest_default_instance_._instance, @@ -425,39 +448,41 @@ const char descriptor_table_protodef_greptime_2fv1_2fmeta_2fheartbeat_2eproto[] "ader\030\001 \001(\0132 .greptime.v1.meta.ResponseHe" "ader\0229\n\017mailbox_message\030\002 \001(\0132 .greptime" ".v1.meta.MailboxMessage\0223\n\014region_lease\030" - "\003 \001(\0132\035.greptime.v1.meta.RegionLease\"h\n\r" - "GrantedRegion\022\021\n\tregion_id\030\001 \001(\004\022*\n\004role" - "\030\002 \001(\0162\034.greptime.v1.meta.RegionRole\022\030\n\020" - "manifest_version\030\003 \001(\004\"\222\001\n\013RegionLease\0220" - "\n\007regions\030\001 \003(\0132\037.greptime.v1.meta.Grant" - "edRegion\022\034\n\024duration_since_epoch\030\002 \001(\004\022\025" - "\n\rlease_seconds\030\003 \001(\004\022\034\n\024closeable_regio" - "n_ids\030\004 \003(\004\"C\n\020AskLeaderRequest\022/\n\006heade" - "r\030\001 \001(\0132\037.greptime.v1.meta.RequestHeader" - "\"m\n\021AskLeaderResponse\0220\n\006header\030\001 \001(\0132 ." - "greptime.v1.meta.ResponseHeader\022&\n\006leade" - "r\030\002 \001(\0132\026.greptime.v1.meta.Peer\"|\n\016Mailb" - "oxMessage\022\n\n\002id\030\001 \001(\004\022\017\n\007subject\030\002 \001(\t\022\014" - "\n\004from\030\003 \001(\t\022\n\n\002to\030\004 \001(\t\022\030\n\020timestamp_mi" - "llis\030\005 \001(\003\022\016\n\004json\030\006 \001(\tH\000B\t\n\007payload*=\n" - "\nRegionRole\022\n\n\006Leader\020\000\022\014\n\010Follower\020\001\022\025\n" - "\021DowngradingLeader\020\0022\277\001\n\tHeartbeat\022Z\n\tHe" - "artbeat\022\".greptime.v1.meta.HeartbeatRequ" - "est\032#.greptime.v1.meta.HeartbeatResponse" - "\"\000(\0010\001\022V\n\tAskLeader\022\".greptime.v1.meta.A" - "skLeaderRequest\032#.greptime.v1.meta.AskLe" - "aderResponse\"\000BOwnCustomDestructor(this, &GrantedRegion::ArenaDtor); + } // @@protoc_insertion_point(arena_constructor:greptime.v1.meta.GrantedRegion) } GrantedRegion::GrantedRegion(const GrantedRegion& from) : ::PROTOBUF_NAMESPACE_ID::Message() { GrantedRegion* const _this = this; (void)_this; new (&_impl_) Impl_{ - decltype(_impl_.region_id_){} - , decltype(_impl_.manifest_version_){} + /*decltype(_impl_.extensions_)*/{} + , decltype(_impl_.region_id_){} , decltype(_impl_.role_){} , /*decltype(_impl_._cached_size_)*/{}}; _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); + _this->_impl_.extensions_.MergeFrom(from._impl_.extensions_); ::memcpy(&_impl_.region_id_, &from._impl_.region_id_, static_cast(reinterpret_cast(&_impl_.role_) - reinterpret_cast(&_impl_.region_id_)) + sizeof(_impl_.role_)); @@ -2326,8 +2369,8 @@ inline void GrantedRegion::SharedCtor( (void)arena; (void)is_message_owned; new (&_impl_) Impl_{ - decltype(_impl_.region_id_){uint64_t{0u}} - , decltype(_impl_.manifest_version_){uint64_t{0u}} + /*decltype(_impl_.extensions_)*/{::_pbi::ArenaInitialized(), arena} + , decltype(_impl_.region_id_){uint64_t{0u}} , decltype(_impl_.role_){0} , /*decltype(_impl_._cached_size_)*/{} }; @@ -2337,6 +2380,7 @@ GrantedRegion::~GrantedRegion() { // @@protoc_insertion_point(destructor:greptime.v1.meta.GrantedRegion) if (auto *arena = _internal_metadata_.DeleteReturnArena<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>()) { (void)arena; + ArenaDtor(this); return; } SharedDtor(); @@ -2344,8 +2388,14 @@ GrantedRegion::~GrantedRegion() { inline void GrantedRegion::SharedDtor() { GOOGLE_DCHECK(GetArenaForAllocation() == nullptr); + _impl_.extensions_.Destruct(); + _impl_.extensions_.~MapField(); } +void GrantedRegion::ArenaDtor(void* object) { + GrantedRegion* _this = reinterpret_cast< GrantedRegion* >(object); + _this->_impl_.extensions_.Destruct(); +} void GrantedRegion::SetCachedSize(int size) const { _impl_._cached_size_.Set(size); } @@ -2356,6 +2406,7 @@ void GrantedRegion::Clear() { // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; + _impl_.extensions_.Clear(); ::memset(&_impl_.region_id_, 0, static_cast( reinterpret_cast(&_impl_.role_) - reinterpret_cast(&_impl_.region_id_)) + sizeof(_impl_.role_)); @@ -2385,11 +2436,16 @@ const char* GrantedRegion::_InternalParse(const char* ptr, ::_pbi::ParseContext* } else goto handle_unusual; continue; - // uint64 manifest_version = 3; - case 3: - if (PROTOBUF_PREDICT_TRUE(static_cast(tag) == 24)) { - _impl_.manifest_version_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint64(&ptr); - CHK_(ptr); + // map extensions = 99; + case 99: + if (PROTOBUF_PREDICT_TRUE(static_cast(tag) == 26)) { + ptr -= 2; + do { + ptr += 2; + ptr = ctx->ParseMessage(&_impl_.extensions_, ptr); + CHK_(ptr); + if (!ctx->DataAvailable(ptr)) break; + } while (::PROTOBUF_NAMESPACE_ID::internal::ExpectTag<794>(ptr)); } else goto handle_unusual; continue; @@ -2435,10 +2491,30 @@ uint8_t* GrantedRegion::_InternalSerialize( 2, this->_internal_role(), target); } - // uint64 manifest_version = 3; - if (this->_internal_manifest_version() != 0) { - target = stream->EnsureSpace(target); - target = ::_pbi::WireFormatLite::WriteUInt64ToArray(3, this->_internal_manifest_version(), target); + // map extensions = 99; + if (!this->_internal_extensions().empty()) { + using MapType = ::_pb::Map; + using WireHelper = GrantedRegion_ExtensionsEntry_DoNotUse::Funcs; + const auto& map_field = this->_internal_extensions(); + auto check_utf8 = [](const MapType::value_type& entry) { + (void)entry; + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( + entry.first.data(), static_cast(entry.first.length()), + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, + "greptime.v1.meta.GrantedRegion.ExtensionsEntry.key"); + }; + + if (stream->IsSerializationDeterministic() && map_field.size() > 1) { + for (const auto& entry : ::_pbi::MapSorterPtr(map_field)) { + target = WireHelper::InternalSerialize(99, entry.first, entry.second, target, stream); + check_utf8(entry); + } + } else { + for (const auto& entry : map_field) { + target = WireHelper::InternalSerialize(99, entry.first, entry.second, target, stream); + check_utf8(entry); + } + } } if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { @@ -2457,16 +2533,20 @@ size_t GrantedRegion::ByteSizeLong() const { // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; + // map extensions = 99; + total_size += 2 * + ::PROTOBUF_NAMESPACE_ID::internal::FromIntSize(this->_internal_extensions_size()); + for (::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >::const_iterator + it = this->_internal_extensions().begin(); + it != this->_internal_extensions().end(); ++it) { + total_size += GrantedRegion_ExtensionsEntry_DoNotUse::Funcs::ByteSizeLong(it->first, it->second); + } + // uint64 region_id = 1; if (this->_internal_region_id() != 0) { total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(this->_internal_region_id()); } - // uint64 manifest_version = 3; - if (this->_internal_manifest_version() != 0) { - total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(this->_internal_manifest_version()); - } - // .greptime.v1.meta.RegionRole role = 2; if (this->_internal_role() != 0) { total_size += 1 + @@ -2491,12 +2571,10 @@ void GrantedRegion::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const :: uint32_t cached_has_bits = 0; (void) cached_has_bits; + _this->_impl_.extensions_.MergeFrom(from._impl_.extensions_); if (from._internal_region_id() != 0) { _this->_internal_set_region_id(from._internal_region_id()); } - if (from._internal_manifest_version() != 0) { - _this->_internal_set_manifest_version(from._internal_manifest_version()); - } if (from._internal_role() != 0) { _this->_internal_set_role(from._internal_role()); } @@ -2517,6 +2595,7 @@ bool GrantedRegion::IsInitialized() const { void GrantedRegion::InternalSwap(GrantedRegion* other) { using std::swap; _internal_metadata_.InternalSwap(&other->_internal_metadata_); + _impl_.extensions_.InternalSwap(&other->_impl_.extensions_); ::PROTOBUF_NAMESPACE_ID::internal::memswap< PROTOBUF_FIELD_OFFSET(GrantedRegion, _impl_.role_) + sizeof(GrantedRegion::_impl_.role_) @@ -2528,7 +2607,7 @@ void GrantedRegion::InternalSwap(GrantedRegion* other) { ::PROTOBUF_NAMESPACE_ID::Metadata GrantedRegion::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_getter, &descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_once, - file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[8]); + file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[9]); } // =================================================================== @@ -2815,7 +2894,7 @@ void RegionLease::InternalSwap(RegionLease* other) { ::PROTOBUF_NAMESPACE_ID::Metadata RegionLease::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_getter, &descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_once, - file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[9]); + file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[10]); } // =================================================================== @@ -3014,7 +3093,7 @@ void AskLeaderRequest::InternalSwap(AskLeaderRequest* other) { ::PROTOBUF_NAMESPACE_ID::Metadata AskLeaderRequest::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_getter, &descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_once, - file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[10]); + file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[11]); } // =================================================================== @@ -3265,7 +3344,7 @@ void AskLeaderResponse::InternalSwap(AskLeaderResponse* other) { ::PROTOBUF_NAMESPACE_ID::Metadata AskLeaderResponse::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_getter, &descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_once, - file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[11]); + file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[12]); } // =================================================================== @@ -3705,7 +3784,7 @@ void MailboxMessage::InternalSwap(MailboxMessage* other) { ::PROTOBUF_NAMESPACE_ID::Metadata MailboxMessage::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_getter, &descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_once, - file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[12]); + file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[13]); } // @@protoc_insertion_point(namespace_scope) @@ -3745,6 +3824,10 @@ template<> PROTOBUF_NOINLINE ::greptime::v1::meta::HeartbeatResponse* Arena::CreateMaybeMessage< ::greptime::v1::meta::HeartbeatResponse >(Arena* arena) { return Arena::CreateMessageInternal< ::greptime::v1::meta::HeartbeatResponse >(arena); } +template<> PROTOBUF_NOINLINE ::greptime::v1::meta::GrantedRegion_ExtensionsEntry_DoNotUse* +Arena::CreateMaybeMessage< ::greptime::v1::meta::GrantedRegion_ExtensionsEntry_DoNotUse >(Arena* arena) { + return Arena::CreateMessageInternal< ::greptime::v1::meta::GrantedRegion_ExtensionsEntry_DoNotUse >(arena); +} template<> PROTOBUF_NOINLINE ::greptime::v1::meta::GrantedRegion* Arena::CreateMaybeMessage< ::greptime::v1::meta::GrantedRegion >(Arena* arena) { return Arena::CreateMessageInternal< ::greptime::v1::meta::GrantedRegion >(arena); diff --git a/c++/greptime/v1/meta/heartbeat.pb.h b/c++/greptime/v1/meta/heartbeat.pb.h index 549f58b2..692e8e4f 100644 --- a/c++/greptime/v1/meta/heartbeat.pb.h +++ b/c++/greptime/v1/meta/heartbeat.pb.h @@ -70,6 +70,9 @@ extern FlowStat_FlowStatSizeEntry_DoNotUseDefaultTypeInternal _FlowStat_FlowStat class GrantedRegion; struct GrantedRegionDefaultTypeInternal; extern GrantedRegionDefaultTypeInternal _GrantedRegion_default_instance_; +class GrantedRegion_ExtensionsEntry_DoNotUse; +struct GrantedRegion_ExtensionsEntry_DoNotUseDefaultTypeInternal; +extern GrantedRegion_ExtensionsEntry_DoNotUseDefaultTypeInternal _GrantedRegion_ExtensionsEntry_DoNotUse_default_instance_; class HeartbeatRequest; struct HeartbeatRequestDefaultTypeInternal; extern HeartbeatRequestDefaultTypeInternal _HeartbeatRequest_default_instance_; @@ -101,6 +104,7 @@ template<> ::greptime::v1::meta::FlowStat* Arena::CreateMaybeMessage<::greptime: template<> ::greptime::v1::meta::FlowStat_FlowLastExecTimeMapEntry_DoNotUse* Arena::CreateMaybeMessage<::greptime::v1::meta::FlowStat_FlowLastExecTimeMapEntry_DoNotUse>(Arena*); template<> ::greptime::v1::meta::FlowStat_FlowStatSizeEntry_DoNotUse* Arena::CreateMaybeMessage<::greptime::v1::meta::FlowStat_FlowStatSizeEntry_DoNotUse>(Arena*); template<> ::greptime::v1::meta::GrantedRegion* Arena::CreateMaybeMessage<::greptime::v1::meta::GrantedRegion>(Arena*); +template<> ::greptime::v1::meta::GrantedRegion_ExtensionsEntry_DoNotUse* Arena::CreateMaybeMessage<::greptime::v1::meta::GrantedRegion_ExtensionsEntry_DoNotUse>(Arena*); template<> ::greptime::v1::meta::HeartbeatRequest* Arena::CreateMaybeMessage<::greptime::v1::meta::HeartbeatRequest>(Arena*); template<> ::greptime::v1::meta::HeartbeatResponse* Arena::CreateMaybeMessage<::greptime::v1::meta::HeartbeatResponse>(Arena*); template<> ::greptime::v1::meta::MailboxMessage* Arena::CreateMaybeMessage<::greptime::v1::meta::MailboxMessage>(Arena*); @@ -1322,6 +1326,32 @@ class HeartbeatResponse final : }; // ------------------------------------------------------------------- +class GrantedRegion_ExtensionsEntry_DoNotUse : public ::PROTOBUF_NAMESPACE_ID::internal::MapEntry { +public: + typedef ::PROTOBUF_NAMESPACE_ID::internal::MapEntry SuperType; + GrantedRegion_ExtensionsEntry_DoNotUse(); + explicit PROTOBUF_CONSTEXPR GrantedRegion_ExtensionsEntry_DoNotUse( + ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized); + explicit GrantedRegion_ExtensionsEntry_DoNotUse(::PROTOBUF_NAMESPACE_ID::Arena* arena); + void MergeFrom(const GrantedRegion_ExtensionsEntry_DoNotUse& other); + static const GrantedRegion_ExtensionsEntry_DoNotUse* internal_default_instance() { return reinterpret_cast(&_GrantedRegion_ExtensionsEntry_DoNotUse_default_instance_); } + static bool ValidateKey(std::string* s) { + return ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(s->data(), static_cast(s->size()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE, "greptime.v1.meta.GrantedRegion.ExtensionsEntry.key"); + } + static bool ValidateValue(void*) { return true; } + using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom; + ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final; + friend struct ::TableStruct_greptime_2fv1_2fmeta_2fheartbeat_2eproto; +}; + +// ------------------------------------------------------------------- + class GrantedRegion final : public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:greptime.v1.meta.GrantedRegion) */ { public: @@ -1370,7 +1400,7 @@ class GrantedRegion final : &_GrantedRegion_default_instance_); } static constexpr int kIndexInFileMessages = - 8; + 9; friend void swap(GrantedRegion& a, GrantedRegion& b) { a.Swap(&b); @@ -1431,6 +1461,8 @@ class GrantedRegion final : protected: explicit GrantedRegion(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned = false); + private: + static void ArenaDtor(void* object); public: static const ClassData _class_data_; @@ -1440,13 +1472,31 @@ class GrantedRegion final : // nested types ---------------------------------------------------- + // accessors ------------------------------------------------------- enum : int { + kExtensionsFieldNumber = 99, kRegionIdFieldNumber = 1, - kManifestVersionFieldNumber = 3, kRoleFieldNumber = 2, }; + // map extensions = 99; + int extensions_size() const; + private: + int _internal_extensions_size() const; + public: + void clear_extensions(); + private: + const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >& + _internal_extensions() const; + ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >* + _internal_mutable_extensions(); + public: + const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >& + extensions() const; + ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >* + mutable_extensions(); + // uint64 region_id = 1; void clear_region_id(); uint64_t region_id() const; @@ -1456,15 +1506,6 @@ class GrantedRegion final : void _internal_set_region_id(uint64_t value); public: - // uint64 manifest_version = 3; - void clear_manifest_version(); - uint64_t manifest_version() const; - void set_manifest_version(uint64_t value); - private: - uint64_t _internal_manifest_version() const; - void _internal_set_manifest_version(uint64_t value); - public: - // .greptime.v1.meta.RegionRole role = 2; void clear_role(); ::greptime::v1::meta::RegionRole role() const; @@ -1482,8 +1523,12 @@ class GrantedRegion final : typedef void InternalArenaConstructable_; typedef void DestructorSkippable_; struct Impl_ { + ::PROTOBUF_NAMESPACE_ID::internal::MapField< + GrantedRegion_ExtensionsEntry_DoNotUse, + std::string, std::string, + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING, + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_BYTES> extensions_; uint64_t region_id_; - uint64_t manifest_version_; int role_; mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; }; @@ -1540,7 +1585,7 @@ class RegionLease final : &_RegionLease_default_instance_); } static constexpr int kIndexInFileMessages = - 9; + 10; friend void swap(RegionLease& a, RegionLease& b) { a.Swap(&b); @@ -1744,7 +1789,7 @@ class AskLeaderRequest final : &_AskLeaderRequest_default_instance_); } static constexpr int kIndexInFileMessages = - 10; + 11; friend void swap(AskLeaderRequest& a, AskLeaderRequest& b) { a.Swap(&b); @@ -1901,7 +1946,7 @@ class AskLeaderResponse final : &_AskLeaderResponse_default_instance_); } static constexpr int kIndexInFileMessages = - 11; + 12; friend void swap(AskLeaderResponse& a, AskLeaderResponse& b) { a.Swap(&b); @@ -2083,7 +2128,7 @@ class MailboxMessage final : &_MailboxMessage_default_instance_); } static constexpr int kIndexInFileMessages = - 12; + 13; friend void swap(MailboxMessage& a, MailboxMessage& b) { a.Swap(&b); @@ -3554,6 +3599,8 @@ inline void HeartbeatResponse::set_allocated_region_lease(::greptime::v1::meta:: // ------------------------------------------------------------------- +// ------------------------------------------------------------------- + // GrantedRegion // uint64 region_id = 1; @@ -3596,24 +3643,33 @@ inline void GrantedRegion::set_role(::greptime::v1::meta::RegionRole value) { // @@protoc_insertion_point(field_set:greptime.v1.meta.GrantedRegion.role) } -// uint64 manifest_version = 3; -inline void GrantedRegion::clear_manifest_version() { - _impl_.manifest_version_ = uint64_t{0u}; +// map extensions = 99; +inline int GrantedRegion::_internal_extensions_size() const { + return _impl_.extensions_.size(); } -inline uint64_t GrantedRegion::_internal_manifest_version() const { - return _impl_.manifest_version_; +inline int GrantedRegion::extensions_size() const { + return _internal_extensions_size(); } -inline uint64_t GrantedRegion::manifest_version() const { - // @@protoc_insertion_point(field_get:greptime.v1.meta.GrantedRegion.manifest_version) - return _internal_manifest_version(); +inline void GrantedRegion::clear_extensions() { + _impl_.extensions_.Clear(); } -inline void GrantedRegion::_internal_set_manifest_version(uint64_t value) { - - _impl_.manifest_version_ = value; +inline const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >& +GrantedRegion::_internal_extensions() const { + return _impl_.extensions_.GetMap(); +} +inline const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >& +GrantedRegion::extensions() const { + // @@protoc_insertion_point(field_map:greptime.v1.meta.GrantedRegion.extensions) + return _internal_extensions(); } -inline void GrantedRegion::set_manifest_version(uint64_t value) { - _internal_set_manifest_version(value); - // @@protoc_insertion_point(field_set:greptime.v1.meta.GrantedRegion.manifest_version) +inline ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >* +GrantedRegion::_internal_mutable_extensions() { + return _impl_.extensions_.MutableMap(); +} +inline ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >* +GrantedRegion::mutable_extensions() { + // @@protoc_insertion_point(field_mutable_map:greptime.v1.meta.GrantedRegion.extensions) + return _internal_mutable_extensions(); } // ------------------------------------------------------------------- @@ -4317,6 +4373,8 @@ inline MailboxMessage::PayloadCase MailboxMessage::payload_case() const { // ------------------------------------------------------------------- +// ------------------------------------------------------------------- + // @@protoc_insertion_point(namespace_scope) diff --git a/go/greptime/v1/meta/heartbeat.pb.go b/go/greptime/v1/meta/heartbeat.pb.go index 43a588d1..e1f07f06 100644 --- a/go/greptime/v1/meta/heartbeat.pb.go +++ b/go/greptime/v1/meta/heartbeat.pb.go @@ -509,10 +509,9 @@ type GrantedRegion struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - RegionId uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"` - Role RegionRole `protobuf:"varint,2,opt,name=role,proto3,enum=greptime.v1.meta.RegionRole" json:"role,omitempty"` - // The manifest version of the region leader. - ManifestVersion uint64 `protobuf:"varint,3,opt,name=manifest_version,json=manifestVersion,proto3" json:"manifest_version,omitempty"` + RegionId uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"` + Role RegionRole `protobuf:"varint,2,opt,name=role,proto3,enum=greptime.v1.meta.RegionRole" json:"role,omitempty"` + Extensions map[string][]byte `protobuf:"bytes,99,rep,name=extensions,proto3" json:"extensions,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` } func (x *GrantedRegion) Reset() { @@ -561,11 +560,11 @@ func (x *GrantedRegion) GetRole() RegionRole { return RegionRole_Leader } -func (x *GrantedRegion) GetManifestVersion() uint64 { +func (x *GrantedRegion) GetExtensions() map[string][]byte { if x != nil { - return x.ManifestVersion + return x.Extensions } - return 0 + return nil } type RegionLease struct { @@ -959,73 +958,79 @@ var file_greptime_v1_meta_heartbeat_proto_rawDesc = []byte{ 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x52, 0x0b, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x4c, 0x65, - 0x61, 0x73, 0x65, 0x22, 0x89, 0x01, 0x0a, 0x0d, 0x47, 0x72, 0x61, 0x6e, 0x74, 0x65, 0x64, 0x52, + 0x61, 0x73, 0x65, 0x22, 0xee, 0x01, 0x0a, 0x0d, 0x47, 0x72, 0x61, 0x6e, 0x74, 0x65, 0x64, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x12, 0x1b, 0x0a, 0x09, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x04, 0x52, 0x08, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x12, 0x30, 0x0a, 0x04, 0x72, 0x6f, 0x6c, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x1c, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x52, 0x6f, 0x6c, 0x65, 0x52, 0x04, - 0x72, 0x6f, 0x6c, 0x65, 0x12, 0x29, 0x0a, 0x10, 0x6d, 0x61, 0x6e, 0x69, 0x66, 0x65, 0x73, 0x74, - 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0f, - 0x6d, 0x61, 0x6e, 0x69, 0x66, 0x65, 0x73, 0x74, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x22, - 0xd1, 0x01, 0x0a, 0x0b, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x12, - 0x39, 0x0a, 0x07, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, - 0x32, 0x1f, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, - 0x65, 0x74, 0x61, 0x2e, 0x47, 0x72, 0x61, 0x6e, 0x74, 0x65, 0x64, 0x52, 0x65, 0x67, 0x69, 0x6f, - 0x6e, 0x52, 0x07, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x30, 0x0a, 0x14, 0x64, 0x75, - 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x73, 0x69, 0x6e, 0x63, 0x65, 0x5f, 0x65, 0x70, 0x6f, - 0x63, 0x68, 0x18, 0x02, 0x20, 0x01, 0x28, 0x04, 0x52, 0x12, 0x64, 0x75, 0x72, 0x61, 0x74, 0x69, - 0x6f, 0x6e, 0x53, 0x69, 0x6e, 0x63, 0x65, 0x45, 0x70, 0x6f, 0x63, 0x68, 0x12, 0x23, 0x0a, 0x0d, - 0x6c, 0x65, 0x61, 0x73, 0x65, 0x5f, 0x73, 0x65, 0x63, 0x6f, 0x6e, 0x64, 0x73, 0x18, 0x03, 0x20, - 0x01, 0x28, 0x04, 0x52, 0x0c, 0x6c, 0x65, 0x61, 0x73, 0x65, 0x53, 0x65, 0x63, 0x6f, 0x6e, 0x64, - 0x73, 0x12, 0x30, 0x0a, 0x14, 0x63, 0x6c, 0x6f, 0x73, 0x65, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x72, - 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x73, 0x18, 0x04, 0x20, 0x03, 0x28, 0x04, 0x52, - 0x12, 0x63, 0x6c, 0x6f, 0x73, 0x65, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, - 0x49, 0x64, 0x73, 0x22, 0x4b, 0x0a, 0x10, 0x41, 0x73, 0x6b, 0x4c, 0x65, 0x61, 0x64, 0x65, 0x72, - 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x37, 0x0a, 0x06, 0x68, 0x65, 0x61, 0x64, 0x65, - 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, - 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x52, 0x65, 0x71, 0x75, 0x65, - 0x73, 0x74, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x52, 0x06, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, - 0x22, 0x7d, 0x0a, 0x11, 0x41, 0x73, 0x6b, 0x4c, 0x65, 0x61, 0x64, 0x65, 0x72, 0x52, 0x65, 0x73, - 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x38, 0x0a, 0x06, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x18, - 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, - 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, - 0x65, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x52, 0x06, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x12, - 0x2e, 0x0a, 0x06, 0x6c, 0x65, 0x61, 0x64, 0x65, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, - 0x16, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, - 0x74, 0x61, 0x2e, 0x50, 0x65, 0x65, 0x72, 0x52, 0x06, 0x6c, 0x65, 0x61, 0x64, 0x65, 0x72, 0x22, - 0xaa, 0x01, 0x0a, 0x0e, 0x4d, 0x61, 0x69, 0x6c, 0x62, 0x6f, 0x78, 0x4d, 0x65, 0x73, 0x73, 0x61, - 0x67, 0x65, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x04, 0x52, 0x02, - 0x69, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x73, 0x75, 0x62, 0x6a, 0x65, 0x63, 0x74, 0x18, 0x02, 0x20, - 0x01, 0x28, 0x09, 0x52, 0x07, 0x73, 0x75, 0x62, 0x6a, 0x65, 0x63, 0x74, 0x12, 0x12, 0x0a, 0x04, - 0x66, 0x72, 0x6f, 0x6d, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x66, 0x72, 0x6f, 0x6d, - 0x12, 0x0e, 0x0a, 0x02, 0x74, 0x6f, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x02, 0x74, 0x6f, - 0x12, 0x29, 0x0a, 0x10, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x5f, 0x6d, 0x69, - 0x6c, 0x6c, 0x69, 0x73, 0x18, 0x05, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0f, 0x74, 0x69, 0x6d, 0x65, - 0x73, 0x74, 0x61, 0x6d, 0x70, 0x4d, 0x69, 0x6c, 0x6c, 0x69, 0x73, 0x12, 0x14, 0x0a, 0x04, 0x6a, - 0x73, 0x6f, 0x6e, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x04, 0x6a, 0x73, 0x6f, - 0x6e, 0x42, 0x09, 0x0a, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x2a, 0x3d, 0x0a, 0x0a, - 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x52, 0x6f, 0x6c, 0x65, 0x12, 0x0a, 0x0a, 0x06, 0x4c, 0x65, - 0x61, 0x64, 0x65, 0x72, 0x10, 0x00, 0x12, 0x0c, 0x0a, 0x08, 0x46, 0x6f, 0x6c, 0x6c, 0x6f, 0x77, - 0x65, 0x72, 0x10, 0x01, 0x12, 0x15, 0x0a, 0x11, 0x44, 0x6f, 0x77, 0x6e, 0x67, 0x72, 0x61, 0x64, - 0x69, 0x6e, 0x67, 0x4c, 0x65, 0x61, 0x64, 0x65, 0x72, 0x10, 0x02, 0x32, 0xbf, 0x01, 0x0a, 0x09, - 0x48, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x12, 0x5a, 0x0a, 0x09, 0x48, 0x65, 0x61, - 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x12, 0x22, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, - 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x48, 0x65, 0x61, 0x72, 0x74, 0x62, - 0x65, 0x61, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x23, 0x2e, 0x67, 0x72, 0x65, - 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x48, 0x65, - 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, - 0x00, 0x28, 0x01, 0x30, 0x01, 0x12, 0x56, 0x0a, 0x09, 0x41, 0x73, 0x6b, 0x4c, 0x65, 0x61, 0x64, - 0x65, 0x72, 0x12, 0x22, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, - 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x41, 0x73, 0x6b, 0x4c, 0x65, 0x61, 0x64, 0x65, 0x72, 0x52, - 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x23, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, - 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x41, 0x73, 0x6b, 0x4c, 0x65, 0x61, - 0x64, 0x65, 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x42, 0x3c, 0x5a, - 0x3a, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x47, 0x72, 0x65, 0x70, - 0x74, 0x69, 0x6d, 0x65, 0x54, 0x65, 0x61, 0x6d, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, - 0x65, 0x2d, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74, - 0x69, 0x6d, 0x65, 0x2f, 0x76, 0x31, 0x2f, 0x6d, 0x65, 0x74, 0x61, 0x62, 0x06, 0x70, 0x72, 0x6f, - 0x74, 0x6f, 0x33, + 0x72, 0x6f, 0x6c, 0x65, 0x12, 0x4f, 0x0a, 0x0a, 0x65, 0x78, 0x74, 0x65, 0x6e, 0x73, 0x69, 0x6f, + 0x6e, 0x73, 0x18, 0x63, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x2f, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, + 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x47, 0x72, 0x61, 0x6e, + 0x74, 0x65, 0x64, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x2e, 0x45, 0x78, 0x74, 0x65, 0x6e, 0x73, + 0x69, 0x6f, 0x6e, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x0a, 0x65, 0x78, 0x74, 0x65, 0x6e, + 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x1a, 0x3d, 0x0a, 0x0f, 0x45, 0x78, 0x74, 0x65, 0x6e, 0x73, 0x69, + 0x6f, 0x6e, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, + 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, + 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, + 0x3a, 0x02, 0x38, 0x01, 0x22, 0xd1, 0x01, 0x0a, 0x0b, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x4c, + 0x65, 0x61, 0x73, 0x65, 0x12, 0x39, 0x0a, 0x07, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x73, 0x18, + 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, + 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x47, 0x72, 0x61, 0x6e, 0x74, 0x65, 0x64, + 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x52, 0x07, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x73, 0x12, + 0x30, 0x0a, 0x14, 0x64, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x73, 0x69, 0x6e, 0x63, + 0x65, 0x5f, 0x65, 0x70, 0x6f, 0x63, 0x68, 0x18, 0x02, 0x20, 0x01, 0x28, 0x04, 0x52, 0x12, 0x64, + 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x69, 0x6e, 0x63, 0x65, 0x45, 0x70, 0x6f, 0x63, + 0x68, 0x12, 0x23, 0x0a, 0x0d, 0x6c, 0x65, 0x61, 0x73, 0x65, 0x5f, 0x73, 0x65, 0x63, 0x6f, 0x6e, + 0x64, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0c, 0x6c, 0x65, 0x61, 0x73, 0x65, 0x53, + 0x65, 0x63, 0x6f, 0x6e, 0x64, 0x73, 0x12, 0x30, 0x0a, 0x14, 0x63, 0x6c, 0x6f, 0x73, 0x65, 0x61, + 0x62, 0x6c, 0x65, 0x5f, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x73, 0x18, 0x04, + 0x20, 0x03, 0x28, 0x04, 0x52, 0x12, 0x63, 0x6c, 0x6f, 0x73, 0x65, 0x61, 0x62, 0x6c, 0x65, 0x52, + 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x73, 0x22, 0x4b, 0x0a, 0x10, 0x41, 0x73, 0x6b, 0x4c, + 0x65, 0x61, 0x64, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x37, 0x0a, 0x06, + 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x67, + 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, + 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x52, 0x06, 0x68, + 0x65, 0x61, 0x64, 0x65, 0x72, 0x22, 0x7d, 0x0a, 0x11, 0x41, 0x73, 0x6b, 0x4c, 0x65, 0x61, 0x64, + 0x65, 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x38, 0x0a, 0x06, 0x68, 0x65, + 0x61, 0x64, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x67, 0x72, 0x65, + 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x52, 0x65, + 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x52, 0x06, 0x68, 0x65, + 0x61, 0x64, 0x65, 0x72, 0x12, 0x2e, 0x0a, 0x06, 0x6c, 0x65, 0x61, 0x64, 0x65, 0x72, 0x18, 0x02, + 0x20, 0x01, 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, + 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x50, 0x65, 0x65, 0x72, 0x52, 0x06, 0x6c, 0x65, + 0x61, 0x64, 0x65, 0x72, 0x22, 0xaa, 0x01, 0x0a, 0x0e, 0x4d, 0x61, 0x69, 0x6c, 0x62, 0x6f, 0x78, + 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, + 0x01, 0x28, 0x04, 0x52, 0x02, 0x69, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x73, 0x75, 0x62, 0x6a, 0x65, + 0x63, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x73, 0x75, 0x62, 0x6a, 0x65, 0x63, + 0x74, 0x12, 0x12, 0x0a, 0x04, 0x66, 0x72, 0x6f, 0x6d, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, + 0x04, 0x66, 0x72, 0x6f, 0x6d, 0x12, 0x0e, 0x0a, 0x02, 0x74, 0x6f, 0x18, 0x04, 0x20, 0x01, 0x28, + 0x09, 0x52, 0x02, 0x74, 0x6f, 0x12, 0x29, 0x0a, 0x10, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, + 0x6d, 0x70, 0x5f, 0x6d, 0x69, 0x6c, 0x6c, 0x69, 0x73, 0x18, 0x05, 0x20, 0x01, 0x28, 0x03, 0x52, + 0x0f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x4d, 0x69, 0x6c, 0x6c, 0x69, 0x73, + 0x12, 0x14, 0x0a, 0x04, 0x6a, 0x73, 0x6f, 0x6e, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, + 0x52, 0x04, 0x6a, 0x73, 0x6f, 0x6e, 0x42, 0x09, 0x0a, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, + 0x64, 0x2a, 0x3d, 0x0a, 0x0a, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x52, 0x6f, 0x6c, 0x65, 0x12, + 0x0a, 0x0a, 0x06, 0x4c, 0x65, 0x61, 0x64, 0x65, 0x72, 0x10, 0x00, 0x12, 0x0c, 0x0a, 0x08, 0x46, + 0x6f, 0x6c, 0x6c, 0x6f, 0x77, 0x65, 0x72, 0x10, 0x01, 0x12, 0x15, 0x0a, 0x11, 0x44, 0x6f, 0x77, + 0x6e, 0x67, 0x72, 0x61, 0x64, 0x69, 0x6e, 0x67, 0x4c, 0x65, 0x61, 0x64, 0x65, 0x72, 0x10, 0x02, + 0x32, 0xbf, 0x01, 0x0a, 0x09, 0x48, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x12, 0x5a, + 0x0a, 0x09, 0x48, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x12, 0x22, 0x2e, 0x67, 0x72, + 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x48, + 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, + 0x23, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, + 0x74, 0x61, 0x2e, 0x48, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x52, 0x65, 0x73, 0x70, + 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x30, 0x01, 0x12, 0x56, 0x0a, 0x09, 0x41, 0x73, + 0x6b, 0x4c, 0x65, 0x61, 0x64, 0x65, 0x72, 0x12, 0x22, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, + 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x41, 0x73, 0x6b, 0x4c, 0x65, + 0x61, 0x64, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x23, 0x2e, 0x67, 0x72, + 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x41, + 0x73, 0x6b, 0x4c, 0x65, 0x61, 0x64, 0x65, 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, + 0x22, 0x00, 0x42, 0x3c, 0x5a, 0x3a, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, + 0x2f, 0x47, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x54, 0x65, 0x61, 0x6d, 0x2f, 0x67, 0x72, + 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2d, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x2f, + 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2f, 0x76, 0x31, 0x2f, 0x6d, 0x65, 0x74, 0x61, + 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, } var ( @@ -1041,7 +1046,7 @@ func file_greptime_v1_meta_heartbeat_proto_rawDescGZIP() []byte { } var file_greptime_v1_meta_heartbeat_proto_enumTypes = make([]protoimpl.EnumInfo, 1) -var file_greptime_v1_meta_heartbeat_proto_msgTypes = make([]protoimpl.MessageInfo, 13) +var file_greptime_v1_meta_heartbeat_proto_msgTypes = make([]protoimpl.MessageInfo, 14) var file_greptime_v1_meta_heartbeat_proto_goTypes = []interface{}{ (RegionRole)(0), // 0: greptime.v1.meta.RegionRole (*HeartbeatRequest)(nil), // 1: greptime.v1.meta.HeartbeatRequest @@ -1057,15 +1062,16 @@ var file_greptime_v1_meta_heartbeat_proto_goTypes = []interface{}{ nil, // 11: greptime.v1.meta.RegionStat.ExtensionsEntry nil, // 12: greptime.v1.meta.FlowStat.FlowStatSizeEntry nil, // 13: greptime.v1.meta.FlowStat.FlowLastExecTimeMapEntry - (*RequestHeader)(nil), // 14: greptime.v1.meta.RequestHeader - (*Peer)(nil), // 15: greptime.v1.meta.Peer - (*TimeInterval)(nil), // 16: greptime.v1.meta.TimeInterval - (*ResponseHeader)(nil), // 17: greptime.v1.meta.ResponseHeader + nil, // 14: greptime.v1.meta.GrantedRegion.ExtensionsEntry + (*RequestHeader)(nil), // 15: greptime.v1.meta.RequestHeader + (*Peer)(nil), // 16: greptime.v1.meta.Peer + (*TimeInterval)(nil), // 17: greptime.v1.meta.TimeInterval + (*ResponseHeader)(nil), // 18: greptime.v1.meta.ResponseHeader } var file_greptime_v1_meta_heartbeat_proto_depIdxs = []int32{ - 14, // 0: greptime.v1.meta.HeartbeatRequest.header:type_name -> greptime.v1.meta.RequestHeader - 15, // 1: greptime.v1.meta.HeartbeatRequest.peer:type_name -> greptime.v1.meta.Peer - 16, // 2: greptime.v1.meta.HeartbeatRequest.report_interval:type_name -> greptime.v1.meta.TimeInterval + 15, // 0: greptime.v1.meta.HeartbeatRequest.header:type_name -> greptime.v1.meta.RequestHeader + 16, // 1: greptime.v1.meta.HeartbeatRequest.peer:type_name -> greptime.v1.meta.Peer + 17, // 2: greptime.v1.meta.HeartbeatRequest.report_interval:type_name -> greptime.v1.meta.TimeInterval 3, // 3: greptime.v1.meta.HeartbeatRequest.region_stats:type_name -> greptime.v1.meta.RegionStat 10, // 4: greptime.v1.meta.HeartbeatRequest.mailbox_message:type_name -> greptime.v1.meta.MailboxMessage 2, // 5: greptime.v1.meta.HeartbeatRequest.info:type_name -> greptime.v1.meta.NodeInfo @@ -1074,23 +1080,24 @@ var file_greptime_v1_meta_heartbeat_proto_depIdxs = []int32{ 11, // 8: greptime.v1.meta.RegionStat.extensions:type_name -> greptime.v1.meta.RegionStat.ExtensionsEntry 12, // 9: greptime.v1.meta.FlowStat.flow_stat_size:type_name -> greptime.v1.meta.FlowStat.FlowStatSizeEntry 13, // 10: greptime.v1.meta.FlowStat.flow_last_exec_time_map:type_name -> greptime.v1.meta.FlowStat.FlowLastExecTimeMapEntry - 17, // 11: greptime.v1.meta.HeartbeatResponse.header:type_name -> greptime.v1.meta.ResponseHeader + 18, // 11: greptime.v1.meta.HeartbeatResponse.header:type_name -> greptime.v1.meta.ResponseHeader 10, // 12: greptime.v1.meta.HeartbeatResponse.mailbox_message:type_name -> greptime.v1.meta.MailboxMessage 7, // 13: greptime.v1.meta.HeartbeatResponse.region_lease:type_name -> greptime.v1.meta.RegionLease 0, // 14: greptime.v1.meta.GrantedRegion.role:type_name -> greptime.v1.meta.RegionRole - 6, // 15: greptime.v1.meta.RegionLease.regions:type_name -> greptime.v1.meta.GrantedRegion - 14, // 16: greptime.v1.meta.AskLeaderRequest.header:type_name -> greptime.v1.meta.RequestHeader - 17, // 17: greptime.v1.meta.AskLeaderResponse.header:type_name -> greptime.v1.meta.ResponseHeader - 15, // 18: greptime.v1.meta.AskLeaderResponse.leader:type_name -> greptime.v1.meta.Peer - 1, // 19: greptime.v1.meta.Heartbeat.Heartbeat:input_type -> greptime.v1.meta.HeartbeatRequest - 8, // 20: greptime.v1.meta.Heartbeat.AskLeader:input_type -> greptime.v1.meta.AskLeaderRequest - 5, // 21: greptime.v1.meta.Heartbeat.Heartbeat:output_type -> greptime.v1.meta.HeartbeatResponse - 9, // 22: greptime.v1.meta.Heartbeat.AskLeader:output_type -> greptime.v1.meta.AskLeaderResponse - 21, // [21:23] is the sub-list for method output_type - 19, // [19:21] is the sub-list for method input_type - 19, // [19:19] is the sub-list for extension type_name - 19, // [19:19] is the sub-list for extension extendee - 0, // [0:19] is the sub-list for field type_name + 14, // 15: greptime.v1.meta.GrantedRegion.extensions:type_name -> greptime.v1.meta.GrantedRegion.ExtensionsEntry + 6, // 16: greptime.v1.meta.RegionLease.regions:type_name -> greptime.v1.meta.GrantedRegion + 15, // 17: greptime.v1.meta.AskLeaderRequest.header:type_name -> greptime.v1.meta.RequestHeader + 18, // 18: greptime.v1.meta.AskLeaderResponse.header:type_name -> greptime.v1.meta.ResponseHeader + 16, // 19: greptime.v1.meta.AskLeaderResponse.leader:type_name -> greptime.v1.meta.Peer + 1, // 20: greptime.v1.meta.Heartbeat.Heartbeat:input_type -> greptime.v1.meta.HeartbeatRequest + 8, // 21: greptime.v1.meta.Heartbeat.AskLeader:input_type -> greptime.v1.meta.AskLeaderRequest + 5, // 22: greptime.v1.meta.Heartbeat.Heartbeat:output_type -> greptime.v1.meta.HeartbeatResponse + 9, // 23: greptime.v1.meta.Heartbeat.AskLeader:output_type -> greptime.v1.meta.AskLeaderResponse + 22, // [22:24] is the sub-list for method output_type + 20, // [20:22] is the sub-list for method input_type + 20, // [20:20] is the sub-list for extension type_name + 20, // [20:20] is the sub-list for extension extendee + 0, // [0:20] is the sub-list for field type_name } func init() { file_greptime_v1_meta_heartbeat_proto_init() } @@ -1230,7 +1237,7 @@ func file_greptime_v1_meta_heartbeat_proto_init() { GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: file_greptime_v1_meta_heartbeat_proto_rawDesc, NumEnums: 1, - NumMessages: 13, + NumMessages: 14, NumExtensions: 0, NumServices: 1, }, diff --git a/java/src/main/java/greptime/v1/meta/HeartbeatOuterClass.java b/java/src/main/java/greptime/v1/meta/HeartbeatOuterClass.java index b819fff4..dcf584e2 100644 --- a/java/src/main/java/greptime/v1/meta/HeartbeatOuterClass.java +++ b/java/src/main/java/greptime/v1/meta/HeartbeatOuterClass.java @@ -7215,14 +7215,40 @@ public interface GrantedRegionOrBuilder extends greptime.v1.meta.HeartbeatOuterClass.RegionRole getRole(); /** - * 
-     * The manifest version of the region leader.
-     *
- * - * uint64 manifest_version = 3; - * @return The manifestVersion. + * map<string, bytes> extensions = 99; + */ + int getExtensionsCount(); + /** + * map<string, bytes> extensions = 99; + */ + boolean containsExtensions( + java.lang.String key); + /** + * Use {@link #getExtensionsMap()} instead. + */ + @java.lang.Deprecated + java.util.Map + getExtensions(); + /** + * map<string, bytes> extensions = 99; + */ + java.util.Map + getExtensionsMap(); + /** + * map<string, bytes> extensions = 99; */ - long getManifestVersion(); + + /* nullable */ +com.google.protobuf.ByteString getExtensionsOrDefault( + java.lang.String key, + /* nullable */ +com.google.protobuf.ByteString defaultValue); + /** + * map<string, bytes> extensions = 99; + */ + + com.google.protobuf.ByteString getExtensionsOrThrow( + java.lang.String key); } /** * 
@@ -7264,6 +7290,7 @@ private GrantedRegion(
       if (extensionRegistry == null) {
         throw new java.lang.NullPointerException();
       }
+      int mutable_bitField0_ = 0;
       com.google.protobuf.UnknownFieldSet.Builder unknownFields =
           com.google.protobuf.UnknownFieldSet.newBuilder();
       try {
@@ -7285,9 +7312,17 @@ private GrantedRegion(
               role_ = rawValue;
               break;
             }
-            case 24: {
-
-              manifestVersion_ = input.readUInt64();
+            case 794: {
+              if (!((mutable_bitField0_ & 0x00000001) != 0)) {
+                extensions_ = com.google.protobuf.MapField.newMapField(
+                    ExtensionsDefaultEntryHolder.defaultEntry);
+                mutable_bitField0_ |= 0x00000001;
+              }
+              com.google.protobuf.MapEntry
+              extensions__ = input.readMessage(
+                  ExtensionsDefaultEntryHolder.defaultEntry.getParserForType(), extensionRegistry);
+              extensions_.getMutableMap().put(
+                  extensions__.getKey(), extensions__.getValue());
               break;
             }
             default: {
@@ -7316,6 +7351,18 @@ private GrantedRegion(
       return greptime.v1.meta.HeartbeatOuterClass.internal_static_greptime_v1_meta_GrantedRegion_descriptor;
     }
 
+    @SuppressWarnings({"rawtypes"})
+    @java.lang.Override
+    protected com.google.protobuf.MapField internalGetMapField(
+        int number) {
+      switch (number) {
+        case 99:
+          return internalGetExtensions();
+        default:
+          throw new RuntimeException(
+              "Invalid map field number: " + number);
+      }
+    }
     @java.lang.Override
     protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
         internalGetFieldAccessorTable() {
@@ -7354,19 +7401,85 @@ public long getRegionId() {
       return result == null ? greptime.v1.meta.HeartbeatOuterClass.RegionRole.UNRECOGNIZED : result;
     }
 
-    public static final int MANIFEST_VERSION_FIELD_NUMBER = 3;
-    private long manifestVersion_;
+    public static final int EXTENSIONS_FIELD_NUMBER = 99;
+    private static final class ExtensionsDefaultEntryHolder {
+      static final com.google.protobuf.MapEntry<
+          java.lang.String, com.google.protobuf.ByteString> defaultEntry =
+              com.google.protobuf.MapEntry
+              .newDefaultInstance(
+                  greptime.v1.meta.HeartbeatOuterClass.internal_static_greptime_v1_meta_GrantedRegion_ExtensionsEntry_descriptor, 
+                  com.google.protobuf.WireFormat.FieldType.STRING,
+                  "",
+                  com.google.protobuf.WireFormat.FieldType.BYTES,
+                  com.google.protobuf.ByteString.EMPTY);
+    }
+    private com.google.protobuf.MapField<
+        java.lang.String, com.google.protobuf.ByteString> extensions_;
+    private com.google.protobuf.MapField
+    internalGetExtensions() {
+      if (extensions_ == null) {
+        return com.google.protobuf.MapField.emptyMapField(
+            ExtensionsDefaultEntryHolder.defaultEntry);
+      }
+      return extensions_;
+    }
+
+    public int getExtensionsCount() {
+      return internalGetExtensions().getMap().size();
+    }
     /**
-     * 
-     * The manifest version of the region leader.
-     * 

-     *
-     * uint64 manifest_version = 3;
-     * @return The manifestVersion.
+     * map<string, bytes> extensions = 99;
+     */
+
+    @java.lang.Override
+    public boolean containsExtensions(
+        java.lang.String key) {
+      if (key == null) { throw new NullPointerException("map key"); }
+      return internalGetExtensions().getMap().containsKey(key);
+    }
+    /**
+     * Use {@link #getExtensionsMap()} instead.
+     */
+    @java.lang.Override
+    @java.lang.Deprecated
+    public java.util.Map getExtensions() {
+      return getExtensionsMap();
+    }
+    /**
+     * map<string, bytes> extensions = 99;
      */
     @java.lang.Override
-    public long getManifestVersion() {
-      return manifestVersion_;
+
+    public java.util.Map getExtensionsMap() {
+      return internalGetExtensions().getMap();
+    }
+    /**
+     * map<string, bytes> extensions = 99;
+     */
+    @java.lang.Override
+
+    public com.google.protobuf.ByteString getExtensionsOrDefault(
+        java.lang.String key,
+        com.google.protobuf.ByteString defaultValue) {
+      if (key == null) { throw new NullPointerException("map key"); }
+      java.util.Map map =
+          internalGetExtensions().getMap();
+      return map.containsKey(key) ? map.get(key) : defaultValue;
+    }
+    /**
+     * map<string, bytes> extensions = 99;
+     */
+    @java.lang.Override
+
+    public com.google.protobuf.ByteString getExtensionsOrThrow(
+        java.lang.String key) {
+      if (key == null) { throw new NullPointerException("map key"); }
+      java.util.Map map =
+          internalGetExtensions().getMap();
+      if (!map.containsKey(key)) {
+        throw new java.lang.IllegalArgumentException();
+      }
+      return map.get(key);
     }
 
     private byte memoizedIsInitialized = -1;
@@ -7389,9 +7502,12 @@ public void writeTo(com.google.protobuf.CodedOutputStream output)
       if (role_ != greptime.v1.meta.HeartbeatOuterClass.RegionRole.Leader.getNumber()) {
         output.writeEnum(2, role_);
       }
-      if (manifestVersion_ != 0L) {
-        output.writeUInt64(3, manifestVersion_);
-      }
+      com.google.protobuf.GeneratedMessageV3
+        .serializeStringMapTo(
+          output,
+          internalGetExtensions(),
+          ExtensionsDefaultEntryHolder.defaultEntry,
+          99);
       unknownFields.writeTo(output);
     }
 
@@ -7409,9 +7525,15 @@ public int getSerializedSize() {
         size += com.google.protobuf.CodedOutputStream
           .computeEnumSize(2, role_);
       }
-      if (manifestVersion_ != 0L) {
+      for (java.util.Map.Entry entry
+           : internalGetExtensions().getMap().entrySet()) {
+        com.google.protobuf.MapEntry
+        extensions__ = ExtensionsDefaultEntryHolder.defaultEntry.newBuilderForType()
+            .setKey(entry.getKey())
+            .setValue(entry.getValue())
+            .build();
         size += com.google.protobuf.CodedOutputStream
-          .computeUInt64Size(3, manifestVersion_);
+            .computeMessageSize(99, extensions__);
       }
       size += unknownFields.getSerializedSize();
       memoizedSize = size;
@@ -7431,8 +7553,8 @@ public boolean equals(final java.lang.Object obj) {
       if (getRegionId()
           != other.getRegionId()) return false;
       if (role_ != other.role_) return false;
-      if (getManifestVersion()
-          != other.getManifestVersion()) return false;
+      if (!internalGetExtensions().equals(
+          other.internalGetExtensions())) return false;
       if (!unknownFields.equals(other.unknownFields)) return false;
       return true;
     }
@@ -7449,9 +7571,10 @@ public int hashCode() {
           getRegionId());
       hash = (37 * hash) + ROLE_FIELD_NUMBER;
       hash = (53 * hash) + role_;
-      hash = (37 * hash) + MANIFEST_VERSION_FIELD_NUMBER;
-      hash = (53 * hash) + com.google.protobuf.Internal.hashLong(
-          getManifestVersion());
+      if (!internalGetExtensions().getMap().isEmpty()) {
+        hash = (37 * hash) + EXTENSIONS_FIELD_NUMBER;
+        hash = (53 * hash) + internalGetExtensions().hashCode();
+      }
       hash = (29 * hash) + unknownFields.hashCode();
       memoizedHashCode = hash;
       return hash;
@@ -7563,6 +7686,28 @@ public static final class Builder extends
         return greptime.v1.meta.HeartbeatOuterClass.internal_static_greptime_v1_meta_GrantedRegion_descriptor;
       }
 
+      @SuppressWarnings({"rawtypes"})
+      protected com.google.protobuf.MapField internalGetMapField(
+          int number) {
+        switch (number) {
+          case 99:
+            return internalGetExtensions();
+          default:
+            throw new RuntimeException(
+                "Invalid map field number: " + number);
+        }
+      }
+      @SuppressWarnings({"rawtypes"})
+      protected com.google.protobuf.MapField internalGetMutableMapField(
+          int number) {
+        switch (number) {
+          case 99:
+            return internalGetMutableExtensions();
+          default:
+            throw new RuntimeException(
+                "Invalid map field number: " + number);
+        }
+      }
       @java.lang.Override
       protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
           internalGetFieldAccessorTable() {
@@ -7593,8 +7738,7 @@ public Builder clear() {
 
         role_ = 0;
 
-        manifestVersion_ = 0L;
-
+        internalGetMutableExtensions().clear();
         return this;
       }
 
@@ -7621,9 +7765,11 @@ public greptime.v1.meta.HeartbeatOuterClass.GrantedRegion build() {
       @java.lang.Override
       public greptime.v1.meta.HeartbeatOuterClass.GrantedRegion buildPartial() {
         greptime.v1.meta.HeartbeatOuterClass.GrantedRegion result = new greptime.v1.meta.HeartbeatOuterClass.GrantedRegion(this);
+        int from_bitField0_ = bitField0_;
         result.regionId_ = regionId_;
         result.role_ = role_;
-        result.manifestVersion_ = manifestVersion_;
+        result.extensions_ = internalGetExtensions();
+        result.extensions_.makeImmutable();
         onBuilt();
         return result;
       }
@@ -7678,9 +7824,8 @@ public Builder mergeFrom(greptime.v1.meta.HeartbeatOuterClass.GrantedRegion othe
         if (other.role_ != 0) {
           setRoleValue(other.getRoleValue());
         }
-        if (other.getManifestVersion() != 0L) {
-          setManifestVersion(other.getManifestVersion());
-        }
+        internalGetMutableExtensions().mergeFrom(
+            other.internalGetExtensions());
         this.mergeUnknownFields(other.unknownFields);
         onChanged();
         return this;
@@ -7709,6 +7854,7 @@ public Builder mergeFrom(
         }
         return this;
       }
+      private int bitField0_;
 
       private long regionId_ ;
       /**
@@ -7795,46 +7941,134 @@ public Builder clearRole() {
         return this;
       }
 
-      private long manifestVersion_ ;
+      private com.google.protobuf.MapField<
+          java.lang.String, com.google.protobuf.ByteString> extensions_;
+      private com.google.protobuf.MapField
+      internalGetExtensions() {
+        if (extensions_ == null) {
+          return com.google.protobuf.MapField.emptyMapField(
+              ExtensionsDefaultEntryHolder.defaultEntry);
+        }
+        return extensions_;
+      }
+      private com.google.protobuf.MapField
+      internalGetMutableExtensions() {
+        onChanged();;
+        if (extensions_ == null) {
+          extensions_ = com.google.protobuf.MapField.newMapField(
+              ExtensionsDefaultEntryHolder.defaultEntry);
+        }
+        if (!extensions_.isMutable()) {
+          extensions_ = extensions_.copy();
+        }
+        return extensions_;
+      }
+
+      public int getExtensionsCount() {
+        return internalGetExtensions().getMap().size();
+      }
       /**
-       * 
-       * The manifest version of the region leader.
-       * 

-       *
-       * uint64 manifest_version = 3;
-       * @return The manifestVersion.
+       * map<string, bytes> extensions = 99;
        */
+
       @java.lang.Override
-      public long getManifestVersion() {
-        return manifestVersion_;
+      public boolean containsExtensions(
+          java.lang.String key) {
+        if (key == null) { throw new NullPointerException("map key"); }
+        return internalGetExtensions().getMap().containsKey(key);
       }
       /**
-       * 
-       * The manifest version of the region leader.
-       * 

-       *
-       * uint64 manifest_version = 3;
-       * @param value The manifestVersion to set.
-       * @return This builder for chaining.
+       * Use {@link #getExtensionsMap()} instead.
        */
-      public Builder setManifestVersion(long value) {
-        
-        manifestVersion_ = value;
-        onChanged();
+      @java.lang.Override
+      @java.lang.Deprecated
+      public java.util.Map getExtensions() {
+        return getExtensionsMap();
+      }
+      /**
+       * map<string, bytes> extensions = 99;
+       */
+      @java.lang.Override
+
+      public java.util.Map getExtensionsMap() {
+        return internalGetExtensions().getMap();
+      }
+      /**
+       * map<string, bytes> extensions = 99;
+       */
+      @java.lang.Override
+
+      public com.google.protobuf.ByteString getExtensionsOrDefault(
+          java.lang.String key,
+          com.google.protobuf.ByteString defaultValue) {
+        if (key == null) { throw new NullPointerException("map key"); }
+        java.util.Map map =
+            internalGetExtensions().getMap();
+        return map.containsKey(key) ? map.get(key) : defaultValue;
+      }
+      /**
+       * map<string, bytes> extensions = 99;
+       */
+      @java.lang.Override
+
+      public com.google.protobuf.ByteString getExtensionsOrThrow(
+          java.lang.String key) {
+        if (key == null) { throw new NullPointerException("map key"); }
+        java.util.Map map =
+            internalGetExtensions().getMap();
+        if (!map.containsKey(key)) {
+          throw new java.lang.IllegalArgumentException();
+        }
+        return map.get(key);
+      }
+
+      public Builder clearExtensions() {
+        internalGetMutableExtensions().getMutableMap()
+            .clear();
         return this;
       }
       /**
-       * 
-       * The manifest version of the region leader.
-       * 

-       *
-       * uint64 manifest_version = 3;
-       * @return This builder for chaining.
+       * map<string, bytes> extensions = 99;
        */
-      public Builder clearManifestVersion() {
-        
-        manifestVersion_ = 0L;
-        onChanged();
+
+      public Builder removeExtensions(
+          java.lang.String key) {
+        if (key == null) { throw new NullPointerException("map key"); }
+        internalGetMutableExtensions().getMutableMap()
+            .remove(key);
+        return this;
+      }
+      /**
+       * Use alternate mutation accessors instead.
+       */
+      @java.lang.Deprecated
+      public java.util.Map
+      getMutableExtensions() {
+        return internalGetMutableExtensions().getMutableMap();
+      }
+      /**
+       * map<string, bytes> extensions = 99;
+       */
+      public Builder putExtensions(
+          java.lang.String key,
+          com.google.protobuf.ByteString value) {
+        if (key == null) { throw new NullPointerException("map key"); }
+        if (value == null) {
+  throw new NullPointerException("map value");
+}
+
+        internalGetMutableExtensions().getMutableMap()
+            .put(key, value);
+        return this;
+      }
+      /**
+       * map<string, bytes> extensions = 99;
+       */
+
+      public Builder putAllExtensions(
+          java.util.Map values) {
+        internalGetMutableExtensions().getMutableMap()
+            .putAll(values);
         return this;
       }
       @java.lang.Override
@@ -11880,6 +12114,11 @@ public greptime.v1.meta.HeartbeatOuterClass.MailboxMessage getDefaultInstanceFor
   private static final 
     com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
       internal_static_greptime_v1_meta_GrantedRegion_fieldAccessorTable;
+  private static final com.google.protobuf.Descriptors.Descriptor
+    internal_static_greptime_v1_meta_GrantedRegion_ExtensionsEntry_descriptor;
+  private static final 
+    com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
+      internal_static_greptime_v1_meta_GrantedRegion_ExtensionsEntry_fieldAccessorTable;
   private static final com.google.protobuf.Descriptors.Descriptor
     internal_static_greptime_v1_meta_RegionLease_descriptor;
   private static final 
@@ -11941,30 +12180,32 @@ public greptime.v1.meta.HeartbeatOuterClass.MailboxMessage getDefaultInstanceFor
       "ader\030\001 \001(\0132 .greptime.v1.meta.ResponseHe" +
       "ader\0229\n\017mailbox_message\030\002 \001(\0132 .greptime" +
       ".v1.meta.MailboxMessage\0223\n\014region_lease\030" +
-      "\003 \001(\0132\035.greptime.v1.meta.RegionLease\"h\n\r" +
-      "GrantedRegion\022\021\n\tregion_id\030\001 \001(\004\022*\n\004role" +
-      "\030\002 \001(\0162\034.greptime.v1.meta.RegionRole\022\030\n\020" +
-      "manifest_version\030\003 \001(\004\"\222\001\n\013RegionLease\0220" +
-      "\n\007regions\030\001 \003(\0132\037.greptime.v1.meta.Grant" +
-      "edRegion\022\034\n\024duration_since_epoch\030\002 \001(\004\022\025" +
-      "\n\rlease_seconds\030\003 \001(\004\022\034\n\024closeable_regio" +
-      "n_ids\030\004 \003(\004\"C\n\020AskLeaderRequest\022/\n\006heade" +
-      "r\030\001 \001(\0132\037.greptime.v1.meta.RequestHeader" +
-      "\"m\n\021AskLeaderResponse\0220\n\006header\030\001 \001(\0132 ." +
-      "greptime.v1.meta.ResponseHeader\022&\n\006leade" +
-      "r\030\002 \001(\0132\026.greptime.v1.meta.Peer\"|\n\016Mailb" +
-      "oxMessage\022\n\n\002id\030\001 \001(\004\022\017\n\007subject\030\002 \001(\t\022\014" +
-      "\n\004from\030\003 \001(\t\022\n\n\002to\030\004 \001(\t\022\030\n\020timestamp_mi" +
-      "llis\030\005 \001(\003\022\016\n\004json\030\006 \001(\tH\000B\t\n\007payload*=\n" +
-      "\nRegionRole\022\n\n\006Leader\020\000\022\014\n\010Follower\020\001\022\025\n" +
-      "\021DowngradingLeader\020\0022\277\001\n\tHeartbeat\022Z\n\tHe" +
-      "artbeat\022\".greptime.v1.meta.HeartbeatRequ" +
-      "est\032#.greptime.v1.meta.HeartbeatResponse" +
-      "\"\000(\0010\001\022V\n\tAskLeader\022\".greptime.v1.meta.A" +
-      "skLeaderRequest\032#.greptime.v1.meta.AskLe" +
-      "aderResponse\"\000B extensions = 99;
 }
 
 message RegionLease {