feat: enhancement information_schema.flows (#221)
* feat:enhancement information_schema.flows * chore: make all --------- Co-authored-by: discord9 <discord9@163.com>
This commit is contained in:
AntiTopQuark
@@ -101,9 +101,21 @@ struct FlowStat_FlowStatSizeEntry_DoNotUseDefaultTypeInternal {
|
||||
};
|
||||
};
|
||||
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 FlowStat_FlowStatSizeEntry_DoNotUseDefaultTypeInternal _FlowStat_FlowStatSizeEntry_DoNotUse_default_instance_;
|
||||
PROTOBUF_CONSTEXPR FlowStat_FlowLastExecTimeMapEntry_DoNotUse::FlowStat_FlowLastExecTimeMapEntry_DoNotUse(
|
||||
::_pbi::ConstantInitialized) {}
|
||||
struct FlowStat_FlowLastExecTimeMapEntry_DoNotUseDefaultTypeInternal {
|
||||
PROTOBUF_CONSTEXPR FlowStat_FlowLastExecTimeMapEntry_DoNotUseDefaultTypeInternal()
|
||||
: _instance(::_pbi::ConstantInitialized{}) {}
|
||||
~FlowStat_FlowLastExecTimeMapEntry_DoNotUseDefaultTypeInternal() {}
|
||||
union {
|
||||
FlowStat_FlowLastExecTimeMapEntry_DoNotUse _instance;
|
||||
};
|
||||
};
|
||||
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 FlowStat_FlowLastExecTimeMapEntry_DoNotUseDefaultTypeInternal _FlowStat_FlowLastExecTimeMapEntry_DoNotUse_default_instance_;
|
||||
PROTOBUF_CONSTEXPR FlowStat::FlowStat(
|
||||
::_pbi::ConstantInitialized): _impl_{
|
||||
/*decltype(_impl_.flow_stat_size_)*/{::_pbi::ConstantInitialized()}
|
||||
, /*decltype(_impl_.flow_last_exec_time_map_)*/{::_pbi::ConstantInitialized()}
|
||||
, /*decltype(_impl_._cached_size_)*/{}} {}
|
||||
struct FlowStatDefaultTypeInternal {
|
||||
PROTOBUF_CONSTEXPR FlowStatDefaultTypeInternal()
|
||||
@@ -209,7 +221,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[12];
|
||||
static ::_pb::Metadata file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[13];
|
||||
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;
|
||||
|
||||
@@ -272,6 +284,16 @@ const uint32_t TableStruct_greptime_2fv1_2fmeta_2fheartbeat_2eproto::offsets[] P
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::FlowStat_FlowStatSizeEntry_DoNotUse, value_),
|
||||
0,
|
||||
1,
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::FlowStat_FlowLastExecTimeMapEntry_DoNotUse, _has_bits_),
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::FlowStat_FlowLastExecTimeMapEntry_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::FlowStat_FlowLastExecTimeMapEntry_DoNotUse, key_),
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::FlowStat_FlowLastExecTimeMapEntry_DoNotUse, value_),
|
||||
0,
|
||||
1,
|
||||
~0u, // no _has_bits_
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::FlowStat, _internal_metadata_),
|
||||
~0u, // no _extensions_
|
||||
@@ -279,6 +301,7 @@ const uint32_t TableStruct_greptime_2fv1_2fmeta_2fheartbeat_2eproto::offsets[] P
|
||||
~0u, // no _weak_field_map_
|
||||
~0u, // no _inlined_string_donated_
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::FlowStat, _impl_.flow_stat_size_),
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::FlowStat, _impl_.flow_last_exec_time_map_),
|
||||
~0u, // no _has_bits_
|
||||
PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::HeartbeatResponse, _internal_metadata_),
|
||||
~0u, // no _extensions_
|
||||
@@ -341,13 +364,14 @@ static const ::_pbi::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protode
|
||||
{ 25, 33, -1, sizeof(::greptime::v1::meta::RegionStat_ExtensionsEntry_DoNotUse)},
|
||||
{ 35, -1, -1, sizeof(::greptime::v1::meta::RegionStat)},
|
||||
{ 48, 56, -1, sizeof(::greptime::v1::meta::FlowStat_FlowStatSizeEntry_DoNotUse)},
|
||||
{ 58, -1, -1, sizeof(::greptime::v1::meta::FlowStat)},
|
||||
{ 65, -1, -1, sizeof(::greptime::v1::meta::HeartbeatResponse)},
|
||||
{ 74, -1, -1, sizeof(::greptime::v1::meta::GrantedRegion)},
|
||||
{ 82, -1, -1, sizeof(::greptime::v1::meta::RegionLease)},
|
||||
{ 92, -1, -1, sizeof(::greptime::v1::meta::AskLeaderRequest)},
|
||||
{ 99, -1, -1, sizeof(::greptime::v1::meta::AskLeaderResponse)},
|
||||
{ 107, -1, -1, sizeof(::greptime::v1::meta::MailboxMessage)},
|
||||
{ 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)},
|
||||
{ 93, -1, -1, sizeof(::greptime::v1::meta::RegionLease)},
|
||||
{ 103, -1, -1, sizeof(::greptime::v1::meta::AskLeaderRequest)},
|
||||
{ 110, -1, -1, sizeof(::greptime::v1::meta::AskLeaderResponse)},
|
||||
{ 118, -1, -1, sizeof(::greptime::v1::meta::MailboxMessage)},
|
||||
};
|
||||
|
||||
static const ::_pb::Message* const file_default_instances[] = {
|
||||
@@ -356,6 +380,7 @@ static const ::_pb::Message* const file_default_instances[] = {
|
||||
&::greptime::v1::meta::_RegionStat_ExtensionsEntry_DoNotUse_default_instance_._instance,
|
||||
&::greptime::v1::meta::_RegionStat_default_instance_._instance,
|
||||
&::greptime::v1::meta::_FlowStat_FlowStatSizeEntry_DoNotUse_default_instance_._instance,
|
||||
&::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_default_instance_._instance,
|
||||
@@ -387,45 +412,49 @@ const char descriptor_table_protodef_greptime_2fv1_2fmeta_2fheartbeat_2eproto[]
|
||||
"ta.RegionRole\022@\n\nextensions\030c \003(\0132,.grep"
|
||||
"time.v1.meta.RegionStat.ExtensionsEntry\032"
|
||||
"1\n\017ExtensionsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value"
|
||||
"\030\002 \001(\014:\0028\001\"\205\001\n\010FlowStat\022D\n\016flow_stat_siz"
|
||||
"\030\002 \001(\014:\0028\001\"\227\002\n\010FlowStat\022D\n\016flow_stat_siz"
|
||||
"e\030\001 \003(\0132,.greptime.v1.meta.FlowStat.Flow"
|
||||
"StatSizeEntry\0323\n\021FlowStatSizeEntry\022\013\n\003ke"
|
||||
"y\030\001 \001(\r\022\r\n\005value\030\002 \001(\004:\0028\001\"\265\001\n\021Heartbeat"
|
||||
"Response\0220\n\006header\030\001 \001(\0132 .greptime.v1.m"
|
||||
"eta.ResponseHeader\0229\n\017mailbox_message\030\002 "
|
||||
"\001(\0132 .greptime.v1.meta.MailboxMessage\0223\n"
|
||||
"\014region_lease\030\003 \001(\0132\035.greptime.v1.meta.R"
|
||||
"egionLease\"N\n\rGrantedRegion\022\021\n\tregion_id"
|
||||
"\030\001 \001(\004\022*\n\004role\030\002 \001(\0162\034.greptime.v1.meta."
|
||||
"RegionRole\"\222\001\n\013RegionLease\0220\n\007regions\030\001 "
|
||||
"\003(\0132\037.greptime.v1.meta.GrantedRegion\022\034\n\024"
|
||||
"duration_since_epoch\030\002 \001(\004\022\025\n\rlease_seco"
|
||||
"nds\030\003 \001(\004\022\034\n\024closeable_region_ids\030\004 \003(\004\""
|
||||
"C\n\020AskLeaderRequest\022/\n\006header\030\001 \001(\0132\037.gr"
|
||||
"eptime.v1.meta.RequestHeader\"m\n\021AskLeade"
|
||||
"rResponse\0220\n\006header\030\001 \001(\0132 .greptime.v1."
|
||||
"meta.ResponseHeader\022&\n\006leader\030\002 \001(\0132\026.gr"
|
||||
"eptime.v1.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\006Leader\020\000\022\014\n\010Follower\020\001\022\025\n\021Downgrading"
|
||||
"Leader\020\0022\277\001\n\tHeartbeat\022Z\n\tHeartbeat\022\".gr"
|
||||
"eptime.v1.meta.HeartbeatRequest\032#.grepti"
|
||||
"me.v1.meta.HeartbeatResponse\"\000(\0010\001\022V\n\tAs"
|
||||
"kLeader\022\".greptime.v1.meta.AskLeaderRequ"
|
||||
"est\032#.greptime.v1.meta.AskLeaderResponse"
|
||||
"\"\000B<Z:github.com/GreptimeTeam/greptime-p"
|
||||
"roto/go/greptime/v1/metab\006proto3"
|
||||
"StatSizeEntry\022T\n\027flow_last_exec_time_map"
|
||||
"\030\002 \003(\01323.greptime.v1.meta.FlowStat.FlowL"
|
||||
"astExecTimeMapEntry\0323\n\021FlowStatSizeEntry"
|
||||
"\022\013\n\003key\030\001 \001(\r\022\r\n\005value\030\002 \001(\004:\0028\001\032:\n\030Flow"
|
||||
"LastExecTimeMapEntry\022\013\n\003key\030\001 \001(\r\022\r\n\005val"
|
||||
"ue\030\002 \001(\003:\0028\001\"\265\001\n\021HeartbeatResponse\0220\n\006he"
|
||||
"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\"N\n\r"
|
||||
"GrantedRegion\022\021\n\tregion_id\030\001 \001(\004\022*\n\004role"
|
||||
"\030\002 \001(\0162\034.greptime.v1.meta.RegionRole\"\222\001\n"
|
||||
"\013RegionLease\0220\n\007regions\030\001 \003(\0132\037.greptime"
|
||||
".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\024c"
|
||||
"loseable_region_ids\030\004 \003(\004\"C\n\020AskLeaderRe"
|
||||
"quest\022/\n\006header\030\001 \001(\0132\037.greptime.v1.meta"
|
||||
".RequestHeader\"m\n\021AskLeaderResponse\0220\n\006h"
|
||||
"eader\030\001 \001(\0132 .greptime.v1.meta.ResponseH"
|
||||
"eader\022&\n\006leader\030\002 \001(\0132\026.greptime.v1.meta"
|
||||
".Peer\"|\n\016MailboxMessage\022\n\n\002id\030\001 \001(\004\022\017\n\007s"
|
||||
"ubject\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\000"
|
||||
"B\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\tH"
|
||||
"eartbeat\022Z\n\tHeartbeat\022\".greptime.v1.meta"
|
||||
".HeartbeatRequest\032#.greptime.v1.meta.Hea"
|
||||
"rtbeatResponse\"\000(\0010\001\022V\n\tAskLeader\022\".grep"
|
||||
"time.v1.meta.AskLeaderRequest\032#.greptime"
|
||||
".v1.meta.AskLeaderResponse\"\000B<Z:github.c"
|
||||
"om/GreptimeTeam/greptime-proto/go/grepti"
|
||||
"me/v1/metab\006proto3"
|
||||
;
|
||||
static const ::_pbi::DescriptorTable* const descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_deps[1] = {
|
||||
&::descriptor_table_greptime_2fv1_2fmeta_2fcommon_2eproto,
|
||||
};
|
||||
static ::_pbi::once_flag descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_once;
|
||||
const ::_pbi::DescriptorTable descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto = {
|
||||
false, false, 2032, descriptor_table_protodef_greptime_2fv1_2fmeta_2fheartbeat_2eproto,
|
||||
false, false, 2178, descriptor_table_protodef_greptime_2fv1_2fmeta_2fheartbeat_2eproto,
|
||||
"greptime/v1/meta/heartbeat.proto",
|
||||
&descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_once, descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_deps, 1, 12,
|
||||
&descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_once, descriptor_table_greptime_2fv1_2fmeta_2fheartbeat_2eproto_deps, 1, 13,
|
||||
schemas, file_default_instances, TableStruct_greptime_2fv1_2fmeta_2fheartbeat_2eproto::offsets,
|
||||
file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto, file_level_enum_descriptors_greptime_2fv1_2fmeta_2fheartbeat_2eproto,
|
||||
file_level_service_descriptors_greptime_2fv1_2fmeta_2fheartbeat_2eproto,
|
||||
@@ -1709,6 +1738,20 @@ void FlowStat_FlowStatSizeEntry_DoNotUse::MergeFrom(const FlowStat_FlowStatSizeE
|
||||
|
||||
// ===================================================================
|
||||
|
||||
FlowStat_FlowLastExecTimeMapEntry_DoNotUse::FlowStat_FlowLastExecTimeMapEntry_DoNotUse() {}
|
||||
FlowStat_FlowLastExecTimeMapEntry_DoNotUse::FlowStat_FlowLastExecTimeMapEntry_DoNotUse(::PROTOBUF_NAMESPACE_ID::Arena* arena)
|
||||
: SuperType(arena) {}
|
||||
void FlowStat_FlowLastExecTimeMapEntry_DoNotUse::MergeFrom(const FlowStat_FlowLastExecTimeMapEntry_DoNotUse& other) {
|
||||
MergeFromInternal(other);
|
||||
}
|
||||
::PROTOBUF_NAMESPACE_ID::Metadata FlowStat_FlowLastExecTimeMapEntry_DoNotUse::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[5]);
|
||||
}
|
||||
|
||||
// ===================================================================
|
||||
|
||||
class FlowStat::_Internal {
|
||||
public:
|
||||
};
|
||||
@@ -1727,10 +1770,12 @@ FlowStat::FlowStat(const FlowStat& from)
|
||||
FlowStat* const _this = this; (void)_this;
|
||||
new (&_impl_) Impl_{
|
||||
/*decltype(_impl_.flow_stat_size_)*/{}
|
||||
, /*decltype(_impl_.flow_last_exec_time_map_)*/{}
|
||||
, /*decltype(_impl_._cached_size_)*/{}};
|
||||
|
||||
_internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
|
||||
_this->_impl_.flow_stat_size_.MergeFrom(from._impl_.flow_stat_size_);
|
||||
_this->_impl_.flow_last_exec_time_map_.MergeFrom(from._impl_.flow_last_exec_time_map_);
|
||||
// @@protoc_insertion_point(copy_constructor:greptime.v1.meta.FlowStat)
|
||||
}
|
||||
|
||||
@@ -1740,6 +1785,7 @@ inline void FlowStat::SharedCtor(
|
||||
(void)is_message_owned;
|
||||
new (&_impl_) Impl_{
|
||||
/*decltype(_impl_.flow_stat_size_)*/{::_pbi::ArenaInitialized(), arena}
|
||||
, /*decltype(_impl_.flow_last_exec_time_map_)*/{::_pbi::ArenaInitialized(), arena}
|
||||
, /*decltype(_impl_._cached_size_)*/{}
|
||||
};
|
||||
}
|
||||
@@ -1758,11 +1804,14 @@ inline void FlowStat::SharedDtor() {
|
||||
GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
|
||||
_impl_.flow_stat_size_.Destruct();
|
||||
_impl_.flow_stat_size_.~MapField();
|
||||
_impl_.flow_last_exec_time_map_.Destruct();
|
||||
_impl_.flow_last_exec_time_map_.~MapField();
|
||||
}
|
||||
|
||||
void FlowStat::ArenaDtor(void* object) {
|
||||
FlowStat* _this = reinterpret_cast< FlowStat* >(object);
|
||||
_this->_impl_.flow_stat_size_.Destruct();
|
||||
_this->_impl_.flow_last_exec_time_map_.Destruct();
|
||||
}
|
||||
void FlowStat::SetCachedSize(int size) const {
|
||||
_impl_._cached_size_.Set(size);
|
||||
@@ -1775,6 +1824,7 @@ void FlowStat::Clear() {
|
||||
(void) cached_has_bits;
|
||||
|
||||
_impl_.flow_stat_size_.Clear();
|
||||
_impl_.flow_last_exec_time_map_.Clear();
|
||||
_internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
|
||||
}
|
||||
|
||||
@@ -1797,6 +1847,19 @@ const char* FlowStat::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx)
|
||||
} else
|
||||
goto handle_unusual;
|
||||
continue;
|
||||
// map<uint32, int64> flow_last_exec_time_map = 2;
|
||||
case 2:
|
||||
if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 18)) {
|
||||
ptr -= 1;
|
||||
do {
|
||||
ptr += 1;
|
||||
ptr = ctx->ParseMessage(&_impl_.flow_last_exec_time_map_, ptr);
|
||||
CHK_(ptr);
|
||||
if (!ctx->DataAvailable(ptr)) break;
|
||||
} while (::PROTOBUF_NAMESPACE_ID::internal::ExpectTag<18>(ptr));
|
||||
} else
|
||||
goto handle_unusual;
|
||||
continue;
|
||||
default:
|
||||
goto handle_unusual;
|
||||
} // switch
|
||||
@@ -1843,6 +1906,23 @@ uint8_t* FlowStat::_InternalSerialize(
|
||||
}
|
||||
}
|
||||
|
||||
// map<uint32, int64> flow_last_exec_time_map = 2;
|
||||
if (!this->_internal_flow_last_exec_time_map().empty()) {
|
||||
using MapType = ::_pb::Map<uint32_t, int64_t>;
|
||||
using WireHelper = FlowStat_FlowLastExecTimeMapEntry_DoNotUse::Funcs;
|
||||
const auto& map_field = this->_internal_flow_last_exec_time_map();
|
||||
|
||||
if (stream->IsSerializationDeterministic() && map_field.size() > 1) {
|
||||
for (const auto& entry : ::_pbi::MapSorterFlat<MapType>(map_field)) {
|
||||
target = WireHelper::InternalSerialize(2, entry.first, entry.second, target, stream);
|
||||
}
|
||||
} else {
|
||||
for (const auto& entry : map_field) {
|
||||
target = WireHelper::InternalSerialize(2, entry.first, entry.second, target, stream);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
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);
|
||||
@@ -1868,6 +1948,15 @@ size_t FlowStat::ByteSizeLong() const {
|
||||
total_size += FlowStat_FlowStatSizeEntry_DoNotUse::Funcs::ByteSizeLong(it->first, it->second);
|
||||
}
|
||||
|
||||
// map<uint32, int64> flow_last_exec_time_map = 2;
|
||||
total_size += 1 *
|
||||
::PROTOBUF_NAMESPACE_ID::internal::FromIntSize(this->_internal_flow_last_exec_time_map_size());
|
||||
for (::PROTOBUF_NAMESPACE_ID::Map< uint32_t, int64_t >::const_iterator
|
||||
it = this->_internal_flow_last_exec_time_map().begin();
|
||||
it != this->_internal_flow_last_exec_time_map().end(); ++it) {
|
||||
total_size += FlowStat_FlowLastExecTimeMapEntry_DoNotUse::Funcs::ByteSizeLong(it->first, it->second);
|
||||
}
|
||||
|
||||
return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_);
|
||||
}
|
||||
|
||||
@@ -1887,6 +1976,7 @@ void FlowStat::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTO
|
||||
(void) cached_has_bits;
|
||||
|
||||
_this->_impl_.flow_stat_size_.MergeFrom(from._impl_.flow_stat_size_);
|
||||
_this->_impl_.flow_last_exec_time_map_.MergeFrom(from._impl_.flow_last_exec_time_map_);
|
||||
_this->_internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
|
||||
}
|
||||
|
||||
@@ -1905,12 +1995,13 @@ void FlowStat::InternalSwap(FlowStat* other) {
|
||||
using std::swap;
|
||||
_internal_metadata_.InternalSwap(&other->_internal_metadata_);
|
||||
_impl_.flow_stat_size_.InternalSwap(&other->_impl_.flow_stat_size_);
|
||||
_impl_.flow_last_exec_time_map_.InternalSwap(&other->_impl_.flow_last_exec_time_map_);
|
||||
}
|
||||
|
||||
::PROTOBUF_NAMESPACE_ID::Metadata FlowStat::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[5]);
|
||||
file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[6]);
|
||||
}
|
||||
|
||||
// ===================================================================
|
||||
@@ -2196,7 +2287,7 @@ void HeartbeatResponse::InternalSwap(HeartbeatResponse* other) {
|
||||
::PROTOBUF_NAMESPACE_ID::Metadata HeartbeatResponse::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[6]);
|
||||
file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[7]);
|
||||
}
|
||||
|
||||
// ===================================================================
|
||||
@@ -2410,7 +2501,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[7]);
|
||||
file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[8]);
|
||||
}
|
||||
|
||||
// ===================================================================
|
||||
@@ -2697,7 +2788,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[8]);
|
||||
file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[9]);
|
||||
}
|
||||
|
||||
// ===================================================================
|
||||
@@ -2896,7 +2987,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[9]);
|
||||
file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[10]);
|
||||
}
|
||||
|
||||
// ===================================================================
|
||||
@@ -3147,7 +3238,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[10]);
|
||||
file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[11]);
|
||||
}
|
||||
|
||||
// ===================================================================
|
||||
@@ -3587,7 +3678,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[11]);
|
||||
file_level_metadata_greptime_2fv1_2fmeta_2fheartbeat_2eproto[12]);
|
||||
}
|
||||
|
||||
// @@protoc_insertion_point(namespace_scope)
|
||||
@@ -3615,6 +3706,10 @@ template<> PROTOBUF_NOINLINE ::greptime::v1::meta::FlowStat_FlowStatSizeEntry_Do
|
||||
Arena::CreateMaybeMessage< ::greptime::v1::meta::FlowStat_FlowStatSizeEntry_DoNotUse >(Arena* arena) {
|
||||
return Arena::CreateMessageInternal< ::greptime::v1::meta::FlowStat_FlowStatSizeEntry_DoNotUse >(arena);
|
||||
}
|
||||
template<> PROTOBUF_NOINLINE ::greptime::v1::meta::FlowStat_FlowLastExecTimeMapEntry_DoNotUse*
|
||||
Arena::CreateMaybeMessage< ::greptime::v1::meta::FlowStat_FlowLastExecTimeMapEntry_DoNotUse >(Arena* arena) {
|
||||
return Arena::CreateMessageInternal< ::greptime::v1::meta::FlowStat_FlowLastExecTimeMapEntry_DoNotUse >(arena);
|
||||
}
|
||||
template<> PROTOBUF_NOINLINE ::greptime::v1::meta::FlowStat*
|
||||
Arena::CreateMaybeMessage< ::greptime::v1::meta::FlowStat >(Arena* arena) {
|
||||
return Arena::CreateMessageInternal< ::greptime::v1::meta::FlowStat >(arena);
|
||||
|
||||
@@ -61,6 +61,9 @@ extern AskLeaderResponseDefaultTypeInternal _AskLeaderResponse_default_instance_
|
||||
class FlowStat;
|
||||
struct FlowStatDefaultTypeInternal;
|
||||
extern FlowStatDefaultTypeInternal _FlowStat_default_instance_;
|
||||
class FlowStat_FlowLastExecTimeMapEntry_DoNotUse;
|
||||
struct FlowStat_FlowLastExecTimeMapEntry_DoNotUseDefaultTypeInternal;
|
||||
extern FlowStat_FlowLastExecTimeMapEntry_DoNotUseDefaultTypeInternal _FlowStat_FlowLastExecTimeMapEntry_DoNotUse_default_instance_;
|
||||
class FlowStat_FlowStatSizeEntry_DoNotUse;
|
||||
struct FlowStat_FlowStatSizeEntry_DoNotUseDefaultTypeInternal;
|
||||
extern FlowStat_FlowStatSizeEntry_DoNotUseDefaultTypeInternal _FlowStat_FlowStatSizeEntry_DoNotUse_default_instance_;
|
||||
@@ -95,6 +98,7 @@ PROTOBUF_NAMESPACE_OPEN
|
||||
template<> ::greptime::v1::meta::AskLeaderRequest* Arena::CreateMaybeMessage<::greptime::v1::meta::AskLeaderRequest>(Arena*);
|
||||
template<> ::greptime::v1::meta::AskLeaderResponse* Arena::CreateMaybeMessage<::greptime::v1::meta::AskLeaderResponse>(Arena*);
|
||||
template<> ::greptime::v1::meta::FlowStat* Arena::CreateMaybeMessage<::greptime::v1::meta::FlowStat>(Arena*);
|
||||
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::HeartbeatRequest* Arena::CreateMaybeMessage<::greptime::v1::meta::HeartbeatRequest>(Arena*);
|
||||
@@ -911,6 +915,30 @@ public:
|
||||
|
||||
// -------------------------------------------------------------------
|
||||
|
||||
class FlowStat_FlowLastExecTimeMapEntry_DoNotUse : public ::PROTOBUF_NAMESPACE_ID::internal::MapEntry<FlowStat_FlowLastExecTimeMapEntry_DoNotUse,
|
||||
uint32_t, int64_t,
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_UINT32,
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_INT64> {
|
||||
public:
|
||||
typedef ::PROTOBUF_NAMESPACE_ID::internal::MapEntry<FlowStat_FlowLastExecTimeMapEntry_DoNotUse,
|
||||
uint32_t, int64_t,
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_UINT32,
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_INT64> SuperType;
|
||||
FlowStat_FlowLastExecTimeMapEntry_DoNotUse();
|
||||
explicit PROTOBUF_CONSTEXPR FlowStat_FlowLastExecTimeMapEntry_DoNotUse(
|
||||
::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
|
||||
explicit FlowStat_FlowLastExecTimeMapEntry_DoNotUse(::PROTOBUF_NAMESPACE_ID::Arena* arena);
|
||||
void MergeFrom(const FlowStat_FlowLastExecTimeMapEntry_DoNotUse& other);
|
||||
static const FlowStat_FlowLastExecTimeMapEntry_DoNotUse* internal_default_instance() { return reinterpret_cast<const FlowStat_FlowLastExecTimeMapEntry_DoNotUse*>(&_FlowStat_FlowLastExecTimeMapEntry_DoNotUse_default_instance_); }
|
||||
static bool ValidateKey(void*) { return true; }
|
||||
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 FlowStat final :
|
||||
public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:greptime.v1.meta.FlowStat) */ {
|
||||
public:
|
||||
@@ -959,7 +987,7 @@ class FlowStat final :
|
||||
&_FlowStat_default_instance_);
|
||||
}
|
||||
static constexpr int kIndexInFileMessages =
|
||||
5;
|
||||
6;
|
||||
|
||||
friend void swap(FlowStat& a, FlowStat& b) {
|
||||
a.Swap(&b);
|
||||
@@ -1036,6 +1064,7 @@ class FlowStat final :
|
||||
|
||||
enum : int {
|
||||
kFlowStatSizeFieldNumber = 1,
|
||||
kFlowLastExecTimeMapFieldNumber = 2,
|
||||
};
|
||||
// map<uint32, uint64> flow_stat_size = 1;
|
||||
int flow_stat_size_size() const;
|
||||
@@ -1054,6 +1083,23 @@ class FlowStat final :
|
||||
::PROTOBUF_NAMESPACE_ID::Map< uint32_t, uint64_t >*
|
||||
mutable_flow_stat_size();
|
||||
|
||||
// map<uint32, int64> flow_last_exec_time_map = 2;
|
||||
int flow_last_exec_time_map_size() const;
|
||||
private:
|
||||
int _internal_flow_last_exec_time_map_size() const;
|
||||
public:
|
||||
void clear_flow_last_exec_time_map();
|
||||
private:
|
||||
const ::PROTOBUF_NAMESPACE_ID::Map< uint32_t, int64_t >&
|
||||
_internal_flow_last_exec_time_map() const;
|
||||
::PROTOBUF_NAMESPACE_ID::Map< uint32_t, int64_t >*
|
||||
_internal_mutable_flow_last_exec_time_map();
|
||||
public:
|
||||
const ::PROTOBUF_NAMESPACE_ID::Map< uint32_t, int64_t >&
|
||||
flow_last_exec_time_map() const;
|
||||
::PROTOBUF_NAMESPACE_ID::Map< uint32_t, int64_t >*
|
||||
mutable_flow_last_exec_time_map();
|
||||
|
||||
// @@protoc_insertion_point(class_scope:greptime.v1.meta.FlowStat)
|
||||
private:
|
||||
class _Internal;
|
||||
@@ -1067,6 +1113,11 @@ class FlowStat final :
|
||||
uint32_t, uint64_t,
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_UINT32,
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_UINT64> flow_stat_size_;
|
||||
::PROTOBUF_NAMESPACE_ID::internal::MapField<
|
||||
FlowStat_FlowLastExecTimeMapEntry_DoNotUse,
|
||||
uint32_t, int64_t,
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_UINT32,
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_INT64> flow_last_exec_time_map_;
|
||||
mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
|
||||
};
|
||||
union { Impl_ _impl_; };
|
||||
@@ -1122,7 +1173,7 @@ class HeartbeatResponse final :
|
||||
&_HeartbeatResponse_default_instance_);
|
||||
}
|
||||
static constexpr int kIndexInFileMessages =
|
||||
6;
|
||||
7;
|
||||
|
||||
friend void swap(HeartbeatResponse& a, HeartbeatResponse& b) {
|
||||
a.Swap(&b);
|
||||
@@ -1319,7 +1370,7 @@ class GrantedRegion final :
|
||||
&_GrantedRegion_default_instance_);
|
||||
}
|
||||
static constexpr int kIndexInFileMessages =
|
||||
7;
|
||||
8;
|
||||
|
||||
friend void swap(GrantedRegion& a, GrantedRegion& b) {
|
||||
a.Swap(&b);
|
||||
@@ -1478,7 +1529,7 @@ class RegionLease final :
|
||||
&_RegionLease_default_instance_);
|
||||
}
|
||||
static constexpr int kIndexInFileMessages =
|
||||
8;
|
||||
9;
|
||||
|
||||
friend void swap(RegionLease& a, RegionLease& b) {
|
||||
a.Swap(&b);
|
||||
@@ -1682,7 +1733,7 @@ class AskLeaderRequest final :
|
||||
&_AskLeaderRequest_default_instance_);
|
||||
}
|
||||
static constexpr int kIndexInFileMessages =
|
||||
9;
|
||||
10;
|
||||
|
||||
friend void swap(AskLeaderRequest& a, AskLeaderRequest& b) {
|
||||
a.Swap(&b);
|
||||
@@ -1839,7 +1890,7 @@ class AskLeaderResponse final :
|
||||
&_AskLeaderResponse_default_instance_);
|
||||
}
|
||||
static constexpr int kIndexInFileMessages =
|
||||
10;
|
||||
11;
|
||||
|
||||
friend void swap(AskLeaderResponse& a, AskLeaderResponse& b) {
|
||||
a.Swap(&b);
|
||||
@@ -2021,7 +2072,7 @@ class MailboxMessage final :
|
||||
&_MailboxMessage_default_instance_);
|
||||
}
|
||||
static constexpr int kIndexInFileMessages =
|
||||
11;
|
||||
12;
|
||||
|
||||
friend void swap(MailboxMessage& a, MailboxMessage& b) {
|
||||
a.Swap(&b);
|
||||
@@ -3159,6 +3210,8 @@ RegionStat::mutable_extensions() {
|
||||
|
||||
// -------------------------------------------------------------------
|
||||
|
||||
// -------------------------------------------------------------------
|
||||
|
||||
// FlowStat
|
||||
|
||||
// map<uint32, uint64> flow_stat_size = 1;
|
||||
@@ -3190,6 +3243,35 @@ FlowStat::mutable_flow_stat_size() {
|
||||
return _internal_mutable_flow_stat_size();
|
||||
}
|
||||
|
||||
// map<uint32, int64> flow_last_exec_time_map = 2;
|
||||
inline int FlowStat::_internal_flow_last_exec_time_map_size() const {
|
||||
return _impl_.flow_last_exec_time_map_.size();
|
||||
}
|
||||
inline int FlowStat::flow_last_exec_time_map_size() const {
|
||||
return _internal_flow_last_exec_time_map_size();
|
||||
}
|
||||
inline void FlowStat::clear_flow_last_exec_time_map() {
|
||||
_impl_.flow_last_exec_time_map_.Clear();
|
||||
}
|
||||
inline const ::PROTOBUF_NAMESPACE_ID::Map< uint32_t, int64_t >&
|
||||
FlowStat::_internal_flow_last_exec_time_map() const {
|
||||
return _impl_.flow_last_exec_time_map_.GetMap();
|
||||
}
|
||||
inline const ::PROTOBUF_NAMESPACE_ID::Map< uint32_t, int64_t >&
|
||||
FlowStat::flow_last_exec_time_map() const {
|
||||
// @@protoc_insertion_point(field_map:greptime.v1.meta.FlowStat.flow_last_exec_time_map)
|
||||
return _internal_flow_last_exec_time_map();
|
||||
}
|
||||
inline ::PROTOBUF_NAMESPACE_ID::Map< uint32_t, int64_t >*
|
||||
FlowStat::_internal_mutable_flow_last_exec_time_map() {
|
||||
return _impl_.flow_last_exec_time_map_.MutableMap();
|
||||
}
|
||||
inline ::PROTOBUF_NAMESPACE_ID::Map< uint32_t, int64_t >*
|
||||
FlowStat::mutable_flow_last_exec_time_map() {
|
||||
// @@protoc_insertion_point(field_mutable_map:greptime.v1.meta.FlowStat.flow_last_exec_time_map)
|
||||
return _internal_mutable_flow_last_exec_time_map();
|
||||
}
|
||||
|
||||
// -------------------------------------------------------------------
|
||||
|
||||
// HeartbeatResponse
|
||||
@@ -4202,6 +4284,8 @@ inline MailboxMessage::PayloadCase MailboxMessage::payload_case() const {
|
||||
|
||||
// -------------------------------------------------------------------
|
||||
|
||||
// -------------------------------------------------------------------
|
||||
|
||||
|
||||
// @@protoc_insertion_point(namespace_scope)
|
||||
|
||||
|
||||
+128
-107
@@ -390,7 +390,8 @@ type FlowStat struct {
|
||||
// Each flow's in mem state's size in bytes
|
||||
// due to protobuf's key can't be a message, so we use uint32 as the key which
|
||||
// is [`FlowId`]'s inner field `id`
|
||||
FlowStatSize map[uint32]uint64 `protobuf:"bytes,1,rep,name=flow_stat_size,json=flowStatSize,proto3" json:"flow_stat_size,omitempty" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"`
|
||||
FlowStatSize map[uint32]uint64 `protobuf:"bytes,1,rep,name=flow_stat_size,json=flowStatSize,proto3" json:"flow_stat_size,omitempty" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"`
|
||||
FlowLastExecTimeMap map[uint32]int64 `protobuf:"bytes,2,rep,name=flow_last_exec_time_map,json=flowLastExecTimeMap,proto3" json:"flow_last_exec_time_map,omitempty" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"`
|
||||
}
|
||||
|
||||
func (x *FlowStat) Reset() {
|
||||
@@ -432,6 +433,13 @@ func (x *FlowStat) GetFlowStatSize() map[uint32]uint64 {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (x *FlowStat) GetFlowLastExecTimeMap() map[uint32]int64 {
|
||||
if x != nil {
|
||||
return x.FlowLastExecTimeMap
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
type HeartbeatResponse struct {
|
||||
state protoimpl.MessageState
|
||||
sizeCache protoimpl.SizeCache
|
||||
@@ -906,94 +914,105 @@ var file_greptime_v1_meta_heartbeat_proto_rawDesc = []byte{
|
||||
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, 0x9f, 0x01, 0x0a, 0x08, 0x46, 0x6c, 0x6f, 0x77, 0x53, 0x74, 0x61, 0x74, 0x12, 0x52,
|
||||
0x01, 0x22, 0xd2, 0x02, 0x0a, 0x08, 0x46, 0x6c, 0x6f, 0x77, 0x53, 0x74, 0x61, 0x74, 0x12, 0x52,
|
||||
0x0a, 0x0e, 0x66, 0x6c, 0x6f, 0x77, 0x5f, 0x73, 0x74, 0x61, 0x74, 0x5f, 0x73, 0x69, 0x7a, 0x65,
|
||||
0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x2c, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d,
|
||||
0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x46, 0x6c, 0x6f, 0x77, 0x53, 0x74,
|
||||
0x61, 0x74, 0x2e, 0x46, 0x6c, 0x6f, 0x77, 0x53, 0x74, 0x61, 0x74, 0x53, 0x69, 0x7a, 0x65, 0x45,
|
||||
0x6e, 0x74, 0x72, 0x79, 0x52, 0x0c, 0x66, 0x6c, 0x6f, 0x77, 0x53, 0x74, 0x61, 0x74, 0x53, 0x69,
|
||||
0x7a, 0x65, 0x1a, 0x3f, 0x0a, 0x11, 0x46, 0x6c, 0x6f, 0x77, 0x53, 0x74, 0x61, 0x74, 0x53, 0x69,
|
||||
0x7a, 0x65, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01,
|
||||
0x20, 0x01, 0x28, 0x0d, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c,
|
||||
0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x04, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a,
|
||||
0x02, 0x38, 0x01, 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,
|
||||
0x7a, 0x65, 0x12, 0x69, 0x0a, 0x17, 0x66, 0x6c, 0x6f, 0x77, 0x5f, 0x6c, 0x61, 0x73, 0x74, 0x5f,
|
||||
0x65, 0x78, 0x65, 0x63, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x5f, 0x6d, 0x61, 0x70, 0x18, 0x02, 0x20,
|
||||
0x03, 0x28, 0x0b, 0x32, 0x33, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76,
|
||||
0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x46, 0x6c, 0x6f, 0x77, 0x53, 0x74, 0x61, 0x74, 0x2e,
|
||||
0x46, 0x6c, 0x6f, 0x77, 0x4c, 0x61, 0x73, 0x74, 0x45, 0x78, 0x65, 0x63, 0x54, 0x69, 0x6d, 0x65,
|
||||
0x4d, 0x61, 0x70, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x13, 0x66, 0x6c, 0x6f, 0x77, 0x4c, 0x61,
|
||||
0x73, 0x74, 0x45, 0x78, 0x65, 0x63, 0x54, 0x69, 0x6d, 0x65, 0x4d, 0x61, 0x70, 0x1a, 0x3f, 0x0a,
|
||||
0x11, 0x46, 0x6c, 0x6f, 0x77, 0x53, 0x74, 0x61, 0x74, 0x53, 0x69, 0x7a, 0x65, 0x45, 0x6e, 0x74,
|
||||
0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52,
|
||||
0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20,
|
||||
0x01, 0x28, 0x04, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x1a, 0x46,
|
||||
0x0a, 0x18, 0x46, 0x6c, 0x6f, 0x77, 0x4c, 0x61, 0x73, 0x74, 0x45, 0x78, 0x65, 0x63, 0x54, 0x69,
|
||||
0x6d, 0x65, 0x4d, 0x61, 0x70, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65,
|
||||
0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05,
|
||||
0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x05, 0x76, 0x61, 0x6c,
|
||||
0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 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, 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, 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,
|
||||
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 (
|
||||
@@ -1009,7 +1028,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, 12)
|
||||
var file_greptime_v1_meta_heartbeat_proto_msgTypes = make([]protoimpl.MessageInfo, 13)
|
||||
var file_greptime_v1_meta_heartbeat_proto_goTypes = []interface{}{
|
||||
(RegionRole)(0), // 0: greptime.v1.meta.RegionRole
|
||||
(*HeartbeatRequest)(nil), // 1: greptime.v1.meta.HeartbeatRequest
|
||||
@@ -1024,15 +1043,16 @@ var file_greptime_v1_meta_heartbeat_proto_goTypes = []interface{}{
|
||||
(*MailboxMessage)(nil), // 10: greptime.v1.meta.MailboxMessage
|
||||
nil, // 11: greptime.v1.meta.RegionStat.ExtensionsEntry
|
||||
nil, // 12: greptime.v1.meta.FlowStat.FlowStatSizeEntry
|
||||
(*RequestHeader)(nil), // 13: greptime.v1.meta.RequestHeader
|
||||
(*Peer)(nil), // 14: greptime.v1.meta.Peer
|
||||
(*TimeInterval)(nil), // 15: greptime.v1.meta.TimeInterval
|
||||
(*ResponseHeader)(nil), // 16: greptime.v1.meta.ResponseHeader
|
||||
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
|
||||
}
|
||||
var file_greptime_v1_meta_heartbeat_proto_depIdxs = []int32{
|
||||
13, // 0: greptime.v1.meta.HeartbeatRequest.header:type_name -> greptime.v1.meta.RequestHeader
|
||||
14, // 1: greptime.v1.meta.HeartbeatRequest.peer:type_name -> greptime.v1.meta.Peer
|
||||
15, // 2: greptime.v1.meta.HeartbeatRequest.report_interval:type_name -> greptime.v1.meta.TimeInterval
|
||||
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
|
||||
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
|
||||
@@ -1040,23 +1060,24 @@ var file_greptime_v1_meta_heartbeat_proto_depIdxs = []int32{
|
||||
0, // 7: greptime.v1.meta.RegionStat.role:type_name -> greptime.v1.meta.RegionRole
|
||||
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
|
||||
16, // 10: greptime.v1.meta.HeartbeatResponse.header:type_name -> greptime.v1.meta.ResponseHeader
|
||||
10, // 11: greptime.v1.meta.HeartbeatResponse.mailbox_message:type_name -> greptime.v1.meta.MailboxMessage
|
||||
7, // 12: greptime.v1.meta.HeartbeatResponse.region_lease:type_name -> greptime.v1.meta.RegionLease
|
||||
0, // 13: greptime.v1.meta.GrantedRegion.role:type_name -> greptime.v1.meta.RegionRole
|
||||
6, // 14: greptime.v1.meta.RegionLease.regions:type_name -> greptime.v1.meta.GrantedRegion
|
||||
13, // 15: greptime.v1.meta.AskLeaderRequest.header:type_name -> greptime.v1.meta.RequestHeader
|
||||
16, // 16: greptime.v1.meta.AskLeaderResponse.header:type_name -> greptime.v1.meta.ResponseHeader
|
||||
14, // 17: greptime.v1.meta.AskLeaderResponse.leader:type_name -> greptime.v1.meta.Peer
|
||||
1, // 18: greptime.v1.meta.Heartbeat.Heartbeat:input_type -> greptime.v1.meta.HeartbeatRequest
|
||||
8, // 19: greptime.v1.meta.Heartbeat.AskLeader:input_type -> greptime.v1.meta.AskLeaderRequest
|
||||
5, // 20: greptime.v1.meta.Heartbeat.Heartbeat:output_type -> greptime.v1.meta.HeartbeatResponse
|
||||
9, // 21: greptime.v1.meta.Heartbeat.AskLeader:output_type -> greptime.v1.meta.AskLeaderResponse
|
||||
20, // [20:22] is the sub-list for method output_type
|
||||
18, // [18:20] is the sub-list for method input_type
|
||||
18, // [18:18] is the sub-list for extension type_name
|
||||
18, // [18:18] is the sub-list for extension extendee
|
||||
0, // [0:18] is the sub-list for field type_name
|
||||
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
|
||||
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
|
||||
}
|
||||
|
||||
func init() { file_greptime_v1_meta_heartbeat_proto_init() }
|
||||
@@ -1196,7 +1217,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: 12,
|
||||
NumMessages: 13,
|
||||
NumExtensions: 0,
|
||||
NumServices: 1,
|
||||
},
|
||||
|
||||
@@ -5106,6 +5106,40 @@ com.google.protobuf.ByteString defaultValue);
|
||||
|
||||
long getFlowStatSizeOrThrow(
|
||||
int key);
|
||||
|
||||
/**
|
||||
* <code>map<uint32, int64> flow_last_exec_time_map = 2;</code>
|
||||
*/
|
||||
int getFlowLastExecTimeMapCount();
|
||||
/**
|
||||
* <code>map<uint32, int64> flow_last_exec_time_map = 2;</code>
|
||||
*/
|
||||
boolean containsFlowLastExecTimeMap(
|
||||
int key);
|
||||
/**
|
||||
* Use {@link #getFlowLastExecTimeMapMap()} instead.
|
||||
*/
|
||||
@java.lang.Deprecated
|
||||
java.util.Map<java.lang.Integer, java.lang.Long>
|
||||
getFlowLastExecTimeMap();
|
||||
/**
|
||||
* <code>map<uint32, int64> flow_last_exec_time_map = 2;</code>
|
||||
*/
|
||||
java.util.Map<java.lang.Integer, java.lang.Long>
|
||||
getFlowLastExecTimeMapMap();
|
||||
/**
|
||||
* <code>map<uint32, int64> flow_last_exec_time_map = 2;</code>
|
||||
*/
|
||||
|
||||
long getFlowLastExecTimeMapOrDefault(
|
||||
int key,
|
||||
long defaultValue);
|
||||
/**
|
||||
* <code>map<uint32, int64> flow_last_exec_time_map = 2;</code>
|
||||
*/
|
||||
|
||||
long getFlowLastExecTimeMapOrThrow(
|
||||
int key);
|
||||
}
|
||||
/**
|
||||
* Protobuf type {@code greptime.v1.meta.FlowStat}
|
||||
@@ -5166,6 +5200,19 @@ com.google.protobuf.ByteString defaultValue);
|
||||
flowStatSize__.getKey(), flowStatSize__.getValue());
|
||||
break;
|
||||
}
|
||||
case 18: {
|
||||
if (!((mutable_bitField0_ & 0x00000002) != 0)) {
|
||||
flowLastExecTimeMap_ = com.google.protobuf.MapField.newMapField(
|
||||
FlowLastExecTimeMapDefaultEntryHolder.defaultEntry);
|
||||
mutable_bitField0_ |= 0x00000002;
|
||||
}
|
||||
com.google.protobuf.MapEntry<java.lang.Integer, java.lang.Long>
|
||||
flowLastExecTimeMap__ = input.readMessage(
|
||||
FlowLastExecTimeMapDefaultEntryHolder.defaultEntry.getParserForType(), extensionRegistry);
|
||||
flowLastExecTimeMap_.getMutableMap().put(
|
||||
flowLastExecTimeMap__.getKey(), flowLastExecTimeMap__.getValue());
|
||||
break;
|
||||
}
|
||||
default: {
|
||||
if (!parseUnknownField(
|
||||
input, unknownFields, extensionRegistry, tag)) {
|
||||
@@ -5199,6 +5246,8 @@ com.google.protobuf.ByteString defaultValue);
|
||||
switch (number) {
|
||||
case 1:
|
||||
return internalGetFlowStatSize();
|
||||
case 2:
|
||||
return internalGetFlowLastExecTimeMap();
|
||||
default:
|
||||
throw new RuntimeException(
|
||||
"Invalid map field number: " + number);
|
||||
@@ -5317,6 +5366,87 @@ com.google.protobuf.ByteString defaultValue);
|
||||
return map.get(key);
|
||||
}
|
||||
|
||||
public static final int FLOW_LAST_EXEC_TIME_MAP_FIELD_NUMBER = 2;
|
||||
private static final class FlowLastExecTimeMapDefaultEntryHolder {
|
||||
static final com.google.protobuf.MapEntry<
|
||||
java.lang.Integer, java.lang.Long> defaultEntry =
|
||||
com.google.protobuf.MapEntry
|
||||
.<java.lang.Integer, java.lang.Long>newDefaultInstance(
|
||||
greptime.v1.meta.HeartbeatOuterClass.internal_static_greptime_v1_meta_FlowStat_FlowLastExecTimeMapEntry_descriptor,
|
||||
com.google.protobuf.WireFormat.FieldType.UINT32,
|
||||
0,
|
||||
com.google.protobuf.WireFormat.FieldType.INT64,
|
||||
0L);
|
||||
}
|
||||
private com.google.protobuf.MapField<
|
||||
java.lang.Integer, java.lang.Long> flowLastExecTimeMap_;
|
||||
private com.google.protobuf.MapField<java.lang.Integer, java.lang.Long>
|
||||
internalGetFlowLastExecTimeMap() {
|
||||
if (flowLastExecTimeMap_ == null) {
|
||||
return com.google.protobuf.MapField.emptyMapField(
|
||||
FlowLastExecTimeMapDefaultEntryHolder.defaultEntry);
|
||||
}
|
||||
return flowLastExecTimeMap_;
|
||||
}
|
||||
|
||||
public int getFlowLastExecTimeMapCount() {
|
||||
return internalGetFlowLastExecTimeMap().getMap().size();
|
||||
}
|
||||
/**
|
||||
* <code>map<uint32, int64> flow_last_exec_time_map = 2;</code>
|
||||
*/
|
||||
|
||||
@java.lang.Override
|
||||
public boolean containsFlowLastExecTimeMap(
|
||||
int key) {
|
||||
|
||||
return internalGetFlowLastExecTimeMap().getMap().containsKey(key);
|
||||
}
|
||||
/**
|
||||
* Use {@link #getFlowLastExecTimeMapMap()} instead.
|
||||
*/
|
||||
@java.lang.Override
|
||||
@java.lang.Deprecated
|
||||
public java.util.Map<java.lang.Integer, java.lang.Long> getFlowLastExecTimeMap() {
|
||||
return getFlowLastExecTimeMapMap();
|
||||
}
|
||||
/**
|
||||
* <code>map<uint32, int64> flow_last_exec_time_map = 2;</code>
|
||||
*/
|
||||
@java.lang.Override
|
||||
|
||||
public java.util.Map<java.lang.Integer, java.lang.Long> getFlowLastExecTimeMapMap() {
|
||||
return internalGetFlowLastExecTimeMap().getMap();
|
||||
}
|
||||
/**
|
||||
* <code>map<uint32, int64> flow_last_exec_time_map = 2;</code>
|
||||
*/
|
||||
@java.lang.Override
|
||||
|
||||
public long getFlowLastExecTimeMapOrDefault(
|
||||
int key,
|
||||
long defaultValue) {
|
||||
|
||||
java.util.Map<java.lang.Integer, java.lang.Long> map =
|
||||
internalGetFlowLastExecTimeMap().getMap();
|
||||
return map.containsKey(key) ? map.get(key) : defaultValue;
|
||||
}
|
||||
/**
|
||||
* <code>map<uint32, int64> flow_last_exec_time_map = 2;</code>
|
||||
*/
|
||||
@java.lang.Override
|
||||
|
||||
public long getFlowLastExecTimeMapOrThrow(
|
||||
int key) {
|
||||
|
||||
java.util.Map<java.lang.Integer, java.lang.Long> map =
|
||||
internalGetFlowLastExecTimeMap().getMap();
|
||||
if (!map.containsKey(key)) {
|
||||
throw new java.lang.IllegalArgumentException();
|
||||
}
|
||||
return map.get(key);
|
||||
}
|
||||
|
||||
private byte memoizedIsInitialized = -1;
|
||||
@java.lang.Override
|
||||
public final boolean isInitialized() {
|
||||
@@ -5337,6 +5467,12 @@ com.google.protobuf.ByteString defaultValue);
|
||||
internalGetFlowStatSize(),
|
||||
FlowStatSizeDefaultEntryHolder.defaultEntry,
|
||||
1);
|
||||
com.google.protobuf.GeneratedMessageV3
|
||||
.serializeIntegerMapTo(
|
||||
output,
|
||||
internalGetFlowLastExecTimeMap(),
|
||||
FlowLastExecTimeMapDefaultEntryHolder.defaultEntry,
|
||||
2);
|
||||
unknownFields.writeTo(output);
|
||||
}
|
||||
|
||||
@@ -5356,6 +5492,16 @@ com.google.protobuf.ByteString defaultValue);
|
||||
size += com.google.protobuf.CodedOutputStream
|
||||
.computeMessageSize(1, flowStatSize__);
|
||||
}
|
||||
for (java.util.Map.Entry<java.lang.Integer, java.lang.Long> entry
|
||||
: internalGetFlowLastExecTimeMap().getMap().entrySet()) {
|
||||
com.google.protobuf.MapEntry<java.lang.Integer, java.lang.Long>
|
||||
flowLastExecTimeMap__ = FlowLastExecTimeMapDefaultEntryHolder.defaultEntry.newBuilderForType()
|
||||
.setKey(entry.getKey())
|
||||
.setValue(entry.getValue())
|
||||
.build();
|
||||
size += com.google.protobuf.CodedOutputStream
|
||||
.computeMessageSize(2, flowLastExecTimeMap__);
|
||||
}
|
||||
size += unknownFields.getSerializedSize();
|
||||
memoizedSize = size;
|
||||
return size;
|
||||
@@ -5373,6 +5519,8 @@ com.google.protobuf.ByteString defaultValue);
|
||||
|
||||
if (!internalGetFlowStatSize().equals(
|
||||
other.internalGetFlowStatSize())) return false;
|
||||
if (!internalGetFlowLastExecTimeMap().equals(
|
||||
other.internalGetFlowLastExecTimeMap())) return false;
|
||||
if (!unknownFields.equals(other.unknownFields)) return false;
|
||||
return true;
|
||||
}
|
||||
@@ -5388,6 +5536,10 @@ com.google.protobuf.ByteString defaultValue);
|
||||
hash = (37 * hash) + FLOW_STAT_SIZE_FIELD_NUMBER;
|
||||
hash = (53 * hash) + internalGetFlowStatSize().hashCode();
|
||||
}
|
||||
if (!internalGetFlowLastExecTimeMap().getMap().isEmpty()) {
|
||||
hash = (37 * hash) + FLOW_LAST_EXEC_TIME_MAP_FIELD_NUMBER;
|
||||
hash = (53 * hash) + internalGetFlowLastExecTimeMap().hashCode();
|
||||
}
|
||||
hash = (29 * hash) + unknownFields.hashCode();
|
||||
memoizedHashCode = hash;
|
||||
return hash;
|
||||
@@ -5501,6 +5653,8 @@ com.google.protobuf.ByteString defaultValue);
|
||||
switch (number) {
|
||||
case 1:
|
||||
return internalGetFlowStatSize();
|
||||
case 2:
|
||||
return internalGetFlowLastExecTimeMap();
|
||||
default:
|
||||
throw new RuntimeException(
|
||||
"Invalid map field number: " + number);
|
||||
@@ -5512,6 +5666,8 @@ com.google.protobuf.ByteString defaultValue);
|
||||
switch (number) {
|
||||
case 1:
|
||||
return internalGetMutableFlowStatSize();
|
||||
case 2:
|
||||
return internalGetMutableFlowLastExecTimeMap();
|
||||
default:
|
||||
throw new RuntimeException(
|
||||
"Invalid map field number: " + number);
|
||||
@@ -5544,6 +5700,7 @@ com.google.protobuf.ByteString defaultValue);
|
||||
public Builder clear() {
|
||||
super.clear();
|
||||
internalGetMutableFlowStatSize().clear();
|
||||
internalGetMutableFlowLastExecTimeMap().clear();
|
||||
return this;
|
||||
}
|
||||
|
||||
@@ -5573,6 +5730,8 @@ com.google.protobuf.ByteString defaultValue);
|
||||
int from_bitField0_ = bitField0_;
|
||||
result.flowStatSize_ = internalGetFlowStatSize();
|
||||
result.flowStatSize_.makeImmutable();
|
||||
result.flowLastExecTimeMap_ = internalGetFlowLastExecTimeMap();
|
||||
result.flowLastExecTimeMap_.makeImmutable();
|
||||
onBuilt();
|
||||
return result;
|
||||
}
|
||||
@@ -5623,6 +5782,8 @@ com.google.protobuf.ByteString defaultValue);
|
||||
if (other == greptime.v1.meta.HeartbeatOuterClass.FlowStat.getDefaultInstance()) return this;
|
||||
internalGetMutableFlowStatSize().mergeFrom(
|
||||
other.internalGetFlowStatSize());
|
||||
internalGetMutableFlowLastExecTimeMap().mergeFrom(
|
||||
other.internalGetFlowLastExecTimeMap());
|
||||
this.mergeUnknownFields(other.unknownFields);
|
||||
onChanged();
|
||||
return this;
|
||||
@@ -5822,6 +5983,134 @@ com.google.protobuf.ByteString defaultValue);
|
||||
.putAll(values);
|
||||
return this;
|
||||
}
|
||||
|
||||
private com.google.protobuf.MapField<
|
||||
java.lang.Integer, java.lang.Long> flowLastExecTimeMap_;
|
||||
private com.google.protobuf.MapField<java.lang.Integer, java.lang.Long>
|
||||
internalGetFlowLastExecTimeMap() {
|
||||
if (flowLastExecTimeMap_ == null) {
|
||||
return com.google.protobuf.MapField.emptyMapField(
|
||||
FlowLastExecTimeMapDefaultEntryHolder.defaultEntry);
|
||||
}
|
||||
return flowLastExecTimeMap_;
|
||||
}
|
||||
private com.google.protobuf.MapField<java.lang.Integer, java.lang.Long>
|
||||
internalGetMutableFlowLastExecTimeMap() {
|
||||
onChanged();;
|
||||
if (flowLastExecTimeMap_ == null) {
|
||||
flowLastExecTimeMap_ = com.google.protobuf.MapField.newMapField(
|
||||
FlowLastExecTimeMapDefaultEntryHolder.defaultEntry);
|
||||
}
|
||||
if (!flowLastExecTimeMap_.isMutable()) {
|
||||
flowLastExecTimeMap_ = flowLastExecTimeMap_.copy();
|
||||
}
|
||||
return flowLastExecTimeMap_;
|
||||
}
|
||||
|
||||
public int getFlowLastExecTimeMapCount() {
|
||||
return internalGetFlowLastExecTimeMap().getMap().size();
|
||||
}
|
||||
/**
|
||||
* <code>map<uint32, int64> flow_last_exec_time_map = 2;</code>
|
||||
*/
|
||||
|
||||
@java.lang.Override
|
||||
public boolean containsFlowLastExecTimeMap(
|
||||
int key) {
|
||||
|
||||
return internalGetFlowLastExecTimeMap().getMap().containsKey(key);
|
||||
}
|
||||
/**
|
||||
* Use {@link #getFlowLastExecTimeMapMap()} instead.
|
||||
*/
|
||||
@java.lang.Override
|
||||
@java.lang.Deprecated
|
||||
public java.util.Map<java.lang.Integer, java.lang.Long> getFlowLastExecTimeMap() {
|
||||
return getFlowLastExecTimeMapMap();
|
||||
}
|
||||
/**
|
||||
* <code>map<uint32, int64> flow_last_exec_time_map = 2;</code>
|
||||
*/
|
||||
@java.lang.Override
|
||||
|
||||
public java.util.Map<java.lang.Integer, java.lang.Long> getFlowLastExecTimeMapMap() {
|
||||
return internalGetFlowLastExecTimeMap().getMap();
|
||||
}
|
||||
/**
|
||||
* <code>map<uint32, int64> flow_last_exec_time_map = 2;</code>
|
||||
*/
|
||||
@java.lang.Override
|
||||
|
||||
public long getFlowLastExecTimeMapOrDefault(
|
||||
int key,
|
||||
long defaultValue) {
|
||||
|
||||
java.util.Map<java.lang.Integer, java.lang.Long> map =
|
||||
internalGetFlowLastExecTimeMap().getMap();
|
||||
return map.containsKey(key) ? map.get(key) : defaultValue;
|
||||
}
|
||||
/**
|
||||
* <code>map<uint32, int64> flow_last_exec_time_map = 2;</code>
|
||||
*/
|
||||
@java.lang.Override
|
||||
|
||||
public long getFlowLastExecTimeMapOrThrow(
|
||||
int key) {
|
||||
|
||||
java.util.Map<java.lang.Integer, java.lang.Long> map =
|
||||
internalGetFlowLastExecTimeMap().getMap();
|
||||
if (!map.containsKey(key)) {
|
||||
throw new java.lang.IllegalArgumentException();
|
||||
}
|
||||
return map.get(key);
|
||||
}
|
||||
|
||||
public Builder clearFlowLastExecTimeMap() {
|
||||
internalGetMutableFlowLastExecTimeMap().getMutableMap()
|
||||
.clear();
|
||||
return this;
|
||||
}
|
||||
/**
|
||||
* <code>map<uint32, int64> flow_last_exec_time_map = 2;</code>
|
||||
*/
|
||||
|
||||
public Builder removeFlowLastExecTimeMap(
|
||||
int key) {
|
||||
|
||||
internalGetMutableFlowLastExecTimeMap().getMutableMap()
|
||||
.remove(key);
|
||||
return this;
|
||||
}
|
||||
/**
|
||||
* Use alternate mutation accessors instead.
|
||||
*/
|
||||
@java.lang.Deprecated
|
||||
public java.util.Map<java.lang.Integer, java.lang.Long>
|
||||
getMutableFlowLastExecTimeMap() {
|
||||
return internalGetMutableFlowLastExecTimeMap().getMutableMap();
|
||||
}
|
||||
/**
|
||||
* <code>map<uint32, int64> flow_last_exec_time_map = 2;</code>
|
||||
*/
|
||||
public Builder putFlowLastExecTimeMap(
|
||||
int key,
|
||||
long value) {
|
||||
|
||||
|
||||
internalGetMutableFlowLastExecTimeMap().getMutableMap()
|
||||
.put(key, value);
|
||||
return this;
|
||||
}
|
||||
/**
|
||||
* <code>map<uint32, int64> flow_last_exec_time_map = 2;</code>
|
||||
*/
|
||||
|
||||
public Builder putAllFlowLastExecTimeMap(
|
||||
java.util.Map<java.lang.Integer, java.lang.Long> values) {
|
||||
internalGetMutableFlowLastExecTimeMap().getMutableMap()
|
||||
.putAll(values);
|
||||
return this;
|
||||
}
|
||||
@java.lang.Override
|
||||
public final Builder setUnknownFields(
|
||||
final com.google.protobuf.UnknownFieldSet unknownFields) {
|
||||
@@ -11477,6 +11766,11 @@ com.google.protobuf.ByteString defaultValue);
|
||||
private static final
|
||||
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
|
||||
internal_static_greptime_v1_meta_FlowStat_FlowStatSizeEntry_fieldAccessorTable;
|
||||
private static final com.google.protobuf.Descriptors.Descriptor
|
||||
internal_static_greptime_v1_meta_FlowStat_FlowLastExecTimeMapEntry_descriptor;
|
||||
private static final
|
||||
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
|
||||
internal_static_greptime_v1_meta_FlowStat_FlowLastExecTimeMapEntry_fieldAccessorTable;
|
||||
private static final com.google.protobuf.Descriptors.Descriptor
|
||||
internal_static_greptime_v1_meta_HeartbeatResponse_descriptor;
|
||||
private static final
|
||||
@@ -11537,36 +11831,40 @@ com.google.protobuf.ByteString defaultValue);
|
||||
"ta.RegionRole\022@\n\nextensions\030c \003(\0132,.grep" +
|
||||
"time.v1.meta.RegionStat.ExtensionsEntry\032" +
|
||||
"1\n\017ExtensionsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value" +
|
||||
"\030\002 \001(\014:\0028\001\"\205\001\n\010FlowStat\022D\n\016flow_stat_siz" +
|
||||
"\030\002 \001(\014:\0028\001\"\227\002\n\010FlowStat\022D\n\016flow_stat_siz" +
|
||||
"e\030\001 \003(\0132,.greptime.v1.meta.FlowStat.Flow" +
|
||||
"StatSizeEntry\0323\n\021FlowStatSizeEntry\022\013\n\003ke" +
|
||||
"y\030\001 \001(\r\022\r\n\005value\030\002 \001(\004:\0028\001\"\265\001\n\021Heartbeat" +
|
||||
"Response\0220\n\006header\030\001 \001(\0132 .greptime.v1.m" +
|
||||
"eta.ResponseHeader\0229\n\017mailbox_message\030\002 " +
|
||||
"\001(\0132 .greptime.v1.meta.MailboxMessage\0223\n" +
|
||||
"\014region_lease\030\003 \001(\0132\035.greptime.v1.meta.R" +
|
||||
"egionLease\"N\n\rGrantedRegion\022\021\n\tregion_id" +
|
||||
"\030\001 \001(\004\022*\n\004role\030\002 \001(\0162\034.greptime.v1.meta." +
|
||||
"RegionRole\"\222\001\n\013RegionLease\0220\n\007regions\030\001 " +
|
||||
"\003(\0132\037.greptime.v1.meta.GrantedRegion\022\034\n\024" +
|
||||
"duration_since_epoch\030\002 \001(\004\022\025\n\rlease_seco" +
|
||||
"nds\030\003 \001(\004\022\034\n\024closeable_region_ids\030\004 \003(\004\"" +
|
||||
"C\n\020AskLeaderRequest\022/\n\006header\030\001 \001(\0132\037.gr" +
|
||||
"eptime.v1.meta.RequestHeader\"m\n\021AskLeade" +
|
||||
"rResponse\0220\n\006header\030\001 \001(\0132 .greptime.v1." +
|
||||
"meta.ResponseHeader\022&\n\006leader\030\002 \001(\0132\026.gr" +
|
||||
"eptime.v1.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\006Leader\020\000\022\014\n\010Follower\020\001\022\025\n\021Downgrading" +
|
||||
"Leader\020\0022\277\001\n\tHeartbeat\022Z\n\tHeartbeat\022\".gr" +
|
||||
"eptime.v1.meta.HeartbeatRequest\032#.grepti" +
|
||||
"me.v1.meta.HeartbeatResponse\"\000(\0010\001\022V\n\tAs" +
|
||||
"kLeader\022\".greptime.v1.meta.AskLeaderRequ" +
|
||||
"est\032#.greptime.v1.meta.AskLeaderResponse" +
|
||||
"\"\000B<Z:github.com/GreptimeTeam/greptime-p" +
|
||||
"roto/go/greptime/v1/metab\006proto3"
|
||||
"StatSizeEntry\022T\n\027flow_last_exec_time_map" +
|
||||
"\030\002 \003(\01323.greptime.v1.meta.FlowStat.FlowL" +
|
||||
"astExecTimeMapEntry\0323\n\021FlowStatSizeEntry" +
|
||||
"\022\013\n\003key\030\001 \001(\r\022\r\n\005value\030\002 \001(\004:\0028\001\032:\n\030Flow" +
|
||||
"LastExecTimeMapEntry\022\013\n\003key\030\001 \001(\r\022\r\n\005val" +
|
||||
"ue\030\002 \001(\003:\0028\001\"\265\001\n\021HeartbeatResponse\0220\n\006he" +
|
||||
"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\"N\n\r" +
|
||||
"GrantedRegion\022\021\n\tregion_id\030\001 \001(\004\022*\n\004role" +
|
||||
"\030\002 \001(\0162\034.greptime.v1.meta.RegionRole\"\222\001\n" +
|
||||
"\013RegionLease\0220\n\007regions\030\001 \003(\0132\037.greptime" +
|
||||
".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\024c" +
|
||||
"loseable_region_ids\030\004 \003(\004\"C\n\020AskLeaderRe" +
|
||||
"quest\022/\n\006header\030\001 \001(\0132\037.greptime.v1.meta" +
|
||||
".RequestHeader\"m\n\021AskLeaderResponse\0220\n\006h" +
|
||||
"eader\030\001 \001(\0132 .greptime.v1.meta.ResponseH" +
|
||||
"eader\022&\n\006leader\030\002 \001(\0132\026.greptime.v1.meta" +
|
||||
".Peer\"|\n\016MailboxMessage\022\n\n\002id\030\001 \001(\004\022\017\n\007s" +
|
||||
"ubject\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\000" +
|
||||
"B\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\tH" +
|
||||
"eartbeat\022Z\n\tHeartbeat\022\".greptime.v1.meta" +
|
||||
".HeartbeatRequest\032#.greptime.v1.meta.Hea" +
|
||||
"rtbeatResponse\"\000(\0010\001\022V\n\tAskLeader\022\".grep" +
|
||||
"time.v1.meta.AskLeaderRequest\032#.greptime" +
|
||||
".v1.meta.AskLeaderResponse\"\000B<Z:github.c" +
|
||||
"om/GreptimeTeam/greptime-proto/go/grepti" +
|
||||
"me/v1/metab\006proto3"
|
||||
};
|
||||
descriptor = com.google.protobuf.Descriptors.FileDescriptor
|
||||
.internalBuildGeneratedFileFrom(descriptorData,
|
||||
@@ -11602,13 +11900,19 @@ com.google.protobuf.ByteString defaultValue);
|
||||
internal_static_greptime_v1_meta_FlowStat_fieldAccessorTable = new
|
||||
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
|
||||
internal_static_greptime_v1_meta_FlowStat_descriptor,
|
||||
new java.lang.String[] { "FlowStatSize", });
|
||||
new java.lang.String[] { "FlowStatSize", "FlowLastExecTimeMap", });
|
||||
internal_static_greptime_v1_meta_FlowStat_FlowStatSizeEntry_descriptor =
|
||||
internal_static_greptime_v1_meta_FlowStat_descriptor.getNestedTypes().get(0);
|
||||
internal_static_greptime_v1_meta_FlowStat_FlowStatSizeEntry_fieldAccessorTable = new
|
||||
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
|
||||
internal_static_greptime_v1_meta_FlowStat_FlowStatSizeEntry_descriptor,
|
||||
new java.lang.String[] { "Key", "Value", });
|
||||
internal_static_greptime_v1_meta_FlowStat_FlowLastExecTimeMapEntry_descriptor =
|
||||
internal_static_greptime_v1_meta_FlowStat_descriptor.getNestedTypes().get(1);
|
||||
internal_static_greptime_v1_meta_FlowStat_FlowLastExecTimeMapEntry_fieldAccessorTable = new
|
||||
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
|
||||
internal_static_greptime_v1_meta_FlowStat_FlowLastExecTimeMapEntry_descriptor,
|
||||
new java.lang.String[] { "Key", "Value", });
|
||||
internal_static_greptime_v1_meta_HeartbeatResponse_descriptor =
|
||||
getDescriptor().getMessageTypes().get(4);
|
||||
internal_static_greptime_v1_meta_HeartbeatResponse_fieldAccessorTable = new
|
||||
|
||||
@@ -94,6 +94,7 @@ message FlowStat {
|
||||
// due to protobuf's key can't be a message, so we use uint32 as the key which
|
||||
// is [`FlowId`]'s inner field `id`
|
||||
map<uint32, uint64> flow_stat_size = 1;
|
||||
map<uint32, int64> flow_last_exec_time_map = 2;
|
||||
}
|
||||
|
||||
message HeartbeatResponse {
|
||||
|
||||
Reference in New Issue
Block a user