diff --git a/c++/greptime/v1/meta/heartbeat.pb.cc b/c++/greptime/v1/meta/heartbeat.pb.cc index 437c1daa..8249d8fa 100644 --- a/c++/greptime/v1/meta/heartbeat.pb.cc +++ b/c++/greptime/v1/meta/heartbeat.pb.cc @@ -93,6 +93,8 @@ PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORIT PROTOBUF_CONSTEXPR RegionLease::RegionLease( ::_pbi::ConstantInitialized): _impl_{ /*decltype(_impl_.regions_)*/{} + , /*decltype(_impl_.closeable_region_ids_)*/{} + , /*decltype(_impl_._closeable_region_ids_cached_byte_size_)*/{0} , /*decltype(_impl_.duration_since_epoch_)*/uint64_t{0u} , /*decltype(_impl_.lease_seconds_)*/uint64_t{0u} , /*decltype(_impl_._cached_size_)*/{}} {} @@ -211,6 +213,7 @@ const uint32_t TableStruct_greptime_2fv1_2fmeta_2fheartbeat_2eproto::offsets[] P PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::RegionLease, _impl_.regions_), PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::RegionLease, _impl_.duration_since_epoch_), PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::RegionLease, _impl_.lease_seconds_), + PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::RegionLease, _impl_.closeable_region_ids_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::AskLeaderRequest, _internal_metadata_), ~0u, // no _extensions_ @@ -246,9 +249,9 @@ static const ::_pbi::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protode { 26, -1, -1, sizeof(::greptime::v1::meta::HeartbeatResponse)}, { 35, -1, -1, sizeof(::greptime::v1::meta::GrantedRegion)}, { 43, -1, -1, sizeof(::greptime::v1::meta::RegionLease)}, - { 52, -1, -1, sizeof(::greptime::v1::meta::AskLeaderRequest)}, - { 59, -1, -1, sizeof(::greptime::v1::meta::AskLeaderResponse)}, - { 67, -1, -1, sizeof(::greptime::v1::meta::MailboxMessage)}, + { 53, -1, -1, sizeof(::greptime::v1::meta::AskLeaderRequest)}, + { 60, -1, -1, sizeof(::greptime::v1::meta::AskLeaderResponse)}, + { 68, -1, -1, sizeof(::greptime::v1::meta::MailboxMessage)}, }; static const ::_pb::Message* const file_default_instances[] = { @@ -284,32 +287,33 @@ const char descriptor_table_protodef_greptime_2fv1_2fmeta_2fheartbeat_2eproto[] "egion_lease\030\003 \001(\0132\035.greptime.v1.meta.Reg" "ionLease\"N\n\rGrantedRegion\022\021\n\tregion_id\030\001" " \001(\004\022*\n\004role\030\002 \001(\0162\034.greptime.v1.meta.Re" - "gionRole\"t\n\013RegionLease\0220\n\007regions\030\001 \003(\013" - "2\037.greptime.v1.meta.GrantedRegion\022\034\n\024dur" - "ation_since_epoch\030\002 \001(\004\022\025\n\rlease_seconds" - "\030\003 \001(\004\"C\n\020AskLeaderRequest\022/\n\006header\030\001 \001" - "(\0132\037.greptime.v1.meta.RequestHeader\"m\n\021A" - "skLeaderResponse\0220\n\006header\030\001 \001(\0132 .grept" - "ime.v1.meta.ResponseHeader\022&\n\006leader\030\002 \001" - "(\0132\026.greptime.v1.meta.Peer\"|\n\016MailboxMes" - "sage\022\n\n\002id\030\001 \001(\004\022\017\n\007subject\030\002 \001(\t\022\014\n\004fro" - "m\030\003 \001(\t\022\n\n\002to\030\004 \001(\t\022\030\n\020timestamp_millis\030" - "\005 \001(\003\022\016\n\004json\030\006 \001(\tH\000B\t\n\007payload*&\n\nRegi" - "onRole\022\n\n\006Leader\020\000\022\014\n\010Follower\020\0012\277\001\n\tHea" - "rtbeat\022Z\n\tHeartbeat\022\".greptime.v1.meta.H" - "eartbeatRequest\032#.greptime.v1.meta.Heart" - "beatResponse\"\000(\0010\001\022V\n\tAskLeader\022\".grepti" - "me.v1.meta.AskLeaderRequest\032#.greptime.v" - "1.meta.AskLeaderResponse\"\000B( reinterpret_cast(&_impl_.lease_seconds_) - reinterpret_cast(&_impl_.duration_since_epoch_)) + sizeof(_impl_.lease_seconds_)); @@ -1735,6 +1745,17 @@ const char* RegionLease::_InternalParse(const char* ptr, ::_pbi::ParseContext* c } else goto handle_unusual; continue; + // repeated uint64 closeable_region_ids = 4; + case 4: + if (PROTOBUF_PREDICT_TRUE(static_cast(tag) == 34)) { + ptr = ::PROTOBUF_NAMESPACE_ID::internal::PackedUInt64Parser(_internal_mutable_closeable_region_ids(), ptr, ctx); + CHK_(ptr); + } else if (static_cast(tag) == 32) { + _internal_add_closeable_region_ids(::PROTOBUF_NAMESPACE_ID::internal::ReadVarint64(&ptr)); + CHK_(ptr); + } else + goto handle_unusual; + continue; default: goto handle_unusual; } // switch @@ -1784,6 +1805,15 @@ uint8_t* RegionLease::_InternalSerialize( target = ::_pbi::WireFormatLite::WriteUInt64ToArray(3, this->_internal_lease_seconds(), target); } + // repeated uint64 closeable_region_ids = 4; + { + int byte_size = _impl_._closeable_region_ids_cached_byte_size_.load(std::memory_order_relaxed); + if (byte_size > 0) { + target = stream->WriteUInt64Packed( + 4, _internal_closeable_region_ids(), byte_size, target); + } + } + if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { target = ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray( _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream); @@ -1807,6 +1837,20 @@ size_t RegionLease::ByteSizeLong() const { ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(msg); } + // repeated uint64 closeable_region_ids = 4; + { + size_t data_size = ::_pbi::WireFormatLite:: + UInt64Size(this->_impl_.closeable_region_ids_); + if (data_size > 0) { + total_size += 1 + + ::_pbi::WireFormatLite::Int32Size(static_cast(data_size)); + } + int cached_size = ::_pbi::ToCachedSize(data_size); + _impl_._closeable_region_ids_cached_byte_size_.store(cached_size, + std::memory_order_relaxed); + total_size += data_size; + } + // uint64 duration_since_epoch = 2; if (this->_internal_duration_since_epoch() != 0) { total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(this->_internal_duration_since_epoch()); @@ -1836,6 +1880,7 @@ void RegionLease::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PR (void) cached_has_bits; _this->_impl_.regions_.MergeFrom(from._impl_.regions_); + _this->_impl_.closeable_region_ids_.MergeFrom(from._impl_.closeable_region_ids_); if (from._internal_duration_since_epoch() != 0) { _this->_internal_set_duration_since_epoch(from._internal_duration_since_epoch()); } @@ -1860,6 +1905,7 @@ void RegionLease::InternalSwap(RegionLease* other) { using std::swap; _internal_metadata_.InternalSwap(&other->_internal_metadata_); _impl_.regions_.InternalSwap(&other->_impl_.regions_); + _impl_.closeable_region_ids_.InternalSwap(&other->_impl_.closeable_region_ids_); ::PROTOBUF_NAMESPACE_ID::internal::memswap< PROTOBUF_FIELD_OFFSET(RegionLease, _impl_.lease_seconds_) + sizeof(RegionLease::_impl_.lease_seconds_) diff --git a/c++/greptime/v1/meta/heartbeat.pb.h b/c++/greptime/v1/meta/heartbeat.pb.h index 6036e778..b5d5987c 100644 --- a/c++/greptime/v1/meta/heartbeat.pb.h +++ b/c++/greptime/v1/meta/heartbeat.pb.h @@ -1073,6 +1073,7 @@ class RegionLease final : enum : int { kRegionsFieldNumber = 1, + kCloseableRegionIdsFieldNumber = 4, kDurationSinceEpochFieldNumber = 2, kLeaseSecondsFieldNumber = 3, }; @@ -1094,6 +1095,28 @@ class RegionLease final : const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::meta::GrantedRegion >& regions() const; + // repeated uint64 closeable_region_ids = 4; + int closeable_region_ids_size() const; + private: + int _internal_closeable_region_ids_size() const; + public: + void clear_closeable_region_ids(); + private: + uint64_t _internal_closeable_region_ids(int index) const; + const ::PROTOBUF_NAMESPACE_ID::RepeatedField< uint64_t >& + _internal_closeable_region_ids() const; + void _internal_add_closeable_region_ids(uint64_t value); + ::PROTOBUF_NAMESPACE_ID::RepeatedField< uint64_t >* + _internal_mutable_closeable_region_ids(); + public: + uint64_t closeable_region_ids(int index) const; + void set_closeable_region_ids(int index, uint64_t value); + void add_closeable_region_ids(uint64_t value); + const ::PROTOBUF_NAMESPACE_ID::RepeatedField< uint64_t >& + closeable_region_ids() const; + ::PROTOBUF_NAMESPACE_ID::RepeatedField< uint64_t >* + mutable_closeable_region_ids(); + // uint64 duration_since_epoch = 2; void clear_duration_since_epoch(); uint64_t duration_since_epoch() const; @@ -1121,6 +1144,8 @@ class RegionLease final : typedef void DestructorSkippable_; struct Impl_ { ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::meta::GrantedRegion > regions_; + ::PROTOBUF_NAMESPACE_ID::RepeatedField< uint64_t > closeable_region_ids_; + mutable std::atomic _closeable_region_ids_cached_byte_size_; uint64_t duration_since_epoch_; uint64_t lease_seconds_; mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; @@ -2713,6 +2738,53 @@ inline void RegionLease::set_lease_seconds(uint64_t value) { // @@protoc_insertion_point(field_set:greptime.v1.meta.RegionLease.lease_seconds) } +// repeated uint64 closeable_region_ids = 4; +inline int RegionLease::_internal_closeable_region_ids_size() const { + return _impl_.closeable_region_ids_.size(); +} +inline int RegionLease::closeable_region_ids_size() const { + return _internal_closeable_region_ids_size(); +} +inline void RegionLease::clear_closeable_region_ids() { + _impl_.closeable_region_ids_.Clear(); +} +inline uint64_t RegionLease::_internal_closeable_region_ids(int index) const { + return _impl_.closeable_region_ids_.Get(index); +} +inline uint64_t RegionLease::closeable_region_ids(int index) const { + // @@protoc_insertion_point(field_get:greptime.v1.meta.RegionLease.closeable_region_ids) + return _internal_closeable_region_ids(index); +} +inline void RegionLease::set_closeable_region_ids(int index, uint64_t value) { + _impl_.closeable_region_ids_.Set(index, value); + // @@protoc_insertion_point(field_set:greptime.v1.meta.RegionLease.closeable_region_ids) +} +inline void RegionLease::_internal_add_closeable_region_ids(uint64_t value) { + _impl_.closeable_region_ids_.Add(value); +} +inline void RegionLease::add_closeable_region_ids(uint64_t value) { + _internal_add_closeable_region_ids(value); + // @@protoc_insertion_point(field_add:greptime.v1.meta.RegionLease.closeable_region_ids) +} +inline const ::PROTOBUF_NAMESPACE_ID::RepeatedField< uint64_t >& +RegionLease::_internal_closeable_region_ids() const { + return _impl_.closeable_region_ids_; +} +inline const ::PROTOBUF_NAMESPACE_ID::RepeatedField< uint64_t >& +RegionLease::closeable_region_ids() const { + // @@protoc_insertion_point(field_list:greptime.v1.meta.RegionLease.closeable_region_ids) + return _internal_closeable_region_ids(); +} +inline ::PROTOBUF_NAMESPACE_ID::RepeatedField< uint64_t >* +RegionLease::_internal_mutable_closeable_region_ids() { + return &_impl_.closeable_region_ids_; +} +inline ::PROTOBUF_NAMESPACE_ID::RepeatedField< uint64_t >* +RegionLease::mutable_closeable_region_ids() { + // @@protoc_insertion_point(field_mutable_list:greptime.v1.meta.RegionLease.closeable_region_ids) + return _internal_mutable_closeable_region_ids(); +} + // ------------------------------------------------------------------- // AskLeaderRequest diff --git a/go/greptime/v1/meta/heartbeat.pb.go b/go/greptime/v1/meta/heartbeat.pb.go index a9a9b6d6..2d5e9a2a 100644 --- a/go/greptime/v1/meta/heartbeat.pb.go +++ b/go/greptime/v1/meta/heartbeat.pb.go @@ -197,7 +197,7 @@ type RegionStat struct { ApproximateBytes int64 `protobuf:"varint,4,opt,name=approximate_bytes,json=approximateBytes,proto3" json:"approximate_bytes,omitempty"` // Approximate number of rows in this region ApproximateRows int64 `protobuf:"varint,5,opt,name=approximate_rows,json=approximateRows,proto3" json:"approximate_rows,omitempty"` - // engine name + // Engine name Engine string `protobuf:"bytes,6,opt,name=engine,proto3" json:"engine,omitempty"` // Region role Role RegionRole `protobuf:"varint,7,opt,name=role,proto3,enum=greptime.v1.meta.RegionRole" json:"role,omitempty"` @@ -410,6 +410,7 @@ type RegionLease struct { Regions []*GrantedRegion `protobuf:"bytes,1,rep,name=regions,proto3" json:"regions,omitempty"` DurationSinceEpoch uint64 `protobuf:"varint,2,opt,name=duration_since_epoch,json=durationSinceEpoch,proto3" json:"duration_since_epoch,omitempty"` LeaseSeconds uint64 `protobuf:"varint,3,opt,name=lease_seconds,json=leaseSeconds,proto3" json:"lease_seconds,omitempty"` + CloseableRegionIds []uint64 `protobuf:"varint,4,rep,packed,name=closeable_region_ids,json=closeableRegionIds,proto3" json:"closeable_region_ids,omitempty"` } func (x *RegionLease) Reset() { @@ -465,6 +466,13 @@ func (x *RegionLease) GetLeaseSeconds() uint64 { return 0 } +func (x *RegionLease) GetCloseableRegionIds() []uint64 { + if x != nil { + return x.CloseableRegionIds + } + return nil +} + type AskLeaderRequest struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache @@ -749,7 +757,7 @@ var file_greptime_v1_meta_heartbeat_proto_rawDesc = []byte{ 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, 0x22, 0x9f, 0x01, 0x0a, 0x0b, 0x52, 0x65, 0x67, 0x69, 0x6f, + 0x52, 0x04, 0x72, 0x6f, 0x6c, 0x65, 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, @@ -759,50 +767,53 @@ var file_greptime_v1_meta_heartbeat_proto_rawDesc = []byte{ 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, 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, + 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, 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, 0x26, 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, 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, + 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, 0x26, 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, 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 ( diff --git a/java/src/main/java/greptime/v1/meta/HeartbeatOuterClass.java b/java/src/main/java/greptime/v1/meta/HeartbeatOuterClass.java index 64eb7588..2c85d9b6 100644 --- a/java/src/main/java/greptime/v1/meta/HeartbeatOuterClass.java +++ b/java/src/main/java/greptime/v1/meta/HeartbeatOuterClass.java @@ -2271,7 +2271,7 @@ public interface RegionStatOrBuilder extends /** *
-     * engine name
+     * Engine name
      * 
