From a70a6af9c69e40f9a918936a48717343402b4393 Mon Sep 17 00:00:00 2001 From: Jeremyhi Date: Tue, 18 Jun 2024 11:42:08 +0800 Subject: [PATCH] feat: flownode role (#178) --- c++/greptime/v1/meta/common.pb.cc | 11 +- c++/greptime/v1/meta/common.pb.h | 3 +- c++/greptime/v1/meta/heartbeat.pb.cc | 99 ++++------ c++/greptime/v1/meta/heartbeat.pb.h | 31 --- go/greptime/v1/meta/common.pb.go | 16 +- go/greptime/v1/meta/heartbeat.pb.go | 177 ++++++++---------- .../main/java/greptime/v1/meta/Common.java | 17 +- .../greptime/v1/meta/HeartbeatOuterClass.java | 152 +++------------ proto/greptime/v1/meta/common.proto | 1 + proto/greptime/v1/meta/heartbeat.proto | 2 - 10 files changed, 181 insertions(+), 328 deletions(-) diff --git a/c++/greptime/v1/meta/common.pb.cc b/c++/greptime/v1/meta/common.pb.cc index 33ebbeee..0ac5a2ee 100644 --- a/c++/greptime/v1/meta/common.pb.cc +++ b/c++/greptime/v1/meta/common.pb.cc @@ -251,14 +251,14 @@ const char descriptor_table_protodef_greptime_2fv1_2fmeta_2fcommon_2eproto[] PRO "\t\"L\n\014TimeInterval\022\036\n\026start_timestamp_mil" "lis\030\001 \001(\003\022\034\n\024end_timestamp_millis\030\002 \001(\003\"" "&\n\010KeyValue\022\013\n\003key\030\001 \001(\014\022\r\n\005value\030\002 \001(\014\"" - "\032\n\013ProcedureId\022\013\n\003key\030\001 \001(\014*\"\n\004Role\022\014\n\010D" - "ATANODE\020\000\022\014\n\010FRONTEND\020\001B::min(), Role_INT_MAX_SENTINEL_DO_NOT_USE_ = std::numeric_limits::max() }; bool Role_IsValid(int value); constexpr Role Role_MIN = DATANODE; -constexpr Role Role_MAX = FRONTEND; +constexpr Role Role_MAX = FLOWNODE; constexpr int Role_ARRAYSIZE = Role_MAX + 1; const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* Role_descriptor(); diff --git a/c++/greptime/v1/meta/heartbeat.pb.cc b/c++/greptime/v1/meta/heartbeat.pb.cc index 4cfe07b2..60aa1a1e 100644 --- a/c++/greptime/v1/meta/heartbeat.pb.cc +++ b/c++/greptime/v1/meta/heartbeat.pb.cc @@ -65,7 +65,6 @@ PROTOBUF_CONSTEXPR RegionStat::RegionStat( , /*decltype(_impl_.rcus_)*/int64_t{0} , /*decltype(_impl_.wcus_)*/int64_t{0} , /*decltype(_impl_.approximate_bytes_)*/int64_t{0} - , /*decltype(_impl_.approximate_rows_)*/int64_t{0} , /*decltype(_impl_.role_)*/0 , /*decltype(_impl_._cached_size_)*/{}} {} struct RegionStatDefaultTypeInternal { @@ -210,7 +209,6 @@ const uint32_t TableStruct_greptime_2fv1_2fmeta_2fheartbeat_2eproto::offsets[] P PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::RegionStat, _impl_.rcus_), PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::RegionStat, _impl_.wcus_), PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::RegionStat, _impl_.approximate_bytes_), - PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::RegionStat, _impl_.approximate_rows_), PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::RegionStat, _impl_.engine_), PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::RegionStat, _impl_.role_), ~0u, // no _has_bits_ @@ -273,12 +271,12 @@ static const ::_pbi::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protode { 0, -1, -1, sizeof(::greptime::v1::meta::HeartbeatRequest)}, { 14, -1, -1, sizeof(::greptime::v1::meta::NodeInfo)}, { 23, -1, -1, sizeof(::greptime::v1::meta::RegionStat)}, - { 36, -1, -1, sizeof(::greptime::v1::meta::HeartbeatResponse)}, - { 45, -1, -1, sizeof(::greptime::v1::meta::GrantedRegion)}, - { 53, -1, -1, sizeof(::greptime::v1::meta::RegionLease)}, - { 63, -1, -1, sizeof(::greptime::v1::meta::AskLeaderRequest)}, - { 70, -1, -1, sizeof(::greptime::v1::meta::AskLeaderResponse)}, - { 78, -1, -1, sizeof(::greptime::v1::meta::MailboxMessage)}, + { 35, -1, -1, sizeof(::greptime::v1::meta::HeartbeatResponse)}, + { 44, -1, -1, sizeof(::greptime::v1::meta::GrantedRegion)}, + { 52, -1, -1, sizeof(::greptime::v1::meta::RegionLease)}, + { 62, -1, -1, sizeof(::greptime::v1::meta::AskLeaderRequest)}, + { 69, -1, -1, sizeof(::greptime::v1::meta::AskLeaderResponse)}, + { 77, -1, -1, sizeof(::greptime::v1::meta::MailboxMessage)}, }; static const ::_pb::Message* const file_default_instances[] = { @@ -307,44 +305,43 @@ const char descriptor_table_protodef_greptime_2fv1_2fmeta_2fheartbeat_2eproto[] "och\030\007 \001(\004\022(\n\004info\030\010 \001(\0132\032.greptime.v1.me" "ta.NodeInfo\"F\n\010NodeInfo\022\017\n\007version\030\001 \001(\t" "\022\022\n\ngit_commit\030\002 \001(\t\022\025\n\rstart_time_ms\030\003 " - "\001(\004\"\254\001\n\nRegionStat\022\021\n\tregion_id\030\001 \001(\004\022\014\n" + "\001(\004\"\222\001\n\nRegionStat\022\021\n\tregion_id\030\001 \001(\004\022\014\n" "\004rcus\030\002 \001(\003\022\014\n\004wcus\030\003 \001(\003\022\031\n\021approximate" - "_bytes\030\004 \001(\003\022\030\n\020approximate_rows\030\005 \001(\003\022\016" - "\n\006engine\030\006 \001(\t\022*\n\004role\030\007 \001(\0162\034.greptime." - "v1.meta.RegionRole\"\265\001\n\021HeartbeatResponse" - "\0220\n\006header\030\001 \001(\0132 .greptime.v1.meta.Resp" - "onseHeader\0229\n\017mailbox_message\030\002 \001(\0132 .gr" - "eptime.v1.meta.MailboxMessage\0223\n\014region_" - "lease\030\003 \001(\0132\035.greptime.v1.meta.RegionLea" - "se\"N\n\rGrantedRegion\022\021\n\tregion_id\030\001 \001(\004\022*" - "\n\004role\030\002 \001(\0162\034.greptime.v1.meta.RegionRo" - "le\"\222\001\n\013RegionLease\0220\n\007regions\030\001 \003(\0132\037.gr" - "eptime.v1.meta.GrantedRegion\022\034\n\024duration" - "_since_epoch\030\002 \001(\004\022\025\n\rlease_seconds\030\003 \001(" - "\004\022\034\n\024closeable_region_ids\030\004 \003(\004\"C\n\020AskLe" - "aderRequest\022/\n\006header\030\001 \001(\0132\037.greptime.v" - "1.meta.RequestHeader\"m\n\021AskLeaderRespons" - "e\0220\n\006header\030\001 \001(\0132 .greptime.v1.meta.Res" - "ponseHeader\022&\n\006leader\030\002 \001(\0132\026.greptime.v" - "1.meta.Peer\"|\n\016MailboxMessage\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_millis\030\005 \001(\003\022\016\n\004json\030\006" - " \001(\tH\000B\t\n\007payload*&\n\nRegionRole\022\n\n\006Leade" - "r\020\000\022\014\n\010Follower\020\0012\277\001\n\tHeartbeat\022Z\n\tHeart" - "beat\022\".greptime.v1.meta.HeartbeatRequest" - "\032#.greptime.v1.meta.HeartbeatResponse\"\000(" - "\0010\001\022V\n\tAskLeader\022\".greptime.v1.meta.AskL" - "eaderRequest\032#.greptime.v1.meta.AskLeade" - "rResponse\"\000B(tag) == 40)) { - _impl_.approximate_rows_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint64(&ptr); - CHK_(ptr); - } else - goto handle_unusual; - continue; // string engine = 6; case 6: if (PROTOBUF_PREDICT_TRUE(static_cast(tag) == 50)) { @@ -1332,12 +1319,6 @@ uint8_t* RegionStat::_InternalSerialize( target = ::_pbi::WireFormatLite::WriteInt64ToArray(4, this->_internal_approximate_bytes(), target); } - // int64 approximate_rows = 5; - if (this->_internal_approximate_rows() != 0) { - target = stream->EnsureSpace(target); - target = ::_pbi::WireFormatLite::WriteInt64ToArray(5, this->_internal_approximate_rows(), target); - } - // string engine = 6; if (!this->_internal_engine().empty()) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( @@ -1398,11 +1379,6 @@ size_t RegionStat::ByteSizeLong() const { total_size += ::_pbi::WireFormatLite::Int64SizePlusOne(this->_internal_approximate_bytes()); } - // int64 approximate_rows = 5; - if (this->_internal_approximate_rows() != 0) { - total_size += ::_pbi::WireFormatLite::Int64SizePlusOne(this->_internal_approximate_rows()); - } - // .greptime.v1.meta.RegionRole role = 7; if (this->_internal_role() != 0) { total_size += 1 + @@ -1442,9 +1418,6 @@ void RegionStat::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PRO if (from._internal_approximate_bytes() != 0) { _this->_internal_set_approximate_bytes(from._internal_approximate_bytes()); } - if (from._internal_approximate_rows() != 0) { - _this->_internal_set_approximate_rows(from._internal_approximate_rows()); - } if (from._internal_role() != 0) { _this->_internal_set_role(from._internal_role()); } diff --git a/c++/greptime/v1/meta/heartbeat.pb.h b/c++/greptime/v1/meta/heartbeat.pb.h index 9a3cd03e..b9a7a2d8 100644 --- a/c++/greptime/v1/meta/heartbeat.pb.h +++ b/c++/greptime/v1/meta/heartbeat.pb.h @@ -706,7 +706,6 @@ class RegionStat final : kRcusFieldNumber = 2, kWcusFieldNumber = 3, kApproximateBytesFieldNumber = 4, - kApproximateRowsFieldNumber = 5, kRoleFieldNumber = 7, }; // string engine = 6; @@ -759,15 +758,6 @@ class RegionStat final : void _internal_set_approximate_bytes(int64_t value); public: - // int64 approximate_rows = 5; - void clear_approximate_rows(); - int64_t approximate_rows() const; - void set_approximate_rows(int64_t value); - private: - int64_t _internal_approximate_rows() const; - void _internal_set_approximate_rows(int64_t value); - public: - // .greptime.v1.meta.RegionRole role = 7; void clear_role(); ::greptime::v1::meta::RegionRole role() const; @@ -790,7 +780,6 @@ class RegionStat final : int64_t rcus_; int64_t wcus_; int64_t approximate_bytes_; - int64_t approximate_rows_; int role_; mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; }; @@ -2669,26 +2658,6 @@ inline void RegionStat::set_approximate_bytes(int64_t value) { // @@protoc_insertion_point(field_set:greptime.v1.meta.RegionStat.approximate_bytes) } -// int64 approximate_rows = 5; -inline void RegionStat::clear_approximate_rows() { - _impl_.approximate_rows_ = int64_t{0}; -} -inline int64_t RegionStat::_internal_approximate_rows() const { - return _impl_.approximate_rows_; -} -inline int64_t RegionStat::approximate_rows() const { - // @@protoc_insertion_point(field_get:greptime.v1.meta.RegionStat.approximate_rows) - return _internal_approximate_rows(); -} -inline void RegionStat::_internal_set_approximate_rows(int64_t value) { - - _impl_.approximate_rows_ = value; -} -inline void RegionStat::set_approximate_rows(int64_t value) { - _internal_set_approximate_rows(value); - // @@protoc_insertion_point(field_set:greptime.v1.meta.RegionStat.approximate_rows) -} - // string engine = 6; inline void RegionStat::clear_engine() { _impl_.engine_.ClearToEmpty(); diff --git a/go/greptime/v1/meta/common.pb.go b/go/greptime/v1/meta/common.pb.go index 9d401d95..42811ae2 100644 --- a/go/greptime/v1/meta/common.pb.go +++ b/go/greptime/v1/meta/common.pb.go @@ -39,6 +39,7 @@ type Role int32 const ( Role_DATANODE Role = 0 Role_FRONTEND Role = 1 + Role_FLOWNODE Role = 2 ) // Enum value maps for Role. @@ -46,10 +47,12 @@ var ( Role_name = map[int32]string{ 0: "DATANODE", 1: "FRONTEND", + 2: "FLOWNODE", } Role_value = map[string]int32{ "DATANODE": 0, "FRONTEND": 1, + "FLOWNODE": 2, } ) @@ -553,13 +556,14 @@ var file_greptime_v1_meta_common_proto_rawDesc = []byte{ 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x22, 0x1f, 0x0a, 0x0b, 0x50, 0x72, 0x6f, 0x63, 0x65, 0x64, 0x75, 0x72, 0x65, 0x49, 0x64, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x03, 0x6b, - 0x65, 0x79, 0x2a, 0x22, 0x0a, 0x04, 0x52, 0x6f, 0x6c, 0x65, 0x12, 0x0c, 0x0a, 0x08, 0x44, 0x41, + 0x65, 0x79, 0x2a, 0x30, 0x0a, 0x04, 0x52, 0x6f, 0x6c, 0x65, 0x12, 0x0c, 0x0a, 0x08, 0x44, 0x41, 0x54, 0x41, 0x4e, 0x4f, 0x44, 0x45, 0x10, 0x00, 0x12, 0x0c, 0x0a, 0x08, 0x46, 0x52, 0x4f, 0x4e, - 0x54, 0x45, 0x4e, 0x44, 0x10, 0x01, 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, + 0x54, 0x45, 0x4e, 0x44, 0x10, 0x01, 0x12, 0x0c, 0x0a, 0x08, 0x46, 0x4c, 0x4f, 0x57, 0x4e, 0x4f, + 0x44, 0x45, 0x10, 0x02, 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/go/greptime/v1/meta/heartbeat.pb.go b/go/greptime/v1/meta/heartbeat.pb.go index 457292ed..2d7a436f 100644 --- a/go/greptime/v1/meta/heartbeat.pb.go +++ b/go/greptime/v1/meta/heartbeat.pb.go @@ -269,8 +269,6 @@ type RegionStat struct { Wcus int64 `protobuf:"varint,3,opt,name=wcus,proto3" json:"wcus,omitempty"` // Approximate bytes of this region 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 string `protobuf:"bytes,6,opt,name=engine,proto3" json:"engine,omitempty"` // Region role @@ -337,13 +335,6 @@ func (x *RegionStat) GetApproximateBytes() int64 { return 0 } -func (x *RegionStat) GetApproximateRows() int64 { - if x != nil { - return x.ApproximateRows - } - return 0 -} - func (x *RegionStat) GetEngine() string { if x != nil { return x.Engine @@ -805,7 +796,7 @@ var file_greptime_v1_meta_heartbeat_proto_rawDesc = []byte{ 0x5f, 0x63, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x67, 0x69, 0x74, 0x43, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x12, 0x22, 0x0a, 0x0d, 0x73, 0x74, 0x61, 0x72, 0x74, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x5f, 0x6d, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x04, 0x52, - 0x0b, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x4d, 0x73, 0x22, 0xf3, 0x01, 0x0a, + 0x0b, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x4d, 0x73, 0x22, 0xc8, 0x01, 0x0a, 0x0a, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x53, 0x74, 0x61, 0x74, 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, 0x12, 0x0a, 0x04, 0x72, 0x63, 0x75, 0x73, @@ -813,90 +804,88 @@ var file_greptime_v1_meta_heartbeat_proto_rawDesc = []byte{ 0x77, 0x63, 0x75, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, 0x52, 0x04, 0x77, 0x63, 0x75, 0x73, 0x12, 0x2b, 0x0a, 0x11, 0x61, 0x70, 0x70, 0x72, 0x6f, 0x78, 0x69, 0x6d, 0x61, 0x74, 0x65, 0x5f, 0x62, 0x79, 0x74, 0x65, 0x73, 0x18, 0x04, 0x20, 0x01, 0x28, 0x03, 0x52, 0x10, 0x61, 0x70, 0x70, - 0x72, 0x6f, 0x78, 0x69, 0x6d, 0x61, 0x74, 0x65, 0x42, 0x79, 0x74, 0x65, 0x73, 0x12, 0x29, 0x0a, - 0x10, 0x61, 0x70, 0x70, 0x72, 0x6f, 0x78, 0x69, 0x6d, 0x61, 0x74, 0x65, 0x5f, 0x72, 0x6f, 0x77, - 0x73, 0x18, 0x05, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0f, 0x61, 0x70, 0x70, 0x72, 0x6f, 0x78, 0x69, - 0x6d, 0x61, 0x74, 0x65, 0x52, 0x6f, 0x77, 0x73, 0x12, 0x16, 0x0a, 0x06, 0x65, 0x6e, 0x67, 0x69, - 0x6e, 0x65, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x65, 0x6e, 0x67, 0x69, 0x6e, 0x65, - 0x12, 0x30, 0x0a, 0x04, 0x72, 0x6f, 0x6c, 0x65, 0x18, 0x07, 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, 0xda, 0x01, 0x0a, 0x11, 0x48, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, - 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, 0x49, 0x0a, 0x0f, 0x6d, 0x61, 0x69, 0x6c, 0x62, 0x6f, 0x78, 0x5f, 0x6d, 0x65, - 0x73, 0x73, 0x61, 0x67, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x67, 0x72, - 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x4d, - 0x61, 0x69, 0x6c, 0x62, 0x6f, 0x78, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x52, 0x0e, 0x6d, - 0x61, 0x69, 0x6c, 0x62, 0x6f, 0x78, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x40, 0x0a, - 0x0c, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x5f, 0x6c, 0x65, 0x61, 0x73, 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, - 0x5e, 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, 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, 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, + 0x72, 0x6f, 0x78, 0x69, 0x6d, 0x61, 0x74, 0x65, 0x42, 0x79, 0x74, 0x65, 0x73, 0x12, 0x16, 0x0a, + 0x06, 0x65, 0x6e, 0x67, 0x69, 0x6e, 0x65, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x65, + 0x6e, 0x67, 0x69, 0x6e, 0x65, 0x12, 0x30, 0x0a, 0x04, 0x72, 0x6f, 0x6c, 0x65, 0x18, 0x07, 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, 0xda, 0x01, 0x0a, 0x11, 0x48, 0x65, 0x61, 0x72, + 0x74, 0x62, 0x65, 0x61, 0x74, 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, 0x49, 0x0a, 0x0f, 0x6d, 0x61, 0x69, 0x6c, 0x62, + 0x6f, 0x78, 0x5f, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, + 0x32, 0x20, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, + 0x65, 0x74, 0x61, 0x2e, 0x4d, 0x61, 0x69, 0x6c, 0x62, 0x6f, 0x78, 0x4d, 0x65, 0x73, 0x73, 0x61, + 0x67, 0x65, 0x52, 0x0e, 0x6d, 0x61, 0x69, 0x6c, 0x62, 0x6f, 0x78, 0x4d, 0x65, 0x73, 0x73, 0x61, + 0x67, 0x65, 0x12, 0x40, 0x0a, 0x0c, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x5f, 0x6c, 0x65, 0x61, + 0x73, 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, 0x5e, 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, 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, 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/Common.java b/java/src/main/java/greptime/v1/meta/Common.java index 1d4d424d..be49f22e 100644 --- a/java/src/main/java/greptime/v1/meta/Common.java +++ b/java/src/main/java/greptime/v1/meta/Common.java @@ -27,6 +27,10 @@ public enum Role * FRONTEND = 1; */ FRONTEND(1), + /** + * FLOWNODE = 2; + */ + FLOWNODE(2), UNRECOGNIZED(-1), ; @@ -38,6 +42,10 @@ public enum Role * FRONTEND = 1; */ public static final int FRONTEND_VALUE = 1; + /** + * FLOWNODE = 2; + */ + public static final int FLOWNODE_VALUE = 2; public final int getNumber() { @@ -66,6 +74,7 @@ public static Role forNumber(int value) { switch (value) { case 0: return DATANODE; case 1: return FRONTEND; + case 2: return FLOWNODE; default: return null; } } @@ -5149,10 +5158,10 @@ public greptime.v1.meta.Common.ProcedureId getDefaultInstanceForType() { "\t\"L\n\014TimeInterval\022\036\n\026start_timestamp_mil" + "lis\030\001 \001(\003\022\034\n\024end_timestamp_millis\030\002 \001(\003\"" + "&\n\010KeyValue\022\013\n\003key\030\001 \001(\014\022\r\n\005value\030\002 \001(\014\"" + - "\032\n\013ProcedureId\022\013\n\003key\030\001 \001(\014*\"\n\004Role\022\014\n\010D" + - "ATANODE\020\000\022\014\n\010FRONTEND\020\001B - * Approximate number of rows in this region - * - * - * int64 approximate_rows = 5; - * @return The approximateRows. - */ - long getApproximateRows(); - /** * 
      * Engine name
@@ -3461,11 +3451,6 @@ private RegionStat(
               approximateBytes_ = input.readInt64();
               break;
             }
-            case 40: {
-
-              approximateRows_ = input.readInt64();
-              break;
-            }
             case 50: {
               java.lang.String s = input.readStringRequireUtf8();
 
@@ -3568,21 +3553,6 @@ public long getApproximateBytes() {
       return approximateBytes_;
     }
 
-    public static final int APPROXIMATE_ROWS_FIELD_NUMBER = 5;
-    private long approximateRows_;
-    /**
-     * 
-     * Approximate number of rows in this region
-     * 

-     *
-     * int64 approximate_rows = 5;
-     * @return The approximateRows.
-     */
-    @java.lang.Override
-    public long getApproximateRows() {
-      return approximateRows_;
-    }
-
     public static final int ENGINE_FIELD_NUMBER = 6;
     private volatile java.lang.Object engine_;
     /**
@@ -3682,9 +3652,6 @@ public void writeTo(com.google.protobuf.CodedOutputStream output)
       if (approximateBytes_ != 0L) {
         output.writeInt64(4, approximateBytes_);
       }
-      if (approximateRows_ != 0L) {
-        output.writeInt64(5, approximateRows_);
-      }
       if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(engine_)) {
         com.google.protobuf.GeneratedMessageV3.writeString(output, 6, engine_);
       }
@@ -3716,10 +3683,6 @@ public int getSerializedSize() {
         size += com.google.protobuf.CodedOutputStream
           .computeInt64Size(4, approximateBytes_);
       }
-      if (approximateRows_ != 0L) {
-        size += com.google.protobuf.CodedOutputStream
-          .computeInt64Size(5, approximateRows_);
-      }
       if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(engine_)) {
         size += com.google.protobuf.GeneratedMessageV3.computeStringSize(6, engine_);
       }
@@ -3750,8 +3713,6 @@ public boolean equals(final java.lang.Object obj) {
           != other.getWcus()) return false;
       if (getApproximateBytes()
           != other.getApproximateBytes()) return false;
-      if (getApproximateRows()
-          != other.getApproximateRows()) return false;
       if (!getEngine()
           .equals(other.getEngine())) return false;
       if (role_ != other.role_) return false;
@@ -3778,9 +3739,6 @@ public int hashCode() {
       hash = (37 * hash) + APPROXIMATE_BYTES_FIELD_NUMBER;
       hash = (53 * hash) + com.google.protobuf.Internal.hashLong(
           getApproximateBytes());
-      hash = (37 * hash) + APPROXIMATE_ROWS_FIELD_NUMBER;
-      hash = (53 * hash) + com.google.protobuf.Internal.hashLong(
-          getApproximateRows());
       hash = (37 * hash) + ENGINE_FIELD_NUMBER;
       hash = (53 * hash) + getEngine().hashCode();
       hash = (37 * hash) + ROLE_FIELD_NUMBER;
@@ -3926,8 +3884,6 @@ public Builder clear() {
 
         approximateBytes_ = 0L;
 
-        approximateRows_ = 0L;
-
         engine_ = "";
 
         role_ = 0;
@@ -3962,7 +3918,6 @@ public greptime.v1.meta.HeartbeatOuterClass.RegionStat buildPartial() {
         result.rcus_ = rcus_;
         result.wcus_ = wcus_;
         result.approximateBytes_ = approximateBytes_;
-        result.approximateRows_ = approximateRows_;
         result.engine_ = engine_;
         result.role_ = role_;
         onBuilt();
@@ -4025,9 +3980,6 @@ public Builder mergeFrom(greptime.v1.meta.HeartbeatOuterClass.RegionStat other)
         if (other.getApproximateBytes() != 0L) {
           setApproximateBytes(other.getApproximateBytes());
         }
-        if (other.getApproximateRows() != 0L) {
-          setApproximateRows(other.getApproximateRows());
-        }
         if (!other.getEngine().isEmpty()) {
           engine_ = other.engine_;
           onChanged();
@@ -4224,49 +4176,6 @@ public Builder clearApproximateBytes() {
         return this;
       }
 
-      private long approximateRows_ ;
-      /**
-       * 
-       * Approximate number of rows in this region
-       * 

-       *
-       * int64 approximate_rows = 5;
-       * @return The approximateRows.
-       */
-      @java.lang.Override
-      public long getApproximateRows() {
-        return approximateRows_;
-      }
-      /**
-       * 
-       * Approximate number of rows in this region
-       * 

-       *
-       * int64 approximate_rows = 5;
-       * @param value The approximateRows to set.
-       * @return This builder for chaining.
-       */
-      public Builder setApproximateRows(long value) {
-        
-        approximateRows_ = value;
-        onChanged();
-        return this;
-      }
-      /**
-       * 
-       * Approximate number of rows in this region
-       * 

-       *
-       * int64 approximate_rows = 5;
-       * @return This builder for chaining.
-       */
-      public Builder clearApproximateRows() {
-        
-        approximateRows_ = 0L;
-        onChanged();
-        return this;
-      }
-
       private java.lang.Object engine_ = "";
       /**
        * 
@@ -10128,37 +10037,36 @@ public greptime.v1.meta.HeartbeatOuterClass.MailboxMessage getDefaultInstanceFor
       "och\030\007 \001(\004\022(\n\004info\030\010 \001(\0132\032.greptime.v1.me" +
       "ta.NodeInfo\"F\n\010NodeInfo\022\017\n\007version\030\001 \001(\t" +
       "\022\022\n\ngit_commit\030\002 \001(\t\022\025\n\rstart_time_ms\030\003 " +
-      "\001(\004\"\254\001\n\nRegionStat\022\021\n\tregion_id\030\001 \001(\004\022\014\n" +
+      "\001(\004\"\222\001\n\nRegionStat\022\021\n\tregion_id\030\001 \001(\004\022\014\n" +
       "\004rcus\030\002 \001(\003\022\014\n\004wcus\030\003 \001(\003\022\031\n\021approximate" +
-      "_bytes\030\004 \001(\003\022\030\n\020approximate_rows\030\005 \001(\003\022\016" +
-      "\n\006engine\030\006 \001(\t\022*\n\004role\030\007 \001(\0162\034.greptime." +
-      "v1.meta.RegionRole\"\265\001\n\021HeartbeatResponse" +
-      "\0220\n\006header\030\001 \001(\0132 .greptime.v1.meta.Resp" +
-      "onseHeader\0229\n\017mailbox_message\030\002 \001(\0132 .gr" +
-      "eptime.v1.meta.MailboxMessage\0223\n\014region_" +
-      "lease\030\003 \001(\0132\035.greptime.v1.meta.RegionLea" +
-      "se\"N\n\rGrantedRegion\022\021\n\tregion_id\030\001 \001(\004\022*" +
-      "\n\004role\030\002 \001(\0162\034.greptime.v1.meta.RegionRo" +
-      "le\"\222\001\n\013RegionLease\0220\n\007regions\030\001 \003(\0132\037.gr" +
-      "eptime.v1.meta.GrantedRegion\022\034\n\024duration" +
-      "_since_epoch\030\002 \001(\004\022\025\n\rlease_seconds\030\003 \001(" +
-      "\004\022\034\n\024closeable_region_ids\030\004 \003(\004\"C\n\020AskLe" +
-      "aderRequest\022/\n\006header\030\001 \001(\0132\037.greptime.v" +
-      "1.meta.RequestHeader\"m\n\021AskLeaderRespons" +
-      "e\0220\n\006header\030\001 \001(\0132 .greptime.v1.meta.Res" +
-      "ponseHeader\022&\n\006leader\030\002 \001(\0132\026.greptime.v" +
-      "1.meta.Peer\"|\n\016MailboxMessage\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_millis\030\005 \001(\003\022\016\n\004json\030\006" +
-      " \001(\tH\000B\t\n\007payload*&\n\nRegionRole\022\n\n\006Leade" +
-      "r\020\000\022\014\n\010Follower\020\0012\277\001\n\tHeartbeat\022Z\n\tHeart" +
-      "beat\022\".greptime.v1.meta.HeartbeatRequest" +
-      "\032#.greptime.v1.meta.HeartbeatResponse\"\000(" +
-      "\0010\001\022V\n\tAskLeader\022\".greptime.v1.meta.AskL" +
-      "eaderRequest\032#.greptime.v1.meta.AskLeade" +
-      "rResponse\"\000B