diff --git a/c++/greptime/v1/region/server.pb.cc b/c++/greptime/v1/region/server.pb.cc index 07d46a2a..8dfd6d2a 100644 --- a/c++/greptime/v1/region/server.pb.cc +++ b/c++/greptime/v1/region/server.pb.cc @@ -63,9 +63,21 @@ struct RegionRequestDefaultTypeInternal { }; }; PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 RegionRequestDefaultTypeInternal _RegionRequest_default_instance_; +PROTOBUF_CONSTEXPR RegionResponse_ExtensionEntry_DoNotUse::RegionResponse_ExtensionEntry_DoNotUse( + ::_pbi::ConstantInitialized) {} +struct RegionResponse_ExtensionEntry_DoNotUseDefaultTypeInternal { + PROTOBUF_CONSTEXPR RegionResponse_ExtensionEntry_DoNotUseDefaultTypeInternal() + : _instance(::_pbi::ConstantInitialized{}) {} + ~RegionResponse_ExtensionEntry_DoNotUseDefaultTypeInternal() {} + union { + RegionResponse_ExtensionEntry_DoNotUse _instance; + }; +}; +PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 RegionResponse_ExtensionEntry_DoNotUseDefaultTypeInternal _RegionResponse_ExtensionEntry_DoNotUse_default_instance_; PROTOBUF_CONSTEXPR RegionResponse::RegionResponse( ::_pbi::ConstantInitialized): _impl_{ - /*decltype(_impl_.header_)*/nullptr + /*decltype(_impl_.extension_)*/{::_pbi::ConstantInitialized()} + , /*decltype(_impl_.header_)*/nullptr , /*decltype(_impl_.affected_rows_)*/uint64_t{0u} , /*decltype(_impl_._cached_size_)*/{}} {} struct RegionResponseDefaultTypeInternal { @@ -393,7 +405,7 @@ PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORIT } // namespace region } // namespace v1 } // namespace greptime -static ::_pb::Metadata file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[27]; +static ::_pb::Metadata file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[28]; static constexpr ::_pb::EnumDescriptor const** file_level_enum_descriptors_greptime_2fv1_2fregion_2fserver_2eproto = nullptr; static constexpr ::_pb::ServiceDescriptor const** file_level_service_descriptors_greptime_2fv1_2fregion_2fserver_2eproto = nullptr; @@ -437,6 +449,16 @@ const uint32_t TableStruct_greptime_2fv1_2fregion_2fserver_2eproto::offsets[] PR ::_pbi::kInvalidFieldOffsetTag, ::_pbi::kInvalidFieldOffsetTag, PROTOBUF_FIELD_OFFSET(::greptime::v1::region::RegionRequest, _impl_.body_), + PROTOBUF_FIELD_OFFSET(::greptime::v1::region::RegionResponse_ExtensionEntry_DoNotUse, _has_bits_), + PROTOBUF_FIELD_OFFSET(::greptime::v1::region::RegionResponse_ExtensionEntry_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::region::RegionResponse_ExtensionEntry_DoNotUse, key_), + PROTOBUF_FIELD_OFFSET(::greptime::v1::region::RegionResponse_ExtensionEntry_DoNotUse, value_), + 0, + 1, ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::greptime::v1::region::RegionResponse, _internal_metadata_), ~0u, // no _extensions_ @@ -445,6 +467,7 @@ const uint32_t TableStruct_greptime_2fv1_2fregion_2fserver_2eproto::offsets[] PR ~0u, // no _inlined_string_donated_ PROTOBUF_FIELD_OFFSET(::greptime::v1::region::RegionResponse, _impl_.header_), PROTOBUF_FIELD_OFFSET(::greptime::v1::region::RegionResponse, _impl_.affected_rows_), + PROTOBUF_FIELD_OFFSET(::greptime::v1::region::RegionResponse, _impl_.extension_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::greptime::v1::region::InsertRequests, _internal_metadata_), ~0u, // no _extensions_ @@ -635,36 +658,38 @@ static const ::_pbi::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protode { 0, 8, -1, sizeof(::greptime::v1::region::RegionRequestHeader_TracingContextEntry_DoNotUse)}, { 10, -1, -1, sizeof(::greptime::v1::region::RegionRequestHeader)}, { 18, -1, -1, sizeof(::greptime::v1::region::RegionRequest)}, - { 39, -1, -1, sizeof(::greptime::v1::region::RegionResponse)}, - { 47, -1, -1, sizeof(::greptime::v1::region::InsertRequests)}, - { 54, -1, -1, sizeof(::greptime::v1::region::DeleteRequests)}, - { 61, -1, -1, sizeof(::greptime::v1::region::InsertRequest)}, - { 69, -1, -1, sizeof(::greptime::v1::region::DeleteRequest)}, - { 77, -1, -1, sizeof(::greptime::v1::region::QueryRequest)}, - { 86, -1, -1, sizeof(::greptime::v1::region::CreateRequests)}, - { 93, 101, -1, sizeof(::greptime::v1::region::CreateRequest_OptionsEntry_DoNotUse)}, - { 103, -1, -1, sizeof(::greptime::v1::region::CreateRequest)}, - { 115, -1, -1, sizeof(::greptime::v1::region::DropRequests)}, - { 122, -1, -1, sizeof(::greptime::v1::region::DropRequest)}, - { 129, 137, -1, sizeof(::greptime::v1::region::OpenRequest_OptionsEntry_DoNotUse)}, - { 139, -1, -1, sizeof(::greptime::v1::region::OpenRequest)}, - { 149, -1, -1, sizeof(::greptime::v1::region::CloseRequest)}, - { 156, -1, -1, sizeof(::greptime::v1::region::AlterRequests)}, - { 163, -1, -1, sizeof(::greptime::v1::region::AlterRequest)}, - { 174, -1, -1, sizeof(::greptime::v1::region::AddColumns)}, - { 181, -1, -1, sizeof(::greptime::v1::region::DropColumns)}, - { 188, -1, -1, sizeof(::greptime::v1::region::AddColumn)}, - { 196, -1, -1, sizeof(::greptime::v1::region::DropColumn)}, - { 203, -1, -1, sizeof(::greptime::v1::region::FlushRequest)}, - { 210, -1, -1, sizeof(::greptime::v1::region::CompactRequest)}, - { 217, -1, -1, sizeof(::greptime::v1::region::TruncateRequest)}, - { 224, -1, -1, sizeof(::greptime::v1::region::RegionColumnDef)}, + { 39, 47, -1, sizeof(::greptime::v1::region::RegionResponse_ExtensionEntry_DoNotUse)}, + { 49, -1, -1, sizeof(::greptime::v1::region::RegionResponse)}, + { 58, -1, -1, sizeof(::greptime::v1::region::InsertRequests)}, + { 65, -1, -1, sizeof(::greptime::v1::region::DeleteRequests)}, + { 72, -1, -1, sizeof(::greptime::v1::region::InsertRequest)}, + { 80, -1, -1, sizeof(::greptime::v1::region::DeleteRequest)}, + { 88, -1, -1, sizeof(::greptime::v1::region::QueryRequest)}, + { 97, -1, -1, sizeof(::greptime::v1::region::CreateRequests)}, + { 104, 112, -1, sizeof(::greptime::v1::region::CreateRequest_OptionsEntry_DoNotUse)}, + { 114, -1, -1, sizeof(::greptime::v1::region::CreateRequest)}, + { 126, -1, -1, sizeof(::greptime::v1::region::DropRequests)}, + { 133, -1, -1, sizeof(::greptime::v1::region::DropRequest)}, + { 140, 148, -1, sizeof(::greptime::v1::region::OpenRequest_OptionsEntry_DoNotUse)}, + { 150, -1, -1, sizeof(::greptime::v1::region::OpenRequest)}, + { 160, -1, -1, sizeof(::greptime::v1::region::CloseRequest)}, + { 167, -1, -1, sizeof(::greptime::v1::region::AlterRequests)}, + { 174, -1, -1, sizeof(::greptime::v1::region::AlterRequest)}, + { 185, -1, -1, sizeof(::greptime::v1::region::AddColumns)}, + { 192, -1, -1, sizeof(::greptime::v1::region::DropColumns)}, + { 199, -1, -1, sizeof(::greptime::v1::region::AddColumn)}, + { 207, -1, -1, sizeof(::greptime::v1::region::DropColumn)}, + { 214, -1, -1, sizeof(::greptime::v1::region::FlushRequest)}, + { 221, -1, -1, sizeof(::greptime::v1::region::CompactRequest)}, + { 228, -1, -1, sizeof(::greptime::v1::region::TruncateRequest)}, + { 235, -1, -1, sizeof(::greptime::v1::region::RegionColumnDef)}, }; static const ::_pb::Message* const file_default_instances[] = { &::greptime::v1::region::_RegionRequestHeader_TracingContextEntry_DoNotUse_default_instance_._instance, &::greptime::v1::region::_RegionRequestHeader_default_instance_._instance, &::greptime::v1::region::_RegionRequest_default_instance_._instance, + &::greptime::v1::region::_RegionResponse_ExtensionEntry_DoNotUse_default_instance_._instance, &::greptime::v1::region::_RegionResponse_default_instance_._instance, &::greptime::v1::region::_InsertRequests_default_instance_._instance, &::greptime::v1::region::_DeleteRequests_default_instance_._instance, @@ -718,58 +743,61 @@ const char descriptor_table_protodef_greptime_2fv1_2fregion_2fserver_2eproto[] P " \001(\0132\".greptime.v1.region.CreateRequests" "H\000\0221\n\005drops\030\016 \001(\0132 .greptime.v1.region.D" "ropRequestsH\000\0223\n\006alters\030\017 \001(\0132!.greptime" - ".v1.region.AlterRequestsH\000B\006\n\004body\"T\n\016Re" - "gionResponse\022+\n\006header\030\001 \001(\0132\033.greptime." - "v1.ResponseHeader\022\025\n\raffected_rows\030\002 \001(\004" - "\"E\n\016InsertRequests\0223\n\010requests\030\001 \003(\0132!.g" - "reptime.v1.region.InsertRequest\"E\n\016Delet" - "eRequests\0223\n\010requests\030\001 \003(\0132!.greptime.v" - "1.region.DeleteRequest\"C\n\rInsertRequest\022" - "\021\n\tregion_id\030\001 \001(\004\022\037\n\004rows\030\002 \001(\0132\021.grept" - "ime.v1.Rows\"C\n\rDeleteRequest\022\021\n\tregion_i" - "d\030\001 \001(\004\022\037\n\004rows\030\002 \001(\0132\021.greptime.v1.Rows" - "\"h\n\014QueryRequest\0227\n\006header\030\001 \001(\0132\'.grept" - "ime.v1.region.RegionRequestHeader\022\021\n\treg" - "ion_id\030\002 \001(\004\022\014\n\004plan\030\003 \001(\014\"E\n\016CreateRequ" - "ests\0223\n\010requests\030\001 \003(\0132!.greptime.v1.reg" - "ion.CreateRequest\"\200\002\n\rCreateRequest\022\021\n\tr" - "egion_id\030\001 \001(\004\022\016\n\006engine\030\002 \001(\t\0228\n\013column" - "_defs\030\003 \003(\0132#.greptime.v1.region.RegionC" - "olumnDef\022\023\n\013primary_key\030\004 \003(\r\022\014\n\004path\030\005 " - "\001(\t\022\?\n\007options\030\006 \003(\0132..greptime.v1.regio" - "n.CreateRequest.OptionsEntry\032.\n\014OptionsE" - "ntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\"A\n\014" - "DropRequests\0221\n\010requests\030\001 \003(\0132\037.greptim" - "e.v1.region.DropRequest\" \n\013DropRequest\022\021" - "\n\tregion_id\030\001 \001(\004\"\255\001\n\013OpenRequest\022\021\n\treg" - "ion_id\030\001 \001(\004\022\016\n\006engine\030\002 \001(\t\022\014\n\004path\030\003 \001" - "(\t\022=\n\007options\030\004 \003(\0132,.greptime.v1.region" - ".OpenRequest.OptionsEntry\032.\n\014OptionsEntr" - "y\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\"!\n\014Clo" - "seRequest\022\021\n\tregion_id\030\001 \001(\004\"C\n\rAlterReq" - "uests\0222\n\010requests\030\001 \003(\0132 .greptime.v1.re" - "gion.AlterRequest\"\261\001\n\014AlterRequest\022\021\n\tre" - "gion_id\030\001 \001(\004\0225\n\013add_columns\030\002 \001(\0132\036.gre" - "ptime.v1.region.AddColumnsH\000\0227\n\014drop_col" - "umns\030\003 \001(\0132\037.greptime.v1.region.DropColu" - "mnsH\000\022\026\n\016schema_version\030\004 \001(\004B\006\n\004kind\"@\n" - "\nAddColumns\0222\n\013add_columns\030\001 \003(\0132\035.grept" - "ime.v1.region.AddColumn\"C\n\013DropColumns\0224" - "\n\014drop_columns\030\001 \003(\0132\036.greptime.v1.regio" - "n.DropColumn\"v\n\tAddColumn\0227\n\ncolumn_def\030" - "\001 \001(\0132#.greptime.v1.region.RegionColumnD" - "ef\0220\n\010location\030\003 \001(\0132\036.greptime.v1.AddCo" - "lumnLocation\"\032\n\nDropColumn\022\014\n\004name\030\001 \001(\t" - "\"!\n\014FlushRequest\022\021\n\tregion_id\030\001 \001(\004\"#\n\016C" - "ompactRequest\022\021\n\tregion_id\030\001 \001(\004\"$\n\017Trun" - "cateRequest\022\021\n\tregion_id\030\001 \001(\004\"P\n\017Region" - "ColumnDef\022*\n\ncolumn_def\030\001 \001(\0132\026.greptime" - ".v1.ColumnDef\022\021\n\tcolumn_id\030\002 \001(\r2Y\n\006Regi" - "on\022O\n\006Handle\022!.greptime.v1.region.Region" - "Request\032\".greptime.v1.region.RegionRespo" - "nseB]\n\025io.greptime.v1.regionB\006ServerZOwnCustomDestructor(this, &RegionResponse::ArenaDtor); + } // @@protoc_insertion_point(arena_constructor:greptime.v1.region.RegionResponse) } RegionResponse::RegionResponse(const RegionResponse& from) : ::PROTOBUF_NAMESPACE_ID::Message() { RegionResponse* const _this = this; (void)_this; new (&_impl_) Impl_{ - decltype(_impl_.header_){nullptr} + /*decltype(_impl_.extension_)*/{} + , decltype(_impl_.header_){nullptr} , decltype(_impl_.affected_rows_){} , /*decltype(_impl_._cached_size_)*/{}}; _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); + _this->_impl_.extension_.MergeFrom(from._impl_.extension_); if (from._internal_has_header()) { _this->_impl_.header_ = new ::greptime::v1::ResponseHeader(*from._impl_.header_); } @@ -2109,7 +2156,8 @@ inline void RegionResponse::SharedCtor( (void)arena; (void)is_message_owned; new (&_impl_) Impl_{ - decltype(_impl_.header_){nullptr} + /*decltype(_impl_.extension_)*/{::_pbi::ArenaInitialized(), arena} + , decltype(_impl_.header_){nullptr} , decltype(_impl_.affected_rows_){uint64_t{0u}} , /*decltype(_impl_._cached_size_)*/{} }; @@ -2119,6 +2167,7 @@ RegionResponse::~RegionResponse() { // @@protoc_insertion_point(destructor:greptime.v1.region.RegionResponse) if (auto *arena = _internal_metadata_.DeleteReturnArena<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>()) { (void)arena; + ArenaDtor(this); return; } SharedDtor(); @@ -2126,9 +2175,15 @@ RegionResponse::~RegionResponse() { inline void RegionResponse::SharedDtor() { GOOGLE_DCHECK(GetArenaForAllocation() == nullptr); + _impl_.extension_.Destruct(); + _impl_.extension_.~MapField(); if (this != internal_default_instance()) delete _impl_.header_; } +void RegionResponse::ArenaDtor(void* object) { + RegionResponse* _this = reinterpret_cast< RegionResponse* >(object); + _this->_impl_.extension_.Destruct(); +} void RegionResponse::SetCachedSize(int size) const { _impl_._cached_size_.Set(size); } @@ -2139,6 +2194,7 @@ void RegionResponse::Clear() { // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; + _impl_.extension_.Clear(); if (GetArenaForAllocation() == nullptr && _impl_.header_ != nullptr) { delete _impl_.header_; } @@ -2169,6 +2225,19 @@ const char* RegionResponse::_InternalParse(const char* ptr, ::_pbi::ParseContext } else goto handle_unusual; continue; + // map extension = 3; + case 3: + if (PROTOBUF_PREDICT_TRUE(static_cast(tag) == 26)) { + ptr -= 1; + do { + ptr += 1; + ptr = ctx->ParseMessage(&_impl_.extension_, ptr); + CHK_(ptr); + if (!ctx->DataAvailable(ptr)) break; + } while (::PROTOBUF_NAMESPACE_ID::internal::ExpectTag<26>(ptr)); + } else + goto handle_unusual; + continue; default: goto handle_unusual; } // switch @@ -2211,6 +2280,32 @@ uint8_t* RegionResponse::_InternalSerialize( target = ::_pbi::WireFormatLite::WriteUInt64ToArray(2, this->_internal_affected_rows(), target); } + // map extension = 3; + if (!this->_internal_extension().empty()) { + using MapType = ::_pb::Map; + using WireHelper = RegionResponse_ExtensionEntry_DoNotUse::Funcs; + const auto& map_field = this->_internal_extension(); + auto check_utf8 = [](const MapType::value_type& entry) { + (void)entry; + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( + entry.first.data(), static_cast(entry.first.length()), + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, + "greptime.v1.region.RegionResponse.ExtensionEntry.key"); + }; + + if (stream->IsSerializationDeterministic() && map_field.size() > 1) { + for (const auto& entry : ::_pbi::MapSorterPtr(map_field)) { + target = WireHelper::InternalSerialize(3, entry.first, entry.second, target, stream); + check_utf8(entry); + } + } else { + for (const auto& entry : map_field) { + target = WireHelper::InternalSerialize(3, entry.first, entry.second, target, stream); + check_utf8(entry); + } + } + } + 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); @@ -2227,6 +2322,15 @@ size_t RegionResponse::ByteSizeLong() const { // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; + // map extension = 3; + total_size += 1 * + ::PROTOBUF_NAMESPACE_ID::internal::FromIntSize(this->_internal_extension_size()); + for (::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >::const_iterator + it = this->_internal_extension().begin(); + it != this->_internal_extension().end(); ++it) { + total_size += RegionResponse_ExtensionEntry_DoNotUse::Funcs::ByteSizeLong(it->first, it->second); + } + // .greptime.v1.ResponseHeader header = 1; if (this->_internal_has_header()) { total_size += 1 + @@ -2257,6 +2361,7 @@ void RegionResponse::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const : uint32_t cached_has_bits = 0; (void) cached_has_bits; + _this->_impl_.extension_.MergeFrom(from._impl_.extension_); if (from._internal_has_header()) { _this->_internal_mutable_header()->::greptime::v1::ResponseHeader::MergeFrom( from._internal_header()); @@ -2281,6 +2386,7 @@ bool RegionResponse::IsInitialized() const { void RegionResponse::InternalSwap(RegionResponse* other) { using std::swap; _internal_metadata_.InternalSwap(&other->_internal_metadata_); + _impl_.extension_.InternalSwap(&other->_impl_.extension_); ::PROTOBUF_NAMESPACE_ID::internal::memswap< PROTOBUF_FIELD_OFFSET(RegionResponse, _impl_.affected_rows_) + sizeof(RegionResponse::_impl_.affected_rows_) @@ -2292,7 +2398,7 @@ void RegionResponse::InternalSwap(RegionResponse* other) { ::PROTOBUF_NAMESPACE_ID::Metadata RegionResponse::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_getter, &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, - file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[3]); + file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[4]); } // =================================================================== @@ -2477,7 +2583,7 @@ void InsertRequests::InternalSwap(InsertRequests* other) { ::PROTOBUF_NAMESPACE_ID::Metadata InsertRequests::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_getter, &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, - file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[4]); + file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[5]); } // =================================================================== @@ -2662,7 +2768,7 @@ void DeleteRequests::InternalSwap(DeleteRequests* other) { ::PROTOBUF_NAMESPACE_ID::Metadata DeleteRequests::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_getter, &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, - file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[5]); + file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[6]); } // =================================================================== @@ -2892,7 +2998,7 @@ void InsertRequest::InternalSwap(InsertRequest* other) { ::PROTOBUF_NAMESPACE_ID::Metadata InsertRequest::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_getter, &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, - file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[6]); + file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[7]); } // =================================================================== @@ -3122,7 +3228,7 @@ void DeleteRequest::InternalSwap(DeleteRequest* other) { ::PROTOBUF_NAMESPACE_ID::Metadata DeleteRequest::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_getter, &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, - file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[7]); + file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[8]); } // =================================================================== @@ -3393,7 +3499,7 @@ void QueryRequest::InternalSwap(QueryRequest* other) { ::PROTOBUF_NAMESPACE_ID::Metadata QueryRequest::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_getter, &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, - file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[8]); + file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[9]); } // =================================================================== @@ -3578,7 +3684,7 @@ void CreateRequests::InternalSwap(CreateRequests* other) { ::PROTOBUF_NAMESPACE_ID::Metadata CreateRequests::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_getter, &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, - file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[9]); + file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[10]); } // =================================================================== @@ -3592,7 +3698,7 @@ void CreateRequest_OptionsEntry_DoNotUse::MergeFrom(const CreateRequest_OptionsE ::PROTOBUF_NAMESPACE_ID::Metadata CreateRequest_OptionsEntry_DoNotUse::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_getter, &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, - file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[10]); + file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[11]); } // =================================================================== @@ -4016,7 +4122,7 @@ void CreateRequest::InternalSwap(CreateRequest* other) { ::PROTOBUF_NAMESPACE_ID::Metadata CreateRequest::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_getter, &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, - file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[11]); + file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[12]); } // =================================================================== @@ -4201,7 +4307,7 @@ void DropRequests::InternalSwap(DropRequests* other) { ::PROTOBUF_NAMESPACE_ID::Metadata DropRequests::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_getter, &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, - file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[12]); + file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[13]); } // =================================================================== @@ -4379,7 +4485,7 @@ void DropRequest::InternalSwap(DropRequest* other) { ::PROTOBUF_NAMESPACE_ID::Metadata DropRequest::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_getter, &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, - file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[13]); + file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[14]); } // =================================================================== @@ -4393,7 +4499,7 @@ void OpenRequest_OptionsEntry_DoNotUse::MergeFrom(const OpenRequest_OptionsEntry ::PROTOBUF_NAMESPACE_ID::Metadata OpenRequest_OptionsEntry_DoNotUse::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_getter, &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, - file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[14]); + file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[15]); } // =================================================================== @@ -4741,7 +4847,7 @@ void OpenRequest::InternalSwap(OpenRequest* other) { ::PROTOBUF_NAMESPACE_ID::Metadata OpenRequest::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_getter, &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, - file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[15]); + file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[16]); } // =================================================================== @@ -4919,7 +5025,7 @@ void CloseRequest::InternalSwap(CloseRequest* other) { ::PROTOBUF_NAMESPACE_ID::Metadata CloseRequest::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_getter, &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, - file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[16]); + file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[17]); } // =================================================================== @@ -5104,7 +5210,7 @@ void AlterRequests::InternalSwap(AlterRequests* other) { ::PROTOBUF_NAMESPACE_ID::Metadata AlterRequests::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_getter, &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, - file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[17]); + file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[18]); } // =================================================================== @@ -5469,7 +5575,7 @@ void AlterRequest::InternalSwap(AlterRequest* other) { ::PROTOBUF_NAMESPACE_ID::Metadata AlterRequest::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_getter, &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, - file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[18]); + file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[19]); } // =================================================================== @@ -5654,7 +5760,7 @@ void AddColumns::InternalSwap(AddColumns* other) { ::PROTOBUF_NAMESPACE_ID::Metadata AddColumns::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_getter, &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, - file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[19]); + file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[20]); } // =================================================================== @@ -5839,7 +5945,7 @@ void DropColumns::InternalSwap(DropColumns* other) { ::PROTOBUF_NAMESPACE_ID::Metadata DropColumns::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_getter, &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, - file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[20]); + file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[21]); } // =================================================================== @@ -6084,7 +6190,7 @@ void AddColumn::InternalSwap(AddColumn* other) { ::PROTOBUF_NAMESPACE_ID::Metadata AddColumn::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_getter, &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, - file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[21]); + file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[22]); } // =================================================================== @@ -6287,7 +6393,7 @@ void DropColumn::InternalSwap(DropColumn* other) { ::PROTOBUF_NAMESPACE_ID::Metadata DropColumn::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_getter, &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, - file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[22]); + file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[23]); } // =================================================================== @@ -6465,7 +6571,7 @@ void FlushRequest::InternalSwap(FlushRequest* other) { ::PROTOBUF_NAMESPACE_ID::Metadata FlushRequest::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_getter, &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, - file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[23]); + file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[24]); } // =================================================================== @@ -6643,7 +6749,7 @@ void CompactRequest::InternalSwap(CompactRequest* other) { ::PROTOBUF_NAMESPACE_ID::Metadata CompactRequest::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_getter, &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, - file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[24]); + file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[25]); } // =================================================================== @@ -6821,7 +6927,7 @@ void TruncateRequest::InternalSwap(TruncateRequest* other) { ::PROTOBUF_NAMESPACE_ID::Metadata TruncateRequest::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_getter, &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, - file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[25]); + file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[26]); } // =================================================================== @@ -7051,7 +7157,7 @@ void RegionColumnDef::InternalSwap(RegionColumnDef* other) { ::PROTOBUF_NAMESPACE_ID::Metadata RegionColumnDef::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_getter, &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, - file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[26]); + file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[27]); } // @@protoc_insertion_point(namespace_scope) @@ -7071,6 +7177,10 @@ template<> PROTOBUF_NOINLINE ::greptime::v1::region::RegionRequest* Arena::CreateMaybeMessage< ::greptime::v1::region::RegionRequest >(Arena* arena) { return Arena::CreateMessageInternal< ::greptime::v1::region::RegionRequest >(arena); } +template<> PROTOBUF_NOINLINE ::greptime::v1::region::RegionResponse_ExtensionEntry_DoNotUse* +Arena::CreateMaybeMessage< ::greptime::v1::region::RegionResponse_ExtensionEntry_DoNotUse >(Arena* arena) { + return Arena::CreateMessageInternal< ::greptime::v1::region::RegionResponse_ExtensionEntry_DoNotUse >(arena); +} template<> PROTOBUF_NOINLINE ::greptime::v1::region::RegionResponse* Arena::CreateMaybeMessage< ::greptime::v1::region::RegionResponse >(Arena* arena) { return Arena::CreateMessageInternal< ::greptime::v1::region::RegionResponse >(arena); diff --git a/c++/greptime/v1/region/server.pb.h b/c++/greptime/v1/region/server.pb.h index 3955b5d4..bff44e20 100644 --- a/c++/greptime/v1/region/server.pb.h +++ b/c++/greptime/v1/region/server.pb.h @@ -131,6 +131,9 @@ extern RegionRequestHeader_TracingContextEntry_DoNotUseDefaultTypeInternal _Regi class RegionResponse; struct RegionResponseDefaultTypeInternal; extern RegionResponseDefaultTypeInternal _RegionResponse_default_instance_; +class RegionResponse_ExtensionEntry_DoNotUse; +struct RegionResponse_ExtensionEntry_DoNotUseDefaultTypeInternal; +extern RegionResponse_ExtensionEntry_DoNotUseDefaultTypeInternal _RegionResponse_ExtensionEntry_DoNotUse_default_instance_; class TruncateRequest; struct TruncateRequestDefaultTypeInternal; extern TruncateRequestDefaultTypeInternal _TruncateRequest_default_instance_; @@ -164,6 +167,7 @@ template<> ::greptime::v1::region::RegionRequest* Arena::CreateMaybeMessage<::gr template<> ::greptime::v1::region::RegionRequestHeader* Arena::CreateMaybeMessage<::greptime::v1::region::RegionRequestHeader>(Arena*); template<> ::greptime::v1::region::RegionRequestHeader_TracingContextEntry_DoNotUse* Arena::CreateMaybeMessage<::greptime::v1::region::RegionRequestHeader_TracingContextEntry_DoNotUse>(Arena*); template<> ::greptime::v1::region::RegionResponse* Arena::CreateMaybeMessage<::greptime::v1::region::RegionResponse>(Arena*); +template<> ::greptime::v1::region::RegionResponse_ExtensionEntry_DoNotUse* Arena::CreateMaybeMessage<::greptime::v1::region::RegionResponse_ExtensionEntry_DoNotUse>(Arena*); template<> ::greptime::v1::region::TruncateRequest* Arena::CreateMaybeMessage<::greptime::v1::region::TruncateRequest>(Arena*); PROTOBUF_NAMESPACE_CLOSE namespace greptime { @@ -837,6 +841,32 @@ class RegionRequest final : }; // ------------------------------------------------------------------- +class RegionResponse_ExtensionEntry_DoNotUse : public ::PROTOBUF_NAMESPACE_ID::internal::MapEntry { +public: + typedef ::PROTOBUF_NAMESPACE_ID::internal::MapEntry SuperType; + RegionResponse_ExtensionEntry_DoNotUse(); + explicit PROTOBUF_CONSTEXPR RegionResponse_ExtensionEntry_DoNotUse( + ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized); + explicit RegionResponse_ExtensionEntry_DoNotUse(::PROTOBUF_NAMESPACE_ID::Arena* arena); + void MergeFrom(const RegionResponse_ExtensionEntry_DoNotUse& other); + static const RegionResponse_ExtensionEntry_DoNotUse* internal_default_instance() { return reinterpret_cast(&_RegionResponse_ExtensionEntry_DoNotUse_default_instance_); } + static bool ValidateKey(std::string* s) { + return ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(s->data(), static_cast(s->size()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE, "greptime.v1.region.RegionResponse.ExtensionEntry.key"); + } + static bool ValidateValue(void*) { return true; } + using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom; + ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final; + friend struct ::TableStruct_greptime_2fv1_2fregion_2fserver_2eproto; +}; + +// ------------------------------------------------------------------- + class RegionResponse final : public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:greptime.v1.region.RegionResponse) */ { public: @@ -885,7 +915,7 @@ class RegionResponse final : &_RegionResponse_default_instance_); } static constexpr int kIndexInFileMessages = - 3; + 4; friend void swap(RegionResponse& a, RegionResponse& b) { a.Swap(&b); @@ -946,6 +976,8 @@ class RegionResponse final : protected: explicit RegionResponse(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned = false); + private: + static void ArenaDtor(void* object); public: static const ClassData _class_data_; @@ -955,12 +987,31 @@ class RegionResponse final : // nested types ---------------------------------------------------- + // accessors ------------------------------------------------------- enum : int { + kExtensionFieldNumber = 3, kHeaderFieldNumber = 1, kAffectedRowsFieldNumber = 2, }; + // map extension = 3; + int extension_size() const; + private: + int _internal_extension_size() const; + public: + void clear_extension(); + private: + const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >& + _internal_extension() const; + ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >* + _internal_mutable_extension(); + public: + const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >& + extension() const; + ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >* + mutable_extension(); + // .greptime.v1.ResponseHeader header = 1; bool has_header() const; private: @@ -996,6 +1047,11 @@ class RegionResponse final : typedef void InternalArenaConstructable_; typedef void DestructorSkippable_; struct Impl_ { + ::PROTOBUF_NAMESPACE_ID::internal::MapField< + RegionResponse_ExtensionEntry_DoNotUse, + std::string, std::string, + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING, + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_BYTES> extension_; ::greptime::v1::ResponseHeader* header_; uint64_t affected_rows_; mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; @@ -1053,7 +1109,7 @@ class InsertRequests final : &_InsertRequests_default_instance_); } static constexpr int kIndexInFileMessages = - 4; + 5; friend void swap(InsertRequests& a, InsertRequests& b) { a.Swap(&b); @@ -1210,7 +1266,7 @@ class DeleteRequests final : &_DeleteRequests_default_instance_); } static constexpr int kIndexInFileMessages = - 5; + 6; friend void swap(DeleteRequests& a, DeleteRequests& b) { a.Swap(&b); @@ -1367,7 +1423,7 @@ class InsertRequest final : &_InsertRequest_default_instance_); } static constexpr int kIndexInFileMessages = - 6; + 7; friend void swap(InsertRequest& a, InsertRequest& b) { a.Swap(&b); @@ -1535,7 +1591,7 @@ class DeleteRequest final : &_DeleteRequest_default_instance_); } static constexpr int kIndexInFileMessages = - 7; + 8; friend void swap(DeleteRequest& a, DeleteRequest& b) { a.Swap(&b); @@ -1703,7 +1759,7 @@ class QueryRequest final : &_QueryRequest_default_instance_); } static constexpr int kIndexInFileMessages = - 8; + 9; friend void swap(QueryRequest& a, QueryRequest& b) { a.Swap(&b); @@ -1887,7 +1943,7 @@ class CreateRequests final : &_CreateRequests_default_instance_); } static constexpr int kIndexInFileMessages = - 9; + 10; friend void swap(CreateRequests& a, CreateRequests& b) { a.Swap(&b); @@ -2072,7 +2128,7 @@ class CreateRequest final : &_CreateRequest_default_instance_); } static constexpr int kIndexInFileMessages = - 11; + 12; friend void swap(CreateRequest& a, CreateRequest& b) { a.Swap(&b); @@ -2323,7 +2379,7 @@ class DropRequests final : &_DropRequests_default_instance_); } static constexpr int kIndexInFileMessages = - 12; + 13; friend void swap(DropRequests& a, DropRequests& b) { a.Swap(&b); @@ -2480,7 +2536,7 @@ class DropRequest final : &_DropRequest_default_instance_); } static constexpr int kIndexInFileMessages = - 13; + 14; friend void swap(DropRequest& a, DropRequest& b) { a.Swap(&b); @@ -2656,7 +2712,7 @@ class OpenRequest final : &_OpenRequest_default_instance_); } static constexpr int kIndexInFileMessages = - 15; + 16; friend void swap(OpenRequest& a, OpenRequest& b) { a.Swap(&b); @@ -2862,7 +2918,7 @@ class CloseRequest final : &_CloseRequest_default_instance_); } static constexpr int kIndexInFileMessages = - 16; + 17; friend void swap(CloseRequest& a, CloseRequest& b) { a.Swap(&b); @@ -3010,7 +3066,7 @@ class AlterRequests final : &_AlterRequests_default_instance_); } static constexpr int kIndexInFileMessages = - 17; + 18; friend void swap(AlterRequests& a, AlterRequests& b) { a.Swap(&b); @@ -3173,7 +3229,7 @@ class AlterRequest final : &_AlterRequest_default_instance_); } static constexpr int kIndexInFileMessages = - 18; + 19; friend void swap(AlterRequest& a, AlterRequest& b) { a.Swap(&b); @@ -3385,7 +3441,7 @@ class AddColumns final : &_AddColumns_default_instance_); } static constexpr int kIndexInFileMessages = - 19; + 20; friend void swap(AddColumns& a, AddColumns& b) { a.Swap(&b); @@ -3542,7 +3598,7 @@ class DropColumns final : &_DropColumns_default_instance_); } static constexpr int kIndexInFileMessages = - 20; + 21; friend void swap(DropColumns& a, DropColumns& b) { a.Swap(&b); @@ -3699,7 +3755,7 @@ class AddColumn final : &_AddColumn_default_instance_); } static constexpr int kIndexInFileMessages = - 21; + 22; friend void swap(AddColumn& a, AddColumn& b) { a.Swap(&b); @@ -3876,7 +3932,7 @@ class DropColumn final : &_DropColumn_default_instance_); } static constexpr int kIndexInFileMessages = - 22; + 23; friend void swap(DropColumn& a, DropColumn& b) { a.Swap(&b); @@ -4029,7 +4085,7 @@ class FlushRequest final : &_FlushRequest_default_instance_); } static constexpr int kIndexInFileMessages = - 23; + 24; friend void swap(FlushRequest& a, FlushRequest& b) { a.Swap(&b); @@ -4177,7 +4233,7 @@ class CompactRequest final : &_CompactRequest_default_instance_); } static constexpr int kIndexInFileMessages = - 24; + 25; friend void swap(CompactRequest& a, CompactRequest& b) { a.Swap(&b); @@ -4325,7 +4381,7 @@ class TruncateRequest final : &_TruncateRequest_default_instance_); } static constexpr int kIndexInFileMessages = - 25; + 26; friend void swap(TruncateRequest& a, TruncateRequest& b) { a.Swap(&b); @@ -4473,7 +4529,7 @@ class RegionColumnDef final : &_RegionColumnDef_default_instance_); } static constexpr int kIndexInFileMessages = - 26; + 27; friend void swap(RegionColumnDef& a, RegionColumnDef& b) { a.Swap(&b); @@ -5750,6 +5806,8 @@ inline RegionRequest::BodyCase RegionRequest::body_case() const { } // ------------------------------------------------------------------- +// ------------------------------------------------------------------- + // RegionResponse // .greptime.v1.ResponseHeader header = 1; @@ -5857,6 +5915,35 @@ inline void RegionResponse::set_affected_rows(uint64_t value) { // @@protoc_insertion_point(field_set:greptime.v1.region.RegionResponse.affected_rows) } +// map extension = 3; +inline int RegionResponse::_internal_extension_size() const { + return _impl_.extension_.size(); +} +inline int RegionResponse::extension_size() const { + return _internal_extension_size(); +} +inline void RegionResponse::clear_extension() { + _impl_.extension_.Clear(); +} +inline const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >& +RegionResponse::_internal_extension() const { + return _impl_.extension_.GetMap(); +} +inline const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >& +RegionResponse::extension() const { + // @@protoc_insertion_point(field_map:greptime.v1.region.RegionResponse.extension) + return _internal_extension(); +} +inline ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >* +RegionResponse::_internal_mutable_extension() { + return _impl_.extension_.MutableMap(); +} +inline ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >* +RegionResponse::mutable_extension() { + // @@protoc_insertion_point(field_mutable_map:greptime.v1.region.RegionResponse.extension) + return _internal_mutable_extension(); +} + // ------------------------------------------------------------------- // InsertRequests @@ -7662,6 +7749,8 @@ inline void RegionColumnDef::set_column_id(uint32_t value) { // ------------------------------------------------------------------- +// ------------------------------------------------------------------- + // @@protoc_insertion_point(namespace_scope) 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 f3965f87..ca5adfd4 100644 --- a/java/src/main/java/io/greptime/v1/region/Server.java +++ b/java/src/main/java/io/greptime/v1/region/Server.java @@ -20,7 +20,8 @@ public interface RegionRequestHeaderOrBuilder extends /** * 
-     * Encoded trace_id & span_id, follow the w3c Trace Context https://www.w3.org/TR/trace-context/#header-name
+     * Encoded trace_id & span_id, follow the w3c Trace Context
+     * https://www.w3.org/TR/trace-context/#header-name
      *
