diff --git a/c++/greptime/v1/region/server.pb.cc b/c++/greptime/v1/region/server.pb.cc index 383cff9..8fb962c 100644 --- a/c++/greptime/v1/region/server.pb.cc +++ b/c++/greptime/v1/region/server.pb.cc @@ -468,6 +468,7 @@ PROTOBUF_CONSTEXPR BulkInsertRequest::BulkInsertRequest( ::_pbi::ConstantInitialized): _impl_{ /*decltype(_impl_.partition_expr_version_)*/nullptr , /*decltype(_impl_.region_id_)*/uint64_t{0u} + , /*decltype(_impl_.aligned_schema_version_)*/uint64_t{0u} , /*decltype(_impl_.body_)*/{} , /*decltype(_impl_._cached_size_)*/{} , /*decltype(_impl_._oneof_case_)*/{}} {} @@ -940,6 +941,7 @@ const uint32_t TableStruct_greptime_2fv1_2fregion_2fserver_2eproto::offsets[] PR PROTOBUF_FIELD_OFFSET(::greptime::v1::region::BulkInsertRequest, _impl_.region_id_), ::_pbi::kInvalidFieldOffsetTag, PROTOBUF_FIELD_OFFSET(::greptime::v1::region::BulkInsertRequest, _impl_.partition_expr_version_), + PROTOBUF_FIELD_OFFSET(::greptime::v1::region::BulkInsertRequest, _impl_.aligned_schema_version_), PROTOBUF_FIELD_OFFSET(::greptime::v1::region::BulkInsertRequest, _impl_.body_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::greptime::v1::region::MitoManifestInfo, _internal_metadata_), @@ -1059,16 +1061,16 @@ static const ::_pbi::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protode { 287, -1, -1, sizeof(::greptime::v1::region::All)}, { 293, -1, -1, sizeof(::greptime::v1::region::RegionColumnDef)}, { 301, -1, -1, sizeof(::greptime::v1::region::BulkInsertRequest)}, - { 311, -1, -1, sizeof(::greptime::v1::region::MitoManifestInfo)}, - { 318, -1, -1, sizeof(::greptime::v1::region::MetricManifestInfo)}, - { 326, -1, -1, sizeof(::greptime::v1::region::SyncRequest)}, - { 336, -1, -1, sizeof(::greptime::v1::region::ListMetadataRequest)}, - { 343, -1, -1, sizeof(::greptime::v1::region::BuildIndexRequest)}, - { 350, -1, -1, sizeof(::greptime::v1::region::FileMetas)}, - { 357, -1, -1, sizeof(::greptime::v1::region::ApplyStagingManifestRequest)}, - { 367, -1, -1, sizeof(::greptime::v1::region::RemoteDynFilterRequest)}, - { 377, -1, -1, sizeof(::greptime::v1::region::RemoteDynFilterUpdate)}, - { 387, -1, -1, sizeof(::greptime::v1::region::RemoteDynFilterUnregister)}, + { 312, -1, -1, sizeof(::greptime::v1::region::MitoManifestInfo)}, + { 319, -1, -1, sizeof(::greptime::v1::region::MetricManifestInfo)}, + { 327, -1, -1, sizeof(::greptime::v1::region::SyncRequest)}, + { 337, -1, -1, sizeof(::greptime::v1::region::ListMetadataRequest)}, + { 344, -1, -1, sizeof(::greptime::v1::region::BuildIndexRequest)}, + { 351, -1, -1, sizeof(::greptime::v1::region::FileMetas)}, + { 358, -1, -1, sizeof(::greptime::v1::region::ApplyStagingManifestRequest)}, + { 368, -1, -1, sizeof(::greptime::v1::region::RemoteDynFilterRequest)}, + { 378, -1, -1, sizeof(::greptime::v1::region::RemoteDynFilterUpdate)}, + { 388, -1, -1, sizeof(::greptime::v1::region::RemoteDynFilterUnregister)}, }; static const ::_pb::Message* const file_default_instances[] = { @@ -1235,38 +1237,39 @@ const char descriptor_table_protodef_greptime_2fv1_2fregion_2fserver_2eproto[] P "es\030\003 \001(\0132\027.greptime.v1.TimeRangesH\000B\006\n\004k" "ind\"\005\n\003All\"P\n\017RegionColumnDef\022*\n\ncolumn_" "def\030\001 \001(\0132\026.greptime.v1.ColumnDef\022\021\n\tcol" - "umn_id\030\002 \001(\r\"\235\001\n\021BulkInsertRequest\022\021\n\tre" + "umn_id\030\002 \001(\r\"\275\001\n\021BulkInsertRequest\022\021\n\tre" "gion_id\030\001 \001(\004\022*\n\tarrow_ipc\030\002 \001(\0132\025.grept" "ime.v1.ArrowIpcH\000\022A\n\026partition_expr_vers" "ion\030\003 \001(\0132!.greptime.v1.PartitionExprVer" - "sionB\006\n\004body\"1\n\020MitoManifestInfo\022\035\n\025data" - "_manifest_version\030\001 \001(\004\"V\n\022MetricManifes" - "tInfo\022\035\n\025data_manifest_version\030\001 \001(\004\022!\n\031" - "metadata_manifest_version\030\002 \001(\004\"\275\001\n\013Sync" - "Request\022\021\n\tregion_id\030\001 \001(\004\022B\n\022mito_manif" - "est_info\030\002 \001(\0132$.greptime.v1.region.Mito" - "ManifestInfoH\000\022F\n\024metric_manifest_info\030\003" - " \001(\0132&.greptime.v1.region.MetricManifest" - "InfoH\000B\017\n\rmanifest_info\")\n\023ListMetadataR" - "equest\022\022\n\nregion_ids\030\001 \003(\004\"&\n\021BuildIndex" - "Request\022\021\n\tregion_id\030\001 \001(\004\"\031\n\tFileMetas\022" - "\014\n\004data\030\001 \001(\014\"z\n\033ApplyStagingManifestReq" - "uest\022\021\n\tregion_id\030\001 \001(\004\022\026\n\016partition_exp" - "r\030\002 \001(\t\022\031\n\021central_region_id\030\003 \001(\004\022\025\n\rma" - "nifest_path\030\004 \001(\t\"\266\001\n\026RemoteDynFilterReq" - "uest\022\020\n\010query_id\030\001 \001(\t\022;\n\006update\030\002 \001(\0132)" - ".greptime.v1.region.RemoteDynFilterUpdat" - "eH\000\022C\n\nunregister\030\003 \001(\0132-.greptime.v1.re" - "gion.RemoteDynFilterUnregisterH\000B\010\n\006acti" - "on\"d\n\025RemoteDynFilterUpdate\022\021\n\tfilter_id" - "\030\001 \001(\t\022\017\n\007payload\030\002 \001(\014\022\022\n\ngeneration\030\003 " - "\001(\004\022\023\n\013is_complete\030\004 \001(\010\".\n\031RemoteDynFil" - "terUnregister\022\021\n\tfilter_id\030\001 \001(\t2Y\n\006Regi" - "on\022O\n\006Handle\022!.greptime.v1.region.Region" - "Request\032\".greptime.v1.region.RegionRespo" - "nseB]\n\025io.greptime.v1.regionB\006ServerZ_impl_.partition_expr_version_ = new ::greptime::v1::PartitionExprVersion(*from._impl_.partition_expr_version_); } - _this->_impl_.region_id_ = from._impl_.region_id_; + ::memcpy(&_impl_.region_id_, &from._impl_.region_id_, + static_cast(reinterpret_cast(&_impl_.aligned_schema_version_) - + reinterpret_cast(&_impl_.region_id_)) + sizeof(_impl_.aligned_schema_version_)); clear_has_body(); switch (from.body_case()) { case kArrowIpc: { @@ -9866,6 +9872,7 @@ inline void BulkInsertRequest::SharedCtor( new (&_impl_) Impl_{ decltype(_impl_.partition_expr_version_){nullptr} , decltype(_impl_.region_id_){uint64_t{0u}} + , decltype(_impl_.aligned_schema_version_){uint64_t{0u}} , decltype(_impl_.body_){} , /*decltype(_impl_._cached_size_)*/{} , /*decltype(_impl_._oneof_case_)*/{} @@ -9921,7 +9928,9 @@ void BulkInsertRequest::Clear() { delete _impl_.partition_expr_version_; } _impl_.partition_expr_version_ = nullptr; - _impl_.region_id_ = uint64_t{0u}; + ::memset(&_impl_.region_id_, 0, static_cast( + reinterpret_cast(&_impl_.aligned_schema_version_) - + reinterpret_cast(&_impl_.region_id_)) + sizeof(_impl_.aligned_schema_version_)); clear_body(); _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } @@ -9956,6 +9965,14 @@ const char* BulkInsertRequest::_InternalParse(const char* ptr, ::_pbi::ParseCont } else goto handle_unusual; continue; + // uint64 aligned_schema_version = 4; + case 4: + if (PROTOBUF_PREDICT_TRUE(static_cast(tag) == 32)) { + _impl_.aligned_schema_version_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint64(&ptr); + CHK_(ptr); + } else + goto handle_unusual; + continue; default: goto handle_unusual; } // switch @@ -10005,6 +10022,12 @@ uint8_t* BulkInsertRequest::_InternalSerialize( _Internal::partition_expr_version(this).GetCachedSize(), target, stream); } + // uint64 aligned_schema_version = 4; + if (this->_internal_aligned_schema_version() != 0) { + target = stream->EnsureSpace(target); + target = ::_pbi::WireFormatLite::WriteUInt64ToArray(4, this->_internal_aligned_schema_version(), target); + } + if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { target = ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray( _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream); @@ -10033,6 +10056,11 @@ size_t BulkInsertRequest::ByteSizeLong() const { total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(this->_internal_region_id()); } + // uint64 aligned_schema_version = 4; + if (this->_internal_aligned_schema_version() != 0) { + total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(this->_internal_aligned_schema_version()); + } + switch (body_case()) { // .greptime.v1.ArrowIpc arrow_ipc = 2; case kArrowIpc: { @@ -10070,6 +10098,9 @@ void BulkInsertRequest::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, cons if (from._internal_region_id() != 0) { _this->_internal_set_region_id(from._internal_region_id()); } + if (from._internal_aligned_schema_version() != 0) { + _this->_internal_set_aligned_schema_version(from._internal_aligned_schema_version()); + } switch (from.body_case()) { case kArrowIpc: { _this->_internal_mutable_arrow_ipc()->::greptime::v1::ArrowIpc::MergeFrom( @@ -10098,8 +10129,8 @@ void BulkInsertRequest::InternalSwap(BulkInsertRequest* other) { using std::swap; _internal_metadata_.InternalSwap(&other->_internal_metadata_); ::PROTOBUF_NAMESPACE_ID::internal::memswap< - PROTOBUF_FIELD_OFFSET(BulkInsertRequest, _impl_.region_id_) - + sizeof(BulkInsertRequest::_impl_.region_id_) + PROTOBUF_FIELD_OFFSET(BulkInsertRequest, _impl_.aligned_schema_version_) + + sizeof(BulkInsertRequest::_impl_.aligned_schema_version_) - PROTOBUF_FIELD_OFFSET(BulkInsertRequest, _impl_.partition_expr_version_)>( reinterpret_cast(&_impl_.partition_expr_version_), reinterpret_cast(&other->_impl_.partition_expr_version_)); diff --git a/c++/greptime/v1/region/server.pb.h b/c++/greptime/v1/region/server.pb.h index e2b5bf8..5e99a6d 100644 --- a/c++/greptime/v1/region/server.pb.h +++ b/c++/greptime/v1/region/server.pb.h @@ -6001,6 +6001,7 @@ class BulkInsertRequest final : enum : int { kPartitionExprVersionFieldNumber = 3, kRegionIdFieldNumber = 1, + kAlignedSchemaVersionFieldNumber = 4, kArrowIpcFieldNumber = 2, }; // .greptime.v1.PartitionExprVersion partition_expr_version = 3; @@ -6030,6 +6031,15 @@ class BulkInsertRequest final : void _internal_set_region_id(uint64_t value); public: + // uint64 aligned_schema_version = 4; + void clear_aligned_schema_version(); + uint64_t aligned_schema_version() const; + void set_aligned_schema_version(uint64_t value); + private: + uint64_t _internal_aligned_schema_version() const; + void _internal_set_aligned_schema_version(uint64_t value); + public: + // .greptime.v1.ArrowIpc arrow_ipc = 2; bool has_arrow_ipc() const; private: @@ -6064,6 +6074,7 @@ class BulkInsertRequest final : struct Impl_ { ::greptime::v1::PartitionExprVersion* partition_expr_version_; uint64_t region_id_; + uint64_t aligned_schema_version_; union BodyUnion { constexpr BodyUnion() : _constinit_{} {} ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized _constinit_; @@ -13006,6 +13017,26 @@ inline void BulkInsertRequest::set_allocated_partition_expr_version(::greptime:: // @@protoc_insertion_point(field_set_allocated:greptime.v1.region.BulkInsertRequest.partition_expr_version) } +// uint64 aligned_schema_version = 4; +inline void BulkInsertRequest::clear_aligned_schema_version() { + _impl_.aligned_schema_version_ = uint64_t{0u}; +} +inline uint64_t BulkInsertRequest::_internal_aligned_schema_version() const { + return _impl_.aligned_schema_version_; +} +inline uint64_t BulkInsertRequest::aligned_schema_version() const { + // @@protoc_insertion_point(field_get:greptime.v1.region.BulkInsertRequest.aligned_schema_version) + return _internal_aligned_schema_version(); +} +inline void BulkInsertRequest::_internal_set_aligned_schema_version(uint64_t value) { + + _impl_.aligned_schema_version_ = value; +} +inline void BulkInsertRequest::set_aligned_schema_version(uint64_t value) { + _internal_set_aligned_schema_version(value); + // @@protoc_insertion_point(field_set:greptime.v1.region.BulkInsertRequest.aligned_schema_version) +} + inline bool BulkInsertRequest::has_body() const { return body_case() != BODY_NOT_SET; } diff --git a/go/greptime/v1/region/server.pb.go b/go/greptime/v1/region/server.pb.go index af2d0c2..2099a66 100644 --- a/go/greptime/v1/region/server.pb.go +++ b/go/greptime/v1/region/server.pb.go @@ -2158,6 +2158,7 @@ type BulkInsertRequest struct { // *BulkInsertRequest_ArrowIpc Body isBulkInsertRequest_Body `protobuf_oneof:"body"` PartitionExprVersion *v1.PartitionExprVersion `protobuf:"bytes,3,opt,name=partition_expr_version,json=partitionExprVersion,proto3" json:"partition_expr_version,omitempty"` + AlignedSchemaVersion uint64 `protobuf:"varint,4,opt,name=aligned_schema_version,json=alignedSchemaVersion,proto3" json:"aligned_schema_version,omitempty"` } func (x *BulkInsertRequest) Reset() { @@ -2220,6 +2221,13 @@ func (x *BulkInsertRequest) GetPartitionExprVersion() *v1.PartitionExprVersion { return nil } +func (x *BulkInsertRequest) GetAlignedSchemaVersion() uint64 { + if x != nil { + return x.AlignedSchemaVersion + } + return 0 +} + type isBulkInsertRequest_Body interface { isBulkInsertRequest_Body() } @@ -3210,7 +3218,7 @@ var file_greptime_v1_region_server_proto_rawDesc = []byte{ 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x44, 0x65, 0x66, 0x52, 0x09, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x44, 0x65, 0x66, 0x12, 0x1b, 0x0a, 0x09, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, - 0x08, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x49, 0x64, 0x22, 0xc7, 0x01, 0x0a, 0x11, 0x42, 0x75, + 0x08, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x49, 0x64, 0x22, 0xfd, 0x01, 0x0a, 0x11, 0x42, 0x75, 0x6c, 0x6b, 0x49, 0x6e, 0x73, 0x65, 0x72, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 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, 0x34, 0x0a, 0x09, @@ -3222,94 +3230,97 @@ var file_greptime_v1_region_server_proto_rawDesc = []byte{ 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x50, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x45, 0x78, 0x70, 0x72, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x14, 0x70, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, - 0x45, 0x78, 0x70, 0x72, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x42, 0x06, 0x0a, 0x04, 0x62, - 0x6f, 0x64, 0x79, 0x22, 0x46, 0x0a, 0x10, 0x4d, 0x69, 0x74, 0x6f, 0x4d, 0x61, 0x6e, 0x69, 0x66, - 0x65, 0x73, 0x74, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x32, 0x0a, 0x15, 0x64, 0x61, 0x74, 0x61, 0x5f, - 0x6d, 0x61, 0x6e, 0x69, 0x66, 0x65, 0x73, 0x74, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, - 0x18, 0x01, 0x20, 0x01, 0x28, 0x04, 0x52, 0x13, 0x64, 0x61, 0x74, 0x61, 0x4d, 0x61, 0x6e, 0x69, - 0x66, 0x65, 0x73, 0x74, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x22, 0x84, 0x01, 0x0a, 0x12, - 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x4d, 0x61, 0x6e, 0x69, 0x66, 0x65, 0x73, 0x74, 0x49, 0x6e, - 0x66, 0x6f, 0x12, 0x32, 0x0a, 0x15, 0x64, 0x61, 0x74, 0x61, 0x5f, 0x6d, 0x61, 0x6e, 0x69, 0x66, - 0x65, 0x73, 0x74, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, - 0x04, 0x52, 0x13, 0x64, 0x61, 0x74, 0x61, 0x4d, 0x61, 0x6e, 0x69, 0x66, 0x65, 0x73, 0x74, 0x56, - 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x3a, 0x0a, 0x19, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, - 0x74, 0x61, 0x5f, 0x6d, 0x61, 0x6e, 0x69, 0x66, 0x65, 0x73, 0x74, 0x5f, 0x76, 0x65, 0x72, 0x73, - 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x04, 0x52, 0x17, 0x6d, 0x65, 0x74, 0x61, 0x64, - 0x61, 0x74, 0x61, 0x4d, 0x61, 0x6e, 0x69, 0x66, 0x65, 0x73, 0x74, 0x56, 0x65, 0x72, 0x73, 0x69, - 0x6f, 0x6e, 0x22, 0xed, 0x01, 0x0a, 0x0b, 0x53, 0x79, 0x6e, 0x63, 0x52, 0x65, 0x71, 0x75, 0x65, - 0x73, 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, - 0x54, 0x0a, 0x12, 0x6d, 0x69, 0x74, 0x6f, 0x5f, 0x6d, 0x61, 0x6e, 0x69, 0x66, 0x65, 0x73, 0x74, - 0x5f, 0x69, 0x6e, 0x66, 0x6f, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x24, 0x2e, 0x67, 0x72, - 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, - 0x2e, 0x4d, 0x69, 0x74, 0x6f, 0x4d, 0x61, 0x6e, 0x69, 0x66, 0x65, 0x73, 0x74, 0x49, 0x6e, 0x66, - 0x6f, 0x48, 0x00, 0x52, 0x10, 0x6d, 0x69, 0x74, 0x6f, 0x4d, 0x61, 0x6e, 0x69, 0x66, 0x65, 0x73, - 0x74, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x5a, 0x0a, 0x14, 0x6d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x5f, - 0x6d, 0x61, 0x6e, 0x69, 0x66, 0x65, 0x73, 0x74, 0x5f, 0x69, 0x6e, 0x66, 0x6f, 0x18, 0x03, 0x20, - 0x01, 0x28, 0x0b, 0x32, 0x26, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, - 0x31, 0x2e, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x2e, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x4d, - 0x61, 0x6e, 0x69, 0x66, 0x65, 0x73, 0x74, 0x49, 0x6e, 0x66, 0x6f, 0x48, 0x00, 0x52, 0x12, 0x6d, + 0x45, 0x78, 0x70, 0x72, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x34, 0x0a, 0x16, 0x61, + 0x6c, 0x69, 0x67, 0x6e, 0x65, 0x64, 0x5f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x5f, 0x76, 0x65, + 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28, 0x04, 0x52, 0x14, 0x61, 0x6c, 0x69, + 0x67, 0x6e, 0x65, 0x64, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, + 0x6e, 0x42, 0x06, 0x0a, 0x04, 0x62, 0x6f, 0x64, 0x79, 0x22, 0x46, 0x0a, 0x10, 0x4d, 0x69, 0x74, + 0x6f, 0x4d, 0x61, 0x6e, 0x69, 0x66, 0x65, 0x73, 0x74, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x32, 0x0a, + 0x15, 0x64, 0x61, 0x74, 0x61, 0x5f, 0x6d, 0x61, 0x6e, 0x69, 0x66, 0x65, 0x73, 0x74, 0x5f, 0x76, + 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x04, 0x52, 0x13, 0x64, 0x61, + 0x74, 0x61, 0x4d, 0x61, 0x6e, 0x69, 0x66, 0x65, 0x73, 0x74, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, + 0x6e, 0x22, 0x84, 0x01, 0x0a, 0x12, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x4d, 0x61, 0x6e, 0x69, + 0x66, 0x65, 0x73, 0x74, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x32, 0x0a, 0x15, 0x64, 0x61, 0x74, 0x61, + 0x5f, 0x6d, 0x61, 0x6e, 0x69, 0x66, 0x65, 0x73, 0x74, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, + 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x04, 0x52, 0x13, 0x64, 0x61, 0x74, 0x61, 0x4d, 0x61, 0x6e, + 0x69, 0x66, 0x65, 0x73, 0x74, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x3a, 0x0a, 0x19, + 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x5f, 0x6d, 0x61, 0x6e, 0x69, 0x66, 0x65, 0x73, + 0x74, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x04, 0x52, + 0x17, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x4d, 0x61, 0x6e, 0x69, 0x66, 0x65, 0x73, + 0x74, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x22, 0xed, 0x01, 0x0a, 0x0b, 0x53, 0x79, 0x6e, + 0x63, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 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, 0x54, 0x0a, 0x12, 0x6d, 0x69, 0x74, 0x6f, 0x5f, 0x6d, 0x61, + 0x6e, 0x69, 0x66, 0x65, 0x73, 0x74, 0x5f, 0x69, 0x6e, 0x66, 0x6f, 0x18, 0x02, 0x20, 0x01, 0x28, + 0x0b, 0x32, 0x24, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, + 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x2e, 0x4d, 0x69, 0x74, 0x6f, 0x4d, 0x61, 0x6e, 0x69, 0x66, + 0x65, 0x73, 0x74, 0x49, 0x6e, 0x66, 0x6f, 0x48, 0x00, 0x52, 0x10, 0x6d, 0x69, 0x74, 0x6f, 0x4d, + 0x61, 0x6e, 0x69, 0x66, 0x65, 0x73, 0x74, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x5a, 0x0a, 0x14, 0x6d, + 0x65, 0x74, 0x72, 0x69, 0x63, 0x5f, 0x6d, 0x61, 0x6e, 0x69, 0x66, 0x65, 0x73, 0x74, 0x5f, 0x69, + 0x6e, 0x66, 0x6f, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x26, 0x2e, 0x67, 0x72, 0x65, 0x70, + 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x2e, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x4d, 0x61, 0x6e, 0x69, 0x66, 0x65, 0x73, 0x74, 0x49, 0x6e, 0x66, - 0x6f, 0x42, 0x0f, 0x0a, 0x0d, 0x6d, 0x61, 0x6e, 0x69, 0x66, 0x65, 0x73, 0x74, 0x5f, 0x69, 0x6e, - 0x66, 0x6f, 0x22, 0x34, 0x0a, 0x13, 0x4c, 0x69, 0x73, 0x74, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, - 0x74, 0x61, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1d, 0x0a, 0x0a, 0x72, 0x65, 0x67, - 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x04, 0x52, 0x09, 0x72, - 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x73, 0x22, 0x30, 0x0a, 0x11, 0x42, 0x75, 0x69, 0x6c, - 0x64, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 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, 0x22, 0x1f, 0x0a, 0x09, 0x46, 0x69, - 0x6c, 0x65, 0x4d, 0x65, 0x74, 0x61, 0x73, 0x12, 0x12, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, - 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x22, 0xb2, 0x01, 0x0a, 0x1b, - 0x41, 0x70, 0x70, 0x6c, 0x79, 0x53, 0x74, 0x61, 0x67, 0x69, 0x6e, 0x67, 0x4d, 0x61, 0x6e, 0x69, - 0x66, 0x65, 0x73, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 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, 0x25, 0x0a, 0x0e, 0x70, 0x61, 0x72, 0x74, - 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x65, 0x78, 0x70, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, - 0x52, 0x0d, 0x70, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x45, 0x78, 0x70, 0x72, 0x12, - 0x2a, 0x0a, 0x11, 0x63, 0x65, 0x6e, 0x74, 0x72, 0x61, 0x6c, 0x5f, 0x72, 0x65, 0x67, 0x69, 0x6f, - 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0f, 0x63, 0x65, 0x6e, 0x74, - 0x72, 0x61, 0x6c, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x12, 0x23, 0x0a, 0x0d, 0x6d, - 0x61, 0x6e, 0x69, 0x66, 0x65, 0x73, 0x74, 0x5f, 0x70, 0x61, 0x74, 0x68, 0x18, 0x04, 0x20, 0x01, - 0x28, 0x09, 0x52, 0x0c, 0x6d, 0x61, 0x6e, 0x69, 0x66, 0x65, 0x73, 0x74, 0x50, 0x61, 0x74, 0x68, - 0x22, 0xd3, 0x01, 0x0a, 0x16, 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x44, 0x79, 0x6e, 0x46, 0x69, - 0x6c, 0x74, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x19, 0x0a, 0x08, 0x71, - 0x75, 0x65, 0x72, 0x79, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x71, - 0x75, 0x65, 0x72, 0x79, 0x49, 0x64, 0x12, 0x43, 0x0a, 0x06, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, - 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x29, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, - 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x2e, 0x52, 0x65, 0x6d, 0x6f, - 0x74, 0x65, 0x44, 0x79, 0x6e, 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x55, 0x70, 0x64, 0x61, 0x74, - 0x65, 0x48, 0x00, 0x52, 0x06, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x12, 0x4f, 0x0a, 0x0a, 0x75, - 0x6e, 0x72, 0x65, 0x67, 0x69, 0x73, 0x74, 0x65, 0x72, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, - 0x2d, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x72, 0x65, - 0x67, 0x69, 0x6f, 0x6e, 0x2e, 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x44, 0x79, 0x6e, 0x46, 0x69, - 0x6c, 0x74, 0x65, 0x72, 0x55, 0x6e, 0x72, 0x65, 0x67, 0x69, 0x73, 0x74, 0x65, 0x72, 0x48, 0x00, - 0x52, 0x0a, 0x75, 0x6e, 0x72, 0x65, 0x67, 0x69, 0x73, 0x74, 0x65, 0x72, 0x42, 0x08, 0x0a, 0x06, - 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x8f, 0x01, 0x0a, 0x15, 0x52, 0x65, 0x6d, 0x6f, 0x74, - 0x65, 0x44, 0x79, 0x6e, 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, - 0x12, 0x1b, 0x0a, 0x09, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, - 0x01, 0x28, 0x09, 0x52, 0x08, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x49, 0x64, 0x12, 0x18, 0x0a, - 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x07, - 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x12, 0x1e, 0x0a, 0x0a, 0x67, 0x65, 0x6e, 0x65, 0x72, - 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0a, 0x67, 0x65, 0x6e, - 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x1f, 0x0a, 0x0b, 0x69, 0x73, 0x5f, 0x63, 0x6f, - 0x6d, 0x70, 0x6c, 0x65, 0x74, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0a, 0x69, 0x73, - 0x43, 0x6f, 0x6d, 0x70, 0x6c, 0x65, 0x74, 0x65, 0x22, 0x38, 0x0a, 0x19, 0x52, 0x65, 0x6d, 0x6f, - 0x74, 0x65, 0x44, 0x79, 0x6e, 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x55, 0x6e, 0x72, 0x65, 0x67, - 0x69, 0x73, 0x74, 0x65, 0x72, 0x12, 0x1b, 0x0a, 0x09, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x5f, - 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, - 0x49, 0x64, 0x32, 0x59, 0x0a, 0x06, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x12, 0x4f, 0x0a, 0x06, - 0x48, 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x12, 0x21, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, - 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x2e, 0x52, 0x65, 0x67, 0x69, - 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x22, 0x2e, 0x67, 0x72, 0x65, 0x70, - 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x2e, 0x52, - 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x42, 0x5d, 0x0a, - 0x15, 0x69, 0x6f, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, - 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x42, 0x06, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x5a, 0x3c, - 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, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x62, 0x06, 0x70, 0x72, - 0x6f, 0x74, 0x6f, 0x33, + 0x6f, 0x48, 0x00, 0x52, 0x12, 0x6d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x4d, 0x61, 0x6e, 0x69, 0x66, + 0x65, 0x73, 0x74, 0x49, 0x6e, 0x66, 0x6f, 0x42, 0x0f, 0x0a, 0x0d, 0x6d, 0x61, 0x6e, 0x69, 0x66, + 0x65, 0x73, 0x74, 0x5f, 0x69, 0x6e, 0x66, 0x6f, 0x22, 0x34, 0x0a, 0x13, 0x4c, 0x69, 0x73, 0x74, + 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, + 0x1d, 0x0a, 0x0a, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x73, 0x18, 0x01, 0x20, + 0x03, 0x28, 0x04, 0x52, 0x09, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x73, 0x22, 0x30, + 0x0a, 0x11, 0x42, 0x75, 0x69, 0x6c, 0x64, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x52, 0x65, 0x71, 0x75, + 0x65, 0x73, 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, + 0x22, 0x1f, 0x0a, 0x09, 0x46, 0x69, 0x6c, 0x65, 0x4d, 0x65, 0x74, 0x61, 0x73, 0x12, 0x12, 0x0a, + 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 0x64, 0x61, 0x74, + 0x61, 0x22, 0xb2, 0x01, 0x0a, 0x1b, 0x41, 0x70, 0x70, 0x6c, 0x79, 0x53, 0x74, 0x61, 0x67, 0x69, + 0x6e, 0x67, 0x4d, 0x61, 0x6e, 0x69, 0x66, 0x65, 0x73, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, + 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, 0x25, + 0x0a, 0x0e, 0x70, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x65, 0x78, 0x70, 0x72, + 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x70, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, + 0x6e, 0x45, 0x78, 0x70, 0x72, 0x12, 0x2a, 0x0a, 0x11, 0x63, 0x65, 0x6e, 0x74, 0x72, 0x61, 0x6c, + 0x5f, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x04, + 0x52, 0x0f, 0x63, 0x65, 0x6e, 0x74, 0x72, 0x61, 0x6c, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x49, + 0x64, 0x12, 0x23, 0x0a, 0x0d, 0x6d, 0x61, 0x6e, 0x69, 0x66, 0x65, 0x73, 0x74, 0x5f, 0x70, 0x61, + 0x74, 0x68, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x6d, 0x61, 0x6e, 0x69, 0x66, 0x65, + 0x73, 0x74, 0x50, 0x61, 0x74, 0x68, 0x22, 0xd3, 0x01, 0x0a, 0x16, 0x52, 0x65, 0x6d, 0x6f, 0x74, + 0x65, 0x44, 0x79, 0x6e, 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, + 0x74, 0x12, 0x19, 0x0a, 0x08, 0x71, 0x75, 0x65, 0x72, 0x79, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, + 0x01, 0x28, 0x09, 0x52, 0x07, 0x71, 0x75, 0x65, 0x72, 0x79, 0x49, 0x64, 0x12, 0x43, 0x0a, 0x06, + 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x29, 0x2e, 0x67, + 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x72, 0x65, 0x67, 0x69, 0x6f, + 0x6e, 0x2e, 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x44, 0x79, 0x6e, 0x46, 0x69, 0x6c, 0x74, 0x65, + 0x72, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x48, 0x00, 0x52, 0x06, 0x75, 0x70, 0x64, 0x61, 0x74, + 0x65, 0x12, 0x4f, 0x0a, 0x0a, 0x75, 0x6e, 0x72, 0x65, 0x67, 0x69, 0x73, 0x74, 0x65, 0x72, 0x18, + 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2d, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, + 0x2e, 0x76, 0x31, 0x2e, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x2e, 0x52, 0x65, 0x6d, 0x6f, 0x74, + 0x65, 0x44, 0x79, 0x6e, 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x55, 0x6e, 0x72, 0x65, 0x67, 0x69, + 0x73, 0x74, 0x65, 0x72, 0x48, 0x00, 0x52, 0x0a, 0x75, 0x6e, 0x72, 0x65, 0x67, 0x69, 0x73, 0x74, + 0x65, 0x72, 0x42, 0x08, 0x0a, 0x06, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x8f, 0x01, 0x0a, + 0x15, 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x44, 0x79, 0x6e, 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, + 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x12, 0x1b, 0x0a, 0x09, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, + 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x66, 0x69, 0x6c, 0x74, 0x65, + 0x72, 0x49, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x18, 0x02, + 0x20, 0x01, 0x28, 0x0c, 0x52, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x12, 0x1e, 0x0a, + 0x0a, 0x67, 0x65, 0x6e, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, + 0x04, 0x52, 0x0a, 0x67, 0x65, 0x6e, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x1f, 0x0a, + 0x0b, 0x69, 0x73, 0x5f, 0x63, 0x6f, 0x6d, 0x70, 0x6c, 0x65, 0x74, 0x65, 0x18, 0x04, 0x20, 0x01, + 0x28, 0x08, 0x52, 0x0a, 0x69, 0x73, 0x43, 0x6f, 0x6d, 0x70, 0x6c, 0x65, 0x74, 0x65, 0x22, 0x38, + 0x0a, 0x19, 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x44, 0x79, 0x6e, 0x46, 0x69, 0x6c, 0x74, 0x65, + 0x72, 0x55, 0x6e, 0x72, 0x65, 0x67, 0x69, 0x73, 0x74, 0x65, 0x72, 0x12, 0x1b, 0x0a, 0x09, 0x66, + 0x69, 0x6c, 0x74, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, + 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x49, 0x64, 0x32, 0x59, 0x0a, 0x06, 0x52, 0x65, 0x67, 0x69, + 0x6f, 0x6e, 0x12, 0x4f, 0x0a, 0x06, 0x48, 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x12, 0x21, 0x2e, 0x67, + 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x72, 0x65, 0x67, 0x69, 0x6f, + 0x6e, 0x2e, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, + 0x22, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x72, 0x65, + 0x67, 0x69, 0x6f, 0x6e, 0x2e, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, + 0x6e, 0x73, 0x65, 0x42, 0x5d, 0x0a, 0x15, 0x69, 0x6f, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, + 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x42, 0x06, 0x53, 0x65, + 0x72, 0x76, 0x65, 0x72, 0x5a, 0x3c, 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, 0x72, 0x65, 0x67, 0x69, + 0x6f, 0x6e, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, } var ( diff --git a/java/src/main/java/io/greptime/v1/region/Server.java b/java/src/main/java/io/greptime/v1/region/Server.java index 6ec8c0f..da1834e 100644 --- a/java/src/main/java/io/greptime/v1/region/Server.java +++ b/java/src/main/java/io/greptime/v1/region/Server.java @@ -30941,6 +30941,12 @@ java.lang.String defaultValue); */ io.greptime.v1.Common.PartitionExprVersionOrBuilder getPartitionExprVersionOrBuilder(); + /** + * uint64 aligned_schema_version = 4; + * @return The alignedSchemaVersion. + */ + long getAlignedSchemaVersion(); + public io.greptime.v1.region.Server.BulkInsertRequest.BodyCase getBodyCase(); } /** @@ -31024,6 +31030,11 @@ java.lang.String defaultValue); break; } + case 32: { + + alignedSchemaVersion_ = input.readUInt64(); + break; + } default: { if (!parseUnknownField( input, unknownFields, extensionRegistry, tag)) { @@ -31165,6 +31176,17 @@ java.lang.String defaultValue); return getPartitionExprVersion(); } + public static final int ALIGNED_SCHEMA_VERSION_FIELD_NUMBER = 4; + private long alignedSchemaVersion_; + /** + * uint64 aligned_schema_version = 4; + * @return The alignedSchemaVersion. + */ + @java.lang.Override + public long getAlignedSchemaVersion() { + return alignedSchemaVersion_; + } + private byte memoizedIsInitialized = -1; @java.lang.Override public final boolean isInitialized() { @@ -31188,6 +31210,9 @@ java.lang.String defaultValue); if (partitionExprVersion_ != null) { output.writeMessage(3, getPartitionExprVersion()); } + if (alignedSchemaVersion_ != 0L) { + output.writeUInt64(4, alignedSchemaVersion_); + } unknownFields.writeTo(output); } @@ -31209,6 +31234,10 @@ java.lang.String defaultValue); size += com.google.protobuf.CodedOutputStream .computeMessageSize(3, getPartitionExprVersion()); } + if (alignedSchemaVersion_ != 0L) { + size += com.google.protobuf.CodedOutputStream + .computeUInt64Size(4, alignedSchemaVersion_); + } size += unknownFields.getSerializedSize(); memoizedSize = size; return size; @@ -31231,6 +31260,8 @@ java.lang.String defaultValue); if (!getPartitionExprVersion() .equals(other.getPartitionExprVersion())) return false; } + if (getAlignedSchemaVersion() + != other.getAlignedSchemaVersion()) return false; if (!getBodyCase().equals(other.getBodyCase())) return false; switch (bodyCase_) { case 2: @@ -31258,6 +31289,9 @@ java.lang.String defaultValue); hash = (37 * hash) + PARTITION_EXPR_VERSION_FIELD_NUMBER; hash = (53 * hash) + getPartitionExprVersion().hashCode(); } + hash = (37 * hash) + ALIGNED_SCHEMA_VERSION_FIELD_NUMBER; + hash = (53 * hash) + com.google.protobuf.Internal.hashLong( + getAlignedSchemaVersion()); switch (bodyCase_) { case 2: hash = (37 * hash) + ARROW_IPC_FIELD_NUMBER; @@ -31411,6 +31445,8 @@ java.lang.String defaultValue); partitionExprVersion_ = null; partitionExprVersionBuilder_ = null; } + alignedSchemaVersion_ = 0L; + bodyCase_ = 0; body_ = null; return this; @@ -31452,6 +31488,7 @@ java.lang.String defaultValue); } else { result.partitionExprVersion_ = partitionExprVersionBuilder_.build(); } + result.alignedSchemaVersion_ = alignedSchemaVersion_; result.bodyCase_ = bodyCase_; onBuilt(); return result; @@ -31507,6 +31544,9 @@ java.lang.String defaultValue); if (other.hasPartitionExprVersion()) { mergePartitionExprVersion(other.getPartitionExprVersion()); } + if (other.getAlignedSchemaVersion() != 0L) { + setAlignedSchemaVersion(other.getAlignedSchemaVersion()); + } switch (other.getBodyCase()) { case ARROW_IPC: { mergeArrowIpc(other.getArrowIpc()); @@ -31851,6 +31891,37 @@ java.lang.String defaultValue); } return partitionExprVersionBuilder_; } + + private long alignedSchemaVersion_ ; + /** + * uint64 aligned_schema_version = 4; + * @return The alignedSchemaVersion. + */ + @java.lang.Override + public long getAlignedSchemaVersion() { + return alignedSchemaVersion_; + } + /** + * uint64 aligned_schema_version = 4; + * @param value The alignedSchemaVersion to set. + * @return This builder for chaining. + */ + public Builder setAlignedSchemaVersion(long value) { + + alignedSchemaVersion_ = value; + onChanged(); + return this; + } + /** + * uint64 aligned_schema_version = 4; + * @return This builder for chaining. + */ + public Builder clearAlignedSchemaVersion() { + + alignedSchemaVersion_ = 0L; + onChanged(); + return this; + } @java.lang.Override public final Builder setUnknownFields( final com.google.protobuf.UnknownFieldSet unknownFields) { @@ -39403,38 +39474,39 @@ java.lang.String defaultValue); "es\030\003 \001(\0132\027.greptime.v1.TimeRangesH\000B\006\n\004k" + "ind\"\005\n\003All\"P\n\017RegionColumnDef\022*\n\ncolumn_" + "def\030\001 \001(\0132\026.greptime.v1.ColumnDef\022\021\n\tcol" + - "umn_id\030\002 \001(\r\"\235\001\n\021BulkInsertRequest\022\021\n\tre" + + "umn_id\030\002 \001(\r\"\275\001\n\021BulkInsertRequest\022\021\n\tre" + "gion_id\030\001 \001(\004\022*\n\tarrow_ipc\030\002 \001(\0132\025.grept" + "ime.v1.ArrowIpcH\000\022A\n\026partition_expr_vers" + "ion\030\003 \001(\0132!.greptime.v1.PartitionExprVer" + - "sionB\006\n\004body\"1\n\020MitoManifestInfo\022\035\n\025data" + - "_manifest_version\030\001 \001(\004\"V\n\022MetricManifes" + - "tInfo\022\035\n\025data_manifest_version\030\001 \001(\004\022!\n\031" + - "metadata_manifest_version\030\002 \001(\004\"\275\001\n\013Sync" + - "Request\022\021\n\tregion_id\030\001 \001(\004\022B\n\022mito_manif" + - "est_info\030\002 \001(\0132$.greptime.v1.region.Mito" + - "ManifestInfoH\000\022F\n\024metric_manifest_info\030\003" + - " \001(\0132&.greptime.v1.region.MetricManifest" + - "InfoH\000B\017\n\rmanifest_info\")\n\023ListMetadataR" + - "equest\022\022\n\nregion_ids\030\001 \003(\004\"&\n\021BuildIndex" + - "Request\022\021\n\tregion_id\030\001 \001(\004\"\031\n\tFileMetas\022" + - "\014\n\004data\030\001 \001(\014\"z\n\033ApplyStagingManifestReq" + - "uest\022\021\n\tregion_id\030\001 \001(\004\022\026\n\016partition_exp" + - "r\030\002 \001(\t\022\031\n\021central_region_id\030\003 \001(\004\022\025\n\rma" + - "nifest_path\030\004 \001(\t\"\266\001\n\026RemoteDynFilterReq" + - "uest\022\020\n\010query_id\030\001 \001(\t\022;\n\006update\030\002 \001(\0132)" + - ".greptime.v1.region.RemoteDynFilterUpdat" + - "eH\000\022C\n\nunregister\030\003 \001(\0132-.greptime.v1.re" + - "gion.RemoteDynFilterUnregisterH\000B\010\n\006acti" + - "on\"d\n\025RemoteDynFilterUpdate\022\021\n\tfilter_id" + - "\030\001 \001(\t\022\017\n\007payload\030\002 \001(\014\022\022\n\ngeneration\030\003 " + - "\001(\004\022\023\n\013is_complete\030\004 \001(\010\".\n\031RemoteDynFil" + - "terUnregister\022\021\n\tfilter_id\030\001 \001(\t2Y\n\006Regi" + - "on\022O\n\006Handle\022!.greptime.v1.region.Region" + - "Request\032\".greptime.v1.region.RegionRespo" + - "nseB]\n\025io.greptime.v1.regionB\006ServerZ, + #[prost(uint64, tag = "4")] + pub aligned_schema_version: u64, #[prost(oneof = "bulk_insert_request::Body", tags = "2")] pub body: ::core::option::Option, } diff --git a/src/generated/greptime_grpc_desc.bin b/src/generated/greptime_grpc_desc.bin index 8346c36..2d2855b 100644 Binary files a/src/generated/greptime_grpc_desc.bin and b/src/generated/greptime_grpc_desc.bin differ