* * string engine = 6; @@ -2280,7 +2280,7 @@ public interface RegionStatOrBuilder extends java.lang.String getEngine(); /** *
-     * engine name
+     * Engine name
      * 
* * string engine = 6; @@ -2501,7 +2501,7 @@ public long getApproximateRows() { private volatile java.lang.Object engine_; /** *
-     * engine name
+     * Engine name
      * 
* * string engine = 6; @@ -2522,7 +2522,7 @@ public java.lang.String getEngine() { } /** *
-     * engine name
+     * Engine name
      * 
* * string engine = 6; @@ -3184,7 +3184,7 @@ public Builder clearApproximateRows() { private java.lang.Object engine_ = ""; /** *
-       * engine name
+       * Engine name
        * 
* * string engine = 6; @@ -3204,7 +3204,7 @@ public java.lang.String getEngine() { } /** *
-       * engine name
+       * Engine name
        * 
* * string engine = 6; @@ -3225,7 +3225,7 @@ public java.lang.String getEngine() { } /** *
-       * engine name
+       * Engine name
        * 
* * string engine = 6; @@ -3244,7 +3244,7 @@ public Builder setEngine( } /** *
-       * engine name
+       * Engine name
        * 
* * string engine = 6; @@ -3258,7 +3258,7 @@ public Builder clearEngine() { } /** *
-       * engine name
+       * Engine name
        * 
* * string engine = 6; @@ -5069,6 +5069,23 @@ greptime.v1.meta.HeartbeatOuterClass.GrantedRegionOrBuilder getRegionsOrBuilder( * @return The leaseSeconds. */ long getLeaseSeconds(); + + /** + * repeated uint64 closeable_region_ids = 4; + * @return A list containing the closeableRegionIds. + */ + java.util.List getCloseableRegionIdsList(); + /** + * repeated uint64 closeable_region_ids = 4; + * @return The count of closeableRegionIds. + */ + int getCloseableRegionIdsCount(); + /** + * repeated uint64 closeable_region_ids = 4; + * @param index The index of the element to return. + * @return The closeableRegionIds at the given index. + */ + long getCloseableRegionIds(int index); } /** * Protobuf type {@code greptime.v1.meta.RegionLease} @@ -5084,6 +5101,7 @@ private RegionLease(com.google.protobuf.GeneratedMessageV3.Builder builder) { } private RegionLease() { regions_ = java.util.Collections.emptyList(); + closeableRegionIds_ = emptyLongList(); } @java.lang.Override @@ -5136,6 +5154,27 @@ private RegionLease( leaseSeconds_ = input.readUInt64(); break; } + case 32: { + if (!((mutable_bitField0_ & 0x00000002) != 0)) { + closeableRegionIds_ = newLongList(); + mutable_bitField0_ |= 0x00000002; + } + closeableRegionIds_.addLong(input.readUInt64()); + break; + } + case 34: { + int length = input.readRawVarint32(); + int limit = input.pushLimit(length); + if (!((mutable_bitField0_ & 0x00000002) != 0) && input.getBytesUntilLimit() > 0) { + closeableRegionIds_ = newLongList(); + mutable_bitField0_ |= 0x00000002; + } + while (input.getBytesUntilLimit() > 0) { + closeableRegionIds_.addLong(input.readUInt64()); + } + input.popLimit(limit); + break; + } default: { if (!parseUnknownField( input, unknownFields, extensionRegistry, tag)) { @@ -5156,6 +5195,9 @@ private RegionLease( if (((mutable_bitField0_ & 0x00000001) != 0)) { regions_ = java.util.Collections.unmodifiableList(regions_); } + if (((mutable_bitField0_ & 0x00000002) != 0)) { + closeableRegionIds_.makeImmutable(); // C + } this.unknownFields = unknownFields.build(); makeExtensionsImmutable(); } @@ -5235,6 +5277,34 @@ public long getLeaseSeconds() { return leaseSeconds_; } + public static final int CLOSEABLE_REGION_IDS_FIELD_NUMBER = 4; + private com.google.protobuf.Internal.LongList closeableRegionIds_; + /** + * repeated uint64 closeable_region_ids = 4; + * @return A list containing the closeableRegionIds. + */ + @java.lang.Override + public java.util.List + getCloseableRegionIdsList() { + return closeableRegionIds_; + } + /** + * repeated uint64 closeable_region_ids = 4; + * @return The count of closeableRegionIds. + */ + public int getCloseableRegionIdsCount() { + return closeableRegionIds_.size(); + } + /** + * repeated uint64 closeable_region_ids = 4; + * @param index The index of the element to return. + * @return The closeableRegionIds at the given index. + */ + public long getCloseableRegionIds(int index) { + return closeableRegionIds_.getLong(index); + } + private int closeableRegionIdsMemoizedSerializedSize = -1; + private byte memoizedIsInitialized = -1; @java.lang.Override public final boolean isInitialized() { @@ -5249,6 +5319,7 @@ public final boolean isInitialized() { @java.lang.Override public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io.IOException { + getSerializedSize(); for (int i = 0; i < regions_.size(); i++) { output.writeMessage(1, regions_.get(i)); } @@ -5258,6 +5329,13 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) if (leaseSeconds_ != 0L) { output.writeUInt64(3, leaseSeconds_); } + if (getCloseableRegionIdsList().size() > 0) { + output.writeUInt32NoTag(34); + output.writeUInt32NoTag(closeableRegionIdsMemoizedSerializedSize); + } + for (int i = 0; i < closeableRegionIds_.size(); i++) { + output.writeUInt64NoTag(closeableRegionIds_.getLong(i)); + } unknownFields.writeTo(output); } @@ -5279,6 +5357,20 @@ public int getSerializedSize() { size += com.google.protobuf.CodedOutputStream .computeUInt64Size(3, leaseSeconds_); } + { + int dataSize = 0; + for (int i = 0; i < closeableRegionIds_.size(); i++) { + dataSize += com.google.protobuf.CodedOutputStream + .computeUInt64SizeNoTag(closeableRegionIds_.getLong(i)); + } + size += dataSize; + if (!getCloseableRegionIdsList().isEmpty()) { + size += 1; + size += com.google.protobuf.CodedOutputStream + .computeInt32SizeNoTag(dataSize); + } + closeableRegionIdsMemoizedSerializedSize = dataSize; + } size += unknownFields.getSerializedSize(); memoizedSize = size; return size; @@ -5300,6 +5392,8 @@ public boolean equals(final java.lang.Object obj) { != other.getDurationSinceEpoch()) return false; if (getLeaseSeconds() != other.getLeaseSeconds()) return false; + if (!getCloseableRegionIdsList() + .equals(other.getCloseableRegionIdsList())) return false; if (!unknownFields.equals(other.unknownFields)) return false; return true; } @@ -5321,6 +5415,10 @@ public int hashCode() { hash = (37 * hash) + LEASE_SECONDS_FIELD_NUMBER; hash = (53 * hash) + com.google.protobuf.Internal.hashLong( getLeaseSeconds()); + if (getCloseableRegionIdsCount() > 0) { + hash = (37 * hash) + CLOSEABLE_REGION_IDS_FIELD_NUMBER; + hash = (53 * hash) + getCloseableRegionIdsList().hashCode(); + } hash = (29 * hash) + unknownFields.hashCode(); memoizedHashCode = hash; return hash; @@ -5465,6 +5563,8 @@ public Builder clear() { leaseSeconds_ = 0L; + closeableRegionIds_ = emptyLongList(); + bitField0_ = (bitField0_ & ~0x00000002); return this; } @@ -5503,6 +5603,11 @@ public greptime.v1.meta.HeartbeatOuterClass.RegionLease buildPartial() { } result.durationSinceEpoch_ = durationSinceEpoch_; result.leaseSeconds_ = leaseSeconds_; + if (((bitField0_ & 0x00000002) != 0)) { + closeableRegionIds_.makeImmutable(); + bitField0_ = (bitField0_ & ~0x00000002); + } + result.closeableRegionIds_ = closeableRegionIds_; onBuilt(); return result; } @@ -5583,6 +5688,16 @@ public Builder mergeFrom(greptime.v1.meta.HeartbeatOuterClass.RegionLease other) if (other.getLeaseSeconds() != 0L) { setLeaseSeconds(other.getLeaseSeconds()); } + if (!other.closeableRegionIds_.isEmpty()) { + if (closeableRegionIds_.isEmpty()) { + closeableRegionIds_ = other.closeableRegionIds_; + bitField0_ = (bitField0_ & ~0x00000002); + } else { + ensureCloseableRegionIdsIsMutable(); + closeableRegionIds_.addAll(other.closeableRegionIds_); + } + onChanged(); + } this.mergeUnknownFields(other.unknownFields); onChanged(); return this; @@ -5914,6 +6029,85 @@ public Builder clearLeaseSeconds() { onChanged(); return this; } + + private com.google.protobuf.Internal.LongList closeableRegionIds_ = emptyLongList(); + private void ensureCloseableRegionIdsIsMutable() { + if (!((bitField0_ & 0x00000002) != 0)) { + closeableRegionIds_ = mutableCopy(closeableRegionIds_); + bitField0_ |= 0x00000002; + } + } + /** + * repeated uint64 closeable_region_ids = 4; + * @return A list containing the closeableRegionIds. + */ + public java.util.List + getCloseableRegionIdsList() { + return ((bitField0_ & 0x00000002) != 0) ? + java.util.Collections.unmodifiableList(closeableRegionIds_) : closeableRegionIds_; + } + /** + * repeated uint64 closeable_region_ids = 4; + * @return The count of closeableRegionIds. + */ + public int getCloseableRegionIdsCount() { + return closeableRegionIds_.size(); + } + /** + * repeated uint64 closeable_region_ids = 4; + * @param index The index of the element to return. + * @return The closeableRegionIds at the given index. + */ + public long getCloseableRegionIds(int index) { + return closeableRegionIds_.getLong(index); + } + /** + * repeated uint64 closeable_region_ids = 4; + * @param index The index to set the value at. + * @param value The closeableRegionIds to set. + * @return This builder for chaining. + */ + public Builder setCloseableRegionIds( + int index, long value) { + ensureCloseableRegionIdsIsMutable(); + closeableRegionIds_.setLong(index, value); + onChanged(); + return this; + } + /** + * repeated uint64 closeable_region_ids = 4; + * @param value The closeableRegionIds to add. + * @return This builder for chaining. + */ + public Builder addCloseableRegionIds(long value) { + ensureCloseableRegionIdsIsMutable(); + closeableRegionIds_.addLong(value); + onChanged(); + return this; + } + /** + * repeated uint64 closeable_region_ids = 4; + * @param values The closeableRegionIds to add. + * @return This builder for chaining. + */ + public Builder addAllCloseableRegionIds( + java.lang.Iterable values) { + ensureCloseableRegionIdsIsMutable(); + com.google.protobuf.AbstractMessageLite.Builder.addAll( + values, closeableRegionIds_); + onChanged(); + return this; + } + /** + * repeated uint64 closeable_region_ids = 4; + * @return This builder for chaining. + */ + public Builder clearCloseableRegionIds() { + closeableRegionIds_ = emptyLongList(); + bitField0_ = (bitField0_ & ~0x00000002); + onChanged(); + return this; + } @java.lang.Override public final Builder setUnknownFields( final com.google.protobuf.UnknownFieldSet unknownFields) { @@ -8851,25 +9045,26 @@ public greptime.v1.meta.HeartbeatOuterClass.MailboxMessage getDefaultInstanceFor "egion_lease\030\003 \001(\0132\035.greptime.v1.meta.Reg" + "ionLease\"N\n\rGrantedRegion\022\021\n\tregion_id\030\001" + " \001(\004\022*\n\004role\030\002 \001(\0162\034.greptime.v1.meta.Re" + - "gionRole\"t\n\013RegionLease\0220\n\007regions\030\001 \003(\013" + - "2\037.greptime.v1.meta.GrantedRegion\022\034\n\024dur" + - "ation_since_epoch\030\002 \001(\004\022\025\n\rlease_seconds" + - "\030\003 \001(\004\"C\n\020AskLeaderRequest\022/\n\006header\030\001 \001" + - "(\0132\037.greptime.v1.meta.RequestHeader\"m\n\021A" + - "skLeaderResponse\0220\n\006header\030\001 \001(\0132 .grept" + - "ime.v1.meta.ResponseHeader\022&\n\006leader\030\002 \001" + - "(\0132\026.greptime.v1.meta.Peer\"|\n\016MailboxMes" + - "sage\022\n\n\002id\030\001 \001(\004\022\017\n\007subject\030\002 \001(\t\022\014\n\004fro" + - "m\030\003 \001(\t\022\n\n\002to\030\004 \001(\t\022\030\n\020timestamp_millis\030" + - "\005 \001(\003\022\016\n\004json\030\006 \001(\tH\000B\t\n\007payload*&\n\nRegi" + - "onRole\022\n\n\006Leader\020\000\022\014\n\010Follower\020\0012\277\001\n\tHea" + - "rtbeat\022Z\n\tHeartbeat\022\".greptime.v1.meta.H" + - "eartbeatRequest\032#.greptime.v1.meta.Heart" + - "beatResponse\"\000(\0010\001\022V\n\tAskLeader\022\".grepti" + - "me.v1.meta.AskLeaderRequest\032#.greptime.v" + - "1.meta.AskLeaderResponse\"\000B