* * map<string, string> tracing_context = 5; @@ -28,7 +29,8 @@ public interface RegionRequestHeaderOrBuilder extends int getTracingContextCount(); /** * 
-     * Encoded trace_id & span_id, follow the w3c Trace Context https://www.w3.org/TR/trace-context/#header-name
+     * Encoded trace_id & span_id, follow the w3c Trace Context
+     * https://www.w3.org/TR/trace-context/#header-name
      *
* * map<string, string> tracing_context = 5; @@ -43,7 +45,8 @@ boolean containsTracingContext( getTracingContext(); /** * 
-     * Encoded trace_id & span_id, follow the w3c Trace Context https://www.w3.org/TR/trace-context/#header-name
+     * Encoded trace_id & span_id, follow the w3c Trace Context
+     * https://www.w3.org/TR/trace-context/#header-name
      *
* * map<string, string> tracing_context = 5; @@ -52,7 +55,8 @@ boolean containsTracingContext( getTracingContextMap(); /** * 
-     * Encoded trace_id & span_id, follow the w3c Trace Context https://www.w3.org/TR/trace-context/#header-name
+     * Encoded trace_id & span_id, follow the w3c Trace Context
+     * https://www.w3.org/TR/trace-context/#header-name
      *
* * map<string, string> tracing_context = 5; @@ -65,7 +69,8 @@ java.lang.String getTracingContextOrDefault( java.lang.String defaultValue); /** * 
-     * Encoded trace_id & span_id, follow the w3c Trace Context https://www.w3.org/TR/trace-context/#header-name
+     * Encoded trace_id & span_id, follow the w3c Trace Context
+     * https://www.w3.org/TR/trace-context/#header-name
      *
* * map<string, string> tracing_context = 5; @@ -234,7 +239,8 @@ public int getTracingContextCount() { } /** * 
-     * Encoded trace_id & span_id, follow the w3c Trace Context https://www.w3.org/TR/trace-context/#header-name
+     * Encoded trace_id & span_id, follow the w3c Trace Context
+     * https://www.w3.org/TR/trace-context/#header-name
      *
* * map<string, string> tracing_context = 5; @@ -256,7 +262,8 @@ public java.util.Map getTracingContext() { } /** * 
-     * Encoded trace_id & span_id, follow the w3c Trace Context https://www.w3.org/TR/trace-context/#header-name
+     * Encoded trace_id & span_id, follow the w3c Trace Context
+     * https://www.w3.org/TR/trace-context/#header-name
      *
* * map<string, string> tracing_context = 5; @@ -268,7 +275,8 @@ public java.util.Map getTracingContextMap() } /** * 
-     * Encoded trace_id & span_id, follow the w3c Trace Context https://www.w3.org/TR/trace-context/#header-name
+     * Encoded trace_id & span_id, follow the w3c Trace Context
+     * https://www.w3.org/TR/trace-context/#header-name
      *
* * map<string, string> tracing_context = 5; @@ -285,7 +293,8 @@ public java.lang.String getTracingContextOrDefault( } /** * 
-     * Encoded trace_id & span_id, follow the w3c Trace Context https://www.w3.org/TR/trace-context/#header-name
+     * Encoded trace_id & span_id, follow the w3c Trace Context
+     * https://www.w3.org/TR/trace-context/#header-name
      *
* * map<string, string> tracing_context = 5; @@ -730,7 +739,8 @@ public int getTracingContextCount() { } /** * 
-       * Encoded trace_id & span_id, follow the w3c Trace Context https://www.w3.org/TR/trace-context/#header-name
+       * Encoded trace_id & span_id, follow the w3c Trace Context
+       * https://www.w3.org/TR/trace-context/#header-name
        *
* * map<string, string> tracing_context = 5; @@ -752,7 +762,8 @@ public java.util.Map getTracingContext() { } /** * 
-       * Encoded trace_id & span_id, follow the w3c Trace Context https://www.w3.org/TR/trace-context/#header-name
+       * Encoded trace_id & span_id, follow the w3c Trace Context
+       * https://www.w3.org/TR/trace-context/#header-name
        *
* * map<string, string> tracing_context = 5; @@ -764,7 +775,8 @@ public java.util.Map getTracingContextMap() } /** * 
-       * Encoded trace_id & span_id, follow the w3c Trace Context https://www.w3.org/TR/trace-context/#header-name
+       * Encoded trace_id & span_id, follow the w3c Trace Context
+       * https://www.w3.org/TR/trace-context/#header-name
        *
* * map<string, string> tracing_context = 5; @@ -781,7 +793,8 @@ public java.lang.String getTracingContextOrDefault( } /** * 
-       * Encoded trace_id & span_id, follow the w3c Trace Context https://www.w3.org/TR/trace-context/#header-name
+       * Encoded trace_id & span_id, follow the w3c Trace Context
+       * https://www.w3.org/TR/trace-context/#header-name
        *
* * map<string, string> tracing_context = 5; @@ -806,7 +819,8 @@ public Builder clearTracingContext() { } /** * 
-       * Encoded trace_id & span_id, follow the w3c Trace Context https://www.w3.org/TR/trace-context/#header-name
+       * Encoded trace_id & span_id, follow the w3c Trace Context
+       * https://www.w3.org/TR/trace-context/#header-name
        *
* * map<string, string> tracing_context = 5; @@ -829,7 +843,8 @@ public Builder removeTracingContext( } /** * 
-       * Encoded trace_id & span_id, follow the w3c Trace Context https://www.w3.org/TR/trace-context/#header-name
+       * Encoded trace_id & span_id, follow the w3c Trace Context
+       * https://www.w3.org/TR/trace-context/#header-name
        *
* * map<string, string> tracing_context = 5; @@ -848,7 +863,8 @@ public Builder putTracingContext( } /** * 
-       * Encoded trace_id & span_id, follow the w3c Trace Context https://www.w3.org/TR/trace-context/#header-name
+       * Encoded trace_id & span_id, follow the w3c Trace Context
+       * https://www.w3.org/TR/trace-context/#header-name
        *
* * map<string, string> tracing_context = 5; @@ -4717,6 +4733,42 @@ public interface RegionResponseOrBuilder extends * @return The affectedRows. */ long getAffectedRows(); + + /** + * map<string, bytes> extension = 3; + */ + int getExtensionCount(); + /** + * map<string, bytes> extension = 3; + */ + boolean containsExtension( + java.lang.String key); + /** + * Use {@link #getExtensionMap()} instead. + */ + @java.lang.Deprecated + java.util.Map + getExtension(); + /** + * map<string, bytes> extension = 3; + */ + java.util.Map + getExtensionMap(); + /** + * map<string, bytes> extension = 3; + */ + + /* nullable */ +com.google.protobuf.ByteString getExtensionOrDefault( + java.lang.String key, + /* nullable */ +com.google.protobuf.ByteString defaultValue); + /** + * map<string, bytes> extension = 3; + */ + + com.google.protobuf.ByteString getExtensionOrThrow( + java.lang.String key); } /** * Protobuf type {@code greptime.v1.region.RegionResponse} @@ -4753,6 +4805,7 @@ private RegionResponse( if (extensionRegistry == null) { throw new java.lang.NullPointerException(); } + int mutable_bitField0_ = 0; com.google.protobuf.UnknownFieldSet.Builder unknownFields = com.google.protobuf.UnknownFieldSet.newBuilder(); try { @@ -4781,6 +4834,19 @@ private RegionResponse( affectedRows_ = input.readUInt64(); break; } + case 26: { + if (!((mutable_bitField0_ & 0x00000001) != 0)) { + extension_ = com.google.protobuf.MapField.newMapField( + ExtensionDefaultEntryHolder.defaultEntry); + mutable_bitField0_ |= 0x00000001; + } + com.google.protobuf.MapEntry + extension__ = input.readMessage( + ExtensionDefaultEntryHolder.defaultEntry.getParserForType(), extensionRegistry); + extension_.getMutableMap().put( + extension__.getKey(), extension__.getValue()); + break; + } default: { if (!parseUnknownField( input, unknownFields, extensionRegistry, tag)) { @@ -4807,6 +4873,18 @@ private RegionResponse( return io.greptime.v1.region.Server.internal_static_greptime_v1_region_RegionResponse_descriptor; } + @SuppressWarnings({"rawtypes"}) + @java.lang.Override + protected com.google.protobuf.MapField internalGetMapField( + int number) { + switch (number) { + case 3: + return internalGetExtension(); + default: + throw new RuntimeException( + "Invalid map field number: " + number); + } + } @java.lang.Override protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable() { @@ -4852,6 +4930,87 @@ public long getAffectedRows() { return affectedRows_; } + public static final int EXTENSION_FIELD_NUMBER = 3; + private static final class ExtensionDefaultEntryHolder { + static final com.google.protobuf.MapEntry< + java.lang.String, com.google.protobuf.ByteString> defaultEntry = + com.google.protobuf.MapEntry + .newDefaultInstance( + io.greptime.v1.region.Server.internal_static_greptime_v1_region_RegionResponse_ExtensionEntry_descriptor, + com.google.protobuf.WireFormat.FieldType.STRING, + "", + com.google.protobuf.WireFormat.FieldType.BYTES, + com.google.protobuf.ByteString.EMPTY); + } + private com.google.protobuf.MapField< + java.lang.String, com.google.protobuf.ByteString> extension_; + private com.google.protobuf.MapField + internalGetExtension() { + if (extension_ == null) { + return com.google.protobuf.MapField.emptyMapField( + ExtensionDefaultEntryHolder.defaultEntry); + } + return extension_; + } + + public int getExtensionCount() { + return internalGetExtension().getMap().size(); + } + /** + * map<string, bytes> extension = 3; + */ + + @java.lang.Override + public boolean containsExtension( + java.lang.String key) { + if (key == null) { throw new NullPointerException("map key"); } + return internalGetExtension().getMap().containsKey(key); + } + /** + * Use {@link #getExtensionMap()} instead. + */ + @java.lang.Override + @java.lang.Deprecated + public java.util.Map getExtension() { + return getExtensionMap(); + } + /** + * map<string, bytes> extension = 3; + */ + @java.lang.Override + + public java.util.Map getExtensionMap() { + return internalGetExtension().getMap(); + } + /** + * map<string, bytes> extension = 3; + */ + @java.lang.Override + + public com.google.protobuf.ByteString getExtensionOrDefault( + java.lang.String key, + com.google.protobuf.ByteString defaultValue) { + if (key == null) { throw new NullPointerException("map key"); } + java.util.Map map = + internalGetExtension().getMap(); + return map.containsKey(key) ? map.get(key) : defaultValue; + } + /** + * map<string, bytes> extension = 3; + */ + @java.lang.Override + + public com.google.protobuf.ByteString getExtensionOrThrow( + java.lang.String key) { + if (key == null) { throw new NullPointerException("map key"); } + java.util.Map map = + internalGetExtension().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() { @@ -4872,6 +5031,12 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) if (affectedRows_ != 0L) { output.writeUInt64(2, affectedRows_); } + com.google.protobuf.GeneratedMessageV3 + .serializeStringMapTo( + output, + internalGetExtension(), + ExtensionDefaultEntryHolder.defaultEntry, + 3); unknownFields.writeTo(output); } @@ -4889,6 +5054,16 @@ public int getSerializedSize() { size += com.google.protobuf.CodedOutputStream .computeUInt64Size(2, affectedRows_); } + for (java.util.Map.Entry entry + : internalGetExtension().getMap().entrySet()) { + com.google.protobuf.MapEntry + extension__ = ExtensionDefaultEntryHolder.defaultEntry.newBuilderForType() + .setKey(entry.getKey()) + .setValue(entry.getValue()) + .build(); + size += com.google.protobuf.CodedOutputStream + .computeMessageSize(3, extension__); + } size += unknownFields.getSerializedSize(); memoizedSize = size; return size; @@ -4911,6 +5086,8 @@ public boolean equals(final java.lang.Object obj) { } if (getAffectedRows() != other.getAffectedRows()) return false; + if (!internalGetExtension().equals( + other.internalGetExtension())) return false; if (!unknownFields.equals(other.unknownFields)) return false; return true; } @@ -4929,6 +5106,10 @@ public int hashCode() { hash = (37 * hash) + AFFECTED_ROWS_FIELD_NUMBER; hash = (53 * hash) + com.google.protobuf.Internal.hashLong( getAffectedRows()); + if (!internalGetExtension().getMap().isEmpty()) { + hash = (37 * hash) + EXTENSION_FIELD_NUMBER; + hash = (53 * hash) + internalGetExtension().hashCode(); + } hash = (29 * hash) + unknownFields.hashCode(); memoizedHashCode = hash; return hash; @@ -5036,6 +5217,28 @@ public static final class Builder extends return io.greptime.v1.region.Server.internal_static_greptime_v1_region_RegionResponse_descriptor; } + @SuppressWarnings({"rawtypes"}) + protected com.google.protobuf.MapField internalGetMapField( + int number) { + switch (number) { + case 3: + return internalGetExtension(); + default: + throw new RuntimeException( + "Invalid map field number: " + number); + } + } + @SuppressWarnings({"rawtypes"}) + protected com.google.protobuf.MapField internalGetMutableMapField( + int number) { + switch (number) { + case 3: + return internalGetMutableExtension(); + default: + throw new RuntimeException( + "Invalid map field number: " + number); + } + } @java.lang.Override protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable() { @@ -5070,6 +5273,7 @@ public Builder clear() { } affectedRows_ = 0L; + internalGetMutableExtension().clear(); return this; } @@ -5096,12 +5300,15 @@ public io.greptime.v1.region.Server.RegionResponse build() { @java.lang.Override public io.greptime.v1.region.Server.RegionResponse buildPartial() { io.greptime.v1.region.Server.RegionResponse result = new io.greptime.v1.region.Server.RegionResponse(this); + int from_bitField0_ = bitField0_; if (headerBuilder_ == null) { result.header_ = header_; } else { result.header_ = headerBuilder_.build(); } result.affectedRows_ = affectedRows_; + result.extension_ = internalGetExtension(); + result.extension_.makeImmutable(); onBuilt(); return result; } @@ -5156,6 +5363,8 @@ public Builder mergeFrom(io.greptime.v1.region.Server.RegionResponse other) { if (other.getAffectedRows() != 0L) { setAffectedRows(other.getAffectedRows()); } + internalGetMutableExtension().mergeFrom( + other.internalGetExtension()); this.mergeUnknownFields(other.unknownFields); onChanged(); return this; @@ -5184,6 +5393,7 @@ public Builder mergeFrom( } return this; } + private int bitField0_; private io.greptime.v1.Common.ResponseHeader header_; private com.google.protobuf.SingleFieldBuilderV3< @@ -5334,6 +5544,137 @@ public Builder clearAffectedRows() { onChanged(); return this; } + + private com.google.protobuf.MapField< + java.lang.String, com.google.protobuf.ByteString> extension_; + private com.google.protobuf.MapField + internalGetExtension() { + if (extension_ == null) { + return com.google.protobuf.MapField.emptyMapField( + ExtensionDefaultEntryHolder.defaultEntry); + } + return extension_; + } + private com.google.protobuf.MapField + internalGetMutableExtension() { + onChanged();; + if (extension_ == null) { + extension_ = com.google.protobuf.MapField.newMapField( + ExtensionDefaultEntryHolder.defaultEntry); + } + if (!extension_.isMutable()) { + extension_ = extension_.copy(); + } + return extension_; + } + + public int getExtensionCount() { + return internalGetExtension().getMap().size(); + } + /** + * map<string, bytes> extension = 3; + */ + + @java.lang.Override + public boolean containsExtension( + java.lang.String key) { + if (key == null) { throw new NullPointerException("map key"); } + return internalGetExtension().getMap().containsKey(key); + } + /** + * Use {@link #getExtensionMap()} instead. + */ + @java.lang.Override + @java.lang.Deprecated + public java.util.Map getExtension() { + return getExtensionMap(); + } + /** + * map<string, bytes> extension = 3; + */ + @java.lang.Override + + public java.util.Map getExtensionMap() { + return internalGetExtension().getMap(); + } + /** + * map<string, bytes> extension = 3; + */ + @java.lang.Override + + public com.google.protobuf.ByteString getExtensionOrDefault( + java.lang.String key, + com.google.protobuf.ByteString defaultValue) { + if (key == null) { throw new NullPointerException("map key"); } + java.util.Map map = + internalGetExtension().getMap(); + return map.containsKey(key) ? map.get(key) : defaultValue; + } + /** + * map<string, bytes> extension = 3; + */ + @java.lang.Override + + public com.google.protobuf.ByteString getExtensionOrThrow( + java.lang.String key) { + if (key == null) { throw new NullPointerException("map key"); } + java.util.Map map = + internalGetExtension().getMap(); + if (!map.containsKey(key)) { + throw new java.lang.IllegalArgumentException(); + } + return map.get(key); + } + + public Builder clearExtension() { + internalGetMutableExtension().getMutableMap() + .clear(); + return this; + } + /** + * map<string, bytes> extension = 3; + */ + + public Builder removeExtension( + java.lang.String key) { + if (key == null) { throw new NullPointerException("map key"); } + internalGetMutableExtension().getMutableMap() + .remove(key); + return this; + } + /** + * Use alternate mutation accessors instead. + */ + @java.lang.Deprecated + public java.util.Map + getMutableExtension() { + return internalGetMutableExtension().getMutableMap(); + } + /** + * map<string, bytes> extension = 3; + */ + public Builder putExtension( + java.lang.String key, + com.google.protobuf.ByteString value) { + if (key == null) { throw new NullPointerException("map key"); } + if (value == null) { + throw new NullPointerException("map value"); +} + + internalGetMutableExtension().getMutableMap() + .put(key, value); + return this; + } + /** + * map<string, bytes> extension = 3; + */ + + public Builder putAllExtension( + java.util.Map values) { + internalGetMutableExtension().getMutableMap() + .putAll(values); + return this; + } @java.lang.Override public final Builder setUnknownFields( final com.google.protobuf.UnknownFieldSet unknownFields) { @@ -9183,9 +9524,9 @@ io.greptime.v1.region.Server.CreateRequestOrBuilder getRequestsOrBuilder( } /** * 
-   * Create a batch of regions at once, usually used to create multiple logical regions
-   * at once. Different engines can choose whether to support this request.
-   * Metric Engine needs it.
+   * Create a batch of regions at once, usually used to create multiple logical
+   * regions at once. Different engines can choose whether to support this
+   * request. Metric Engine needs it.
    *
* * Protobuf type {@code greptime.v1.region.CreateRequests} @@ -9479,9 +9820,9 @@ protected Builder newBuilderForType( } /** * 
-     * Create a batch of regions at once, usually used to create multiple logical regions
-     * at once. Different engines can choose whether to support this request.
-     * Metric Engine needs it.
+     * Create a batch of regions at once, usually used to create multiple logical
+     * regions at once. Different engines can choose whether to support this
+     * request. Metric Engine needs it.
      *
* * Protobuf type {@code greptime.v1.region.CreateRequests} @@ -22073,6 +22414,11 @@ public io.greptime.v1.region.Server.RegionColumnDef getDefaultInstanceForType() private static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_greptime_v1_region_RegionResponse_fieldAccessorTable; + private static final com.google.protobuf.Descriptors.Descriptor + internal_static_greptime_v1_region_RegionResponse_ExtensionEntry_descriptor; + private static final + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internal_static_greptime_v1_region_RegionResponse_ExtensionEntry_fieldAccessorTable; private static final com.google.protobuf.Descriptors.Descriptor internal_static_greptime_v1_region_InsertRequests_descriptor; private static final @@ -22223,58 +22569,61 @@ public io.greptime.v1.region.Server.RegionColumnDef getDefaultInstanceForType() " \001(\0132\".greptime.v1.region.CreateRequests" + "H\000\0221\n\005drops\030\016 \001(\0132 .greptime.v1.region.D" + "ropRequestsH\000\0223\n\006alters\030\017 \001(\0132!.greptime" + - ".v1.region.AlterRequestsH\000B\006\n\004body\"T\n\016Re" + - "gionResponse\022+\n\006header\030\001 \001(\0132\033.greptime." + - "v1.ResponseHeader\022\025\n\raffected_rows\030\002 \001(\004" + - "\"E\n\016InsertRequests\0223\n\010requests\030\001 \003(\0132!.g" + - "reptime.v1.region.InsertRequest\"E\n\016Delet" + - "eRequests\0223\n\010requests\030\001 \003(\0132!.greptime.v" + - "1.region.DeleteRequest\"C\n\rInsertRequest\022" + - "\021\n\tregion_id\030\001 \001(\004\022\037\n\004rows\030\002 \001(\0132\021.grept" + - "ime.v1.Rows\"C\n\rDeleteRequest\022\021\n\tregion_i" + - "d\030\001 \001(\004\022\037\n\004rows\030\002 \001(\0132\021.greptime.v1.Rows" + - "\"h\n\014QueryRequest\0227\n\006header\030\001 \001(\0132\'.grept" + - "ime.v1.region.RegionRequestHeader\022\021\n\treg" + - "ion_id\030\002 \001(\004\022\014\n\004plan\030\003 \001(\014\"E\n\016CreateRequ" + - "ests\0223\n\010requests\030\001 \003(\0132!.greptime.v1.reg" + - "ion.CreateRequest\"\200\002\n\rCreateRequest\022\021\n\tr" + - "egion_id\030\001 \001(\004\022\016\n\006engine\030\002 \001(\t\0228\n\013column" + - "_defs\030\003 \003(\0132#.greptime.v1.region.RegionC" + - "olumnDef\022\023\n\013primary_key\030\004 \003(\r\022\014\n\004path\030\005 " + - "\001(\t\022?\n\007options\030\006 \003(\0132..greptime.v1.regio" + - "n.CreateRequest.OptionsEntry\032.\n\014OptionsE" + - "ntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\"A\n\014" + - "DropRequests\0221\n\010requests\030\001 \003(\0132\037.greptim" + - "e.v1.region.DropRequest\" \n\013DropRequest\022\021" + - "\n\tregion_id\030\001 \001(\004\"\255\001\n\013OpenRequest\022\021\n\treg" + - "ion_id\030\001 \001(\004\022\016\n\006engine\030\002 \001(\t\022\014\n\004path\030\003 \001" + - "(\t\022=\n\007options\030\004 \003(\0132,.greptime.v1.region" + - ".OpenRequest.OptionsEntry\032.\n\014OptionsEntr" + - "y\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\"!\n\014Clo" + - "seRequest\022\021\n\tregion_id\030\001 \001(\004\"C\n\rAlterReq" + - "uests\0222\n\010requests\030\001 \003(\0132 .greptime.v1.re" + - "gion.AlterRequest\"\261\001\n\014AlterRequest\022\021\n\tre" + - "gion_id\030\001 \001(\004\0225\n\013add_columns\030\002 \001(\0132\036.gre" + - "ptime.v1.region.AddColumnsH\000\0227\n\014drop_col" + - "umns\030\003 \001(\0132\037.greptime.v1.region.DropColu" + - "mnsH\000\022\026\n\016schema_version\030\004 \001(\004B\006\n\004kind\"@\n" + - "\nAddColumns\0222\n\013add_columns\030\001 \003(\0132\035.grept" + - "ime.v1.region.AddColumn\"C\n\013DropColumns\0224" + - "\n\014drop_columns\030\001 \003(\0132\036.greptime.v1.regio" + - "n.DropColumn\"v\n\tAddColumn\0227\n\ncolumn_def\030" + - "\001 \001(\0132#.greptime.v1.region.RegionColumnD" + - "ef\0220\n\010location\030\003 \001(\0132\036.greptime.v1.AddCo" + - "lumnLocation\"\032\n\nDropColumn\022\014\n\004name\030\001 \001(\t" + - "\"!\n\014FlushRequest\022\021\n\tregion_id\030\001 \001(\004\"#\n\016C" + - "ompactRequest\022\021\n\tregion_id\030\001 \001(\004\"$\n\017Trun" + - "cateRequest\022\021\n\tregion_id\030\001 \001(\004\"P\n\017Region" + - "ColumnDef\022*\n\ncolumn_def\030\001 \001(\0132\026.greptime" + - ".v1.ColumnDef\022\021\n\tcolumn_id\030\002 \001(\r2Y\n\006Regi" + - "on\022O\n\006Handle\022!.greptime.v1.region.Region" + - "Request\032\".greptime.v1.region.RegionRespo" + - "nseB]\n\025io.greptime.v1.regionB\006ServerZ tracing_context = 5; // DB Name of request, tracking only string dbname = 3; @@ -56,6 +57,7 @@ message RegionRequest { message RegionResponse { ResponseHeader header = 1; uint64 affected_rows = 2; + map extension = 3; } message InsertRequests { repeated InsertRequest requests = 1; } @@ -79,9 +81,9 @@ message QueryRequest { bytes plan = 3; } -// Create a batch of regions at once, usually used to create multiple logical regions -// at once. Different engines can choose whether to support this request. -// Metric Engine needs it. +// Create a batch of regions at once, usually used to create multiple logical +// regions at once. Different engines can choose whether to support this +// request. Metric Engine needs it. message CreateRequests { repeated CreateRequest requests = 1; } message CreateRequest {