diff --git a/c++/greptime/v1/region/server.pb.cc b/c++/greptime/v1/region/server.pb.cc index b17c95b0..af96d172 100644 --- a/c++/greptime/v1/region/server.pb.cc +++ b/c++/greptime/v1/region/server.pb.cc @@ -363,10 +363,36 @@ struct FlushRequestDefaultTypeInternal { }; }; PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 FlushRequestDefaultTypeInternal _FlushRequest_default_instance_; +PROTOBUF_CONSTEXPR Regular::Regular( + ::_pbi::ConstantInitialized) {} +struct RegularDefaultTypeInternal { + PROTOBUF_CONSTEXPR RegularDefaultTypeInternal() + : _instance(::_pbi::ConstantInitialized{}) {} + ~RegularDefaultTypeInternal() {} + union { + Regular _instance; + }; +}; +PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 RegularDefaultTypeInternal _Regular_default_instance_; +PROTOBUF_CONSTEXPR StrictWindow::StrictWindow( + ::_pbi::ConstantInitialized): _impl_{ + /*decltype(_impl_.window_seconds_)*/int64_t{0} + , /*decltype(_impl_._cached_size_)*/{}} {} +struct StrictWindowDefaultTypeInternal { + PROTOBUF_CONSTEXPR StrictWindowDefaultTypeInternal() + : _instance(::_pbi::ConstantInitialized{}) {} + ~StrictWindowDefaultTypeInternal() {} + union { + StrictWindow _instance; + }; +}; +PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 StrictWindowDefaultTypeInternal _StrictWindow_default_instance_; PROTOBUF_CONSTEXPR CompactRequest::CompactRequest( ::_pbi::ConstantInitialized): _impl_{ /*decltype(_impl_.region_id_)*/uint64_t{0u} - , /*decltype(_impl_._cached_size_)*/{}} {} + , /*decltype(_impl_.options_)*/{} + , /*decltype(_impl_._cached_size_)*/{} + , /*decltype(_impl_._oneof_case_)*/{}} {} struct CompactRequestDefaultTypeInternal { PROTOBUF_CONSTEXPR CompactRequestDefaultTypeInternal() : _instance(::_pbi::ConstantInitialized{}) {} @@ -406,7 +432,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[28]; +static ::_pb::Metadata file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[30]; 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; @@ -635,12 +661,28 @@ const uint32_t TableStruct_greptime_2fv1_2fregion_2fserver_2eproto::offsets[] PR ~0u, // no _inlined_string_donated_ PROTOBUF_FIELD_OFFSET(::greptime::v1::region::FlushRequest, _impl_.region_id_), ~0u, // no _has_bits_ - PROTOBUF_FIELD_OFFSET(::greptime::v1::region::CompactRequest, _internal_metadata_), + PROTOBUF_FIELD_OFFSET(::greptime::v1::region::Regular, _internal_metadata_), + ~0u, // no _extensions_ + ~0u, // no _oneof_case_ + ~0u, // no _weak_field_map_ + ~0u, // no _inlined_string_donated_ + ~0u, // no _has_bits_ + PROTOBUF_FIELD_OFFSET(::greptime::v1::region::StrictWindow, _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::StrictWindow, _impl_.window_seconds_), + ~0u, // no _has_bits_ + PROTOBUF_FIELD_OFFSET(::greptime::v1::region::CompactRequest, _internal_metadata_), + ~0u, // no _extensions_ + PROTOBUF_FIELD_OFFSET(::greptime::v1::region::CompactRequest, _impl_._oneof_case_[0]), + ~0u, // no _weak_field_map_ + ~0u, // no _inlined_string_donated_ PROTOBUF_FIELD_OFFSET(::greptime::v1::region::CompactRequest, _impl_.region_id_), + ::_pbi::kInvalidFieldOffsetTag, + ::_pbi::kInvalidFieldOffsetTag, + PROTOBUF_FIELD_OFFSET(::greptime::v1::region::CompactRequest, _impl_.options_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::greptime::v1::region::TruncateRequest, _internal_metadata_), ~0u, // no _extensions_ @@ -683,9 +725,11 @@ static const ::_pbi::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protode { 201, -1, -1, sizeof(::greptime::v1::region::AddColumn)}, { 209, -1, -1, sizeof(::greptime::v1::region::DropColumn)}, { 216, -1, -1, sizeof(::greptime::v1::region::FlushRequest)}, - { 223, -1, -1, sizeof(::greptime::v1::region::CompactRequest)}, - { 230, -1, -1, sizeof(::greptime::v1::region::TruncateRequest)}, - { 237, -1, -1, sizeof(::greptime::v1::region::RegionColumnDef)}, + { 223, -1, -1, sizeof(::greptime::v1::region::Regular)}, + { 229, -1, -1, sizeof(::greptime::v1::region::StrictWindow)}, + { 236, -1, -1, sizeof(::greptime::v1::region::CompactRequest)}, + { 246, -1, -1, sizeof(::greptime::v1::region::TruncateRequest)}, + { 253, -1, -1, sizeof(::greptime::v1::region::RegionColumnDef)}, }; static const ::_pb::Message* const file_default_instances[] = { @@ -714,6 +758,8 @@ static const ::_pb::Message* const file_default_instances[] = { &::greptime::v1::region::_AddColumn_default_instance_._instance, &::greptime::v1::region::_DropColumn_default_instance_._instance, &::greptime::v1::region::_FlushRequest_default_instance_._instance, + &::greptime::v1::region::_Regular_default_instance_._instance, + &::greptime::v1::region::_StrictWindow_default_instance_._instance, &::greptime::v1::region::_CompactRequest_default_instance_._instance, &::greptime::v1::region::_TruncateRequest_default_instance_._instance, &::greptime::v1::region::_RegionColumnDef_default_instance_._instance, @@ -794,16 +840,20 @@ const char descriptor_table_protodef_greptime_2fv1_2fregion_2fserver_2eproto[] P "#.greptime.v1.region.RegionColumnDef\0220\n\010" "location\030\003 \001(\0132\036.greptime.v1.AddColumnLo" "cation\"\032\n\nDropColumn\022\014\n\004name\030\001 \001(\t\"!\n\014Fl" - "ushRequest\022\021\n\tregion_id\030\001 \001(\004\"#\n\016Compact" - "Request\022\021\n\tregion_id\030\001 \001(\004\"$\n\017TruncateRe" - "quest\022\021\n\tregion_id\030\001 \001(\004\"P\n\017RegionColumn" - "Def\022*\n\ncolumn_def\030\001 \001(\0132\026.greptime.v1.Co" - "lumnDef\022\021\n\tcolumn_id\030\002 \001(\r2Y\n\006Region\022O\n\006" - "Handle\022!.greptime.v1.region.RegionReques" - "t\032\".greptime.v1.region.RegionResponseB]\n" - "\025io.greptime.v1.regionB\006ServerZ(from._internal_metadata_); + // @@protoc_insertion_point(copy_constructor:greptime.v1.region.Regular) +} + + + + + +const ::PROTOBUF_NAMESPACE_ID::Message::ClassData Regular::_class_data_ = { + ::PROTOBUF_NAMESPACE_ID::internal::ZeroFieldsBase::CopyImpl, + ::PROTOBUF_NAMESPACE_ID::internal::ZeroFieldsBase::MergeImpl, +}; +const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*Regular::GetClassData() const { return &_class_data_; } + + + + + + + +::PROTOBUF_NAMESPACE_ID::Metadata Regular::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]); +} + +// =================================================================== + +class StrictWindow::_Internal { + public: +}; + +StrictWindow::StrictWindow(::PROTOBUF_NAMESPACE_ID::Arena* arena, + bool is_message_owned) + : ::PROTOBUF_NAMESPACE_ID::Message(arena, is_message_owned) { + SharedCtor(arena, is_message_owned); + // @@protoc_insertion_point(arena_constructor:greptime.v1.region.StrictWindow) +} +StrictWindow::StrictWindow(const StrictWindow& from) + : ::PROTOBUF_NAMESPACE_ID::Message() { + StrictWindow* const _this = this; (void)_this; + new (&_impl_) Impl_{ + decltype(_impl_.window_seconds_){} + , /*decltype(_impl_._cached_size_)*/{}}; + + _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); + _this->_impl_.window_seconds_ = from._impl_.window_seconds_; + // @@protoc_insertion_point(copy_constructor:greptime.v1.region.StrictWindow) +} + +inline void StrictWindow::SharedCtor( + ::_pb::Arena* arena, bool is_message_owned) { + (void)arena; + (void)is_message_owned; + new (&_impl_) Impl_{ + decltype(_impl_.window_seconds_){int64_t{0}} + , /*decltype(_impl_._cached_size_)*/{} + }; +} + +StrictWindow::~StrictWindow() { + // @@protoc_insertion_point(destructor:greptime.v1.region.StrictWindow) + if (auto *arena = _internal_metadata_.DeleteReturnArena<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>()) { + (void)arena; + return; + } + SharedDtor(); +} + +inline void StrictWindow::SharedDtor() { + GOOGLE_DCHECK(GetArenaForAllocation() == nullptr); +} + +void StrictWindow::SetCachedSize(int size) const { + _impl_._cached_size_.Set(size); +} + +void StrictWindow::Clear() { +// @@protoc_insertion_point(message_clear_start:greptime.v1.region.StrictWindow) + uint32_t cached_has_bits = 0; + // Prevent compiler warnings about cached_has_bits being unused + (void) cached_has_bits; + + _impl_.window_seconds_ = int64_t{0}; + _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); +} + +const char* StrictWindow::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) { +#define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure + while (!ctx->Done(&ptr)) { + uint32_t tag; + ptr = ::_pbi::ReadTag(ptr, &tag); + switch (tag >> 3) { + // int64 window_seconds = 1; + case 1: + if (PROTOBUF_PREDICT_TRUE(static_cast(tag) == 8)) { + _impl_.window_seconds_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint64(&ptr); + CHK_(ptr); + } else + goto handle_unusual; + continue; + default: + goto handle_unusual; + } // switch + handle_unusual: + if ((tag == 0) || ((tag & 7) == 4)) { + CHK_(ptr); + ctx->SetLastTag(tag); + goto message_done; + } + ptr = UnknownFieldParse( + tag, + _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(), + ptr, ctx); + CHK_(ptr != nullptr); + } // while +message_done: + return ptr; +failure: + ptr = nullptr; + goto message_done; +#undef CHK_ +} + +uint8_t* StrictWindow::_InternalSerialize( + uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { + // @@protoc_insertion_point(serialize_to_array_start:greptime.v1.region.StrictWindow) + uint32_t cached_has_bits = 0; + (void) cached_has_bits; + + // int64 window_seconds = 1; + if (this->_internal_window_seconds() != 0) { + target = stream->EnsureSpace(target); + target = ::_pbi::WireFormatLite::WriteInt64ToArray(1, this->_internal_window_seconds(), 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); + } + // @@protoc_insertion_point(serialize_to_array_end:greptime.v1.region.StrictWindow) + return target; +} + +size_t StrictWindow::ByteSizeLong() const { +// @@protoc_insertion_point(message_byte_size_start:greptime.v1.region.StrictWindow) + size_t total_size = 0; + + uint32_t cached_has_bits = 0; + // Prevent compiler warnings about cached_has_bits being unused + (void) cached_has_bits; + + // int64 window_seconds = 1; + if (this->_internal_window_seconds() != 0) { + total_size += ::_pbi::WireFormatLite::Int64SizePlusOne(this->_internal_window_seconds()); + } + + return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_); +} + +const ::PROTOBUF_NAMESPACE_ID::Message::ClassData StrictWindow::_class_data_ = { + ::PROTOBUF_NAMESPACE_ID::Message::CopyWithSourceCheck, + StrictWindow::MergeImpl +}; +const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*StrictWindow::GetClassData() const { return &_class_data_; } + + +void StrictWindow::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg) { + auto* const _this = static_cast(&to_msg); + auto& from = static_cast(from_msg); + // @@protoc_insertion_point(class_specific_merge_from_start:greptime.v1.region.StrictWindow) + GOOGLE_DCHECK_NE(&from, _this); + uint32_t cached_has_bits = 0; + (void) cached_has_bits; + + if (from._internal_window_seconds() != 0) { + _this->_internal_set_window_seconds(from._internal_window_seconds()); + } + _this->_internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); +} + +void StrictWindow::CopyFrom(const StrictWindow& from) { +// @@protoc_insertion_point(class_specific_copy_from_start:greptime.v1.region.StrictWindow) + if (&from == this) return; + Clear(); + MergeFrom(from); +} + +bool StrictWindow::IsInitialized() const { + return true; +} + +void StrictWindow::InternalSwap(StrictWindow* other) { + using std::swap; + _internal_metadata_.InternalSwap(&other->_internal_metadata_); + swap(_impl_.window_seconds_, other->_impl_.window_seconds_); +} + +::PROTOBUF_NAMESPACE_ID::Metadata StrictWindow::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]); +} + +// =================================================================== + class CompactRequest::_Internal { public: + static const ::greptime::v1::region::Regular& regular(const CompactRequest* msg); + static const ::greptime::v1::region::StrictWindow& strict_window(const CompactRequest* msg); }; +const ::greptime::v1::region::Regular& +CompactRequest::_Internal::regular(const CompactRequest* msg) { + return *msg->_impl_.options_.regular_; +} +const ::greptime::v1::region::StrictWindow& +CompactRequest::_Internal::strict_window(const CompactRequest* msg) { + return *msg->_impl_.options_.strict_window_; +} +void CompactRequest::set_allocated_regular(::greptime::v1::region::Regular* regular) { + ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation(); + clear_options(); + if (regular) { + ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena = + ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(regular); + if (message_arena != submessage_arena) { + regular = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage( + message_arena, regular, submessage_arena); + } + set_has_regular(); + _impl_.options_.regular_ = regular; + } + // @@protoc_insertion_point(field_set_allocated:greptime.v1.region.CompactRequest.regular) +} +void CompactRequest::set_allocated_strict_window(::greptime::v1::region::StrictWindow* strict_window) { + ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation(); + clear_options(); + if (strict_window) { + ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena = + ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(strict_window); + if (message_arena != submessage_arena) { + strict_window = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage( + message_arena, strict_window, submessage_arena); + } + set_has_strict_window(); + _impl_.options_.strict_window_ = strict_window; + } + // @@protoc_insertion_point(field_set_allocated:greptime.v1.region.CompactRequest.strict_window) +} CompactRequest::CompactRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned) : ::PROTOBUF_NAMESPACE_ID::Message(arena, is_message_owned) { @@ -6712,10 +7020,28 @@ CompactRequest::CompactRequest(const CompactRequest& from) CompactRequest* const _this = this; (void)_this; new (&_impl_) Impl_{ decltype(_impl_.region_id_){} - , /*decltype(_impl_._cached_size_)*/{}}; + , decltype(_impl_.options_){} + , /*decltype(_impl_._cached_size_)*/{} + , /*decltype(_impl_._oneof_case_)*/{}}; _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); _this->_impl_.region_id_ = from._impl_.region_id_; + clear_has_options(); + switch (from.options_case()) { + case kRegular: { + _this->_internal_mutable_regular()->::greptime::v1::region::Regular::MergeFrom( + from._internal_regular()); + break; + } + case kStrictWindow: { + _this->_internal_mutable_strict_window()->::greptime::v1::region::StrictWindow::MergeFrom( + from._internal_strict_window()); + break; + } + case OPTIONS_NOT_SET: { + break; + } + } // @@protoc_insertion_point(copy_constructor:greptime.v1.region.CompactRequest) } @@ -6725,8 +7051,11 @@ inline void CompactRequest::SharedCtor( (void)is_message_owned; new (&_impl_) Impl_{ decltype(_impl_.region_id_){uint64_t{0u}} + , decltype(_impl_.options_){} , /*decltype(_impl_._cached_size_)*/{} + , /*decltype(_impl_._oneof_case_)*/{} }; + clear_has_options(); } CompactRequest::~CompactRequest() { @@ -6740,12 +7069,38 @@ CompactRequest::~CompactRequest() { inline void CompactRequest::SharedDtor() { GOOGLE_DCHECK(GetArenaForAllocation() == nullptr); + if (has_options()) { + clear_options(); + } } void CompactRequest::SetCachedSize(int size) const { _impl_._cached_size_.Set(size); } +void CompactRequest::clear_options() { +// @@protoc_insertion_point(one_of_clear_start:greptime.v1.region.CompactRequest) + switch (options_case()) { + case kRegular: { + if (GetArenaForAllocation() == nullptr) { + delete _impl_.options_.regular_; + } + break; + } + case kStrictWindow: { + if (GetArenaForAllocation() == nullptr) { + delete _impl_.options_.strict_window_; + } + break; + } + case OPTIONS_NOT_SET: { + break; + } + } + _impl_._oneof_case_[0] = OPTIONS_NOT_SET; +} + + void CompactRequest::Clear() { // @@protoc_insertion_point(message_clear_start:greptime.v1.region.CompactRequest) uint32_t cached_has_bits = 0; @@ -6753,6 +7108,7 @@ void CompactRequest::Clear() { (void) cached_has_bits; _impl_.region_id_ = uint64_t{0u}; + clear_options(); _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } @@ -6770,6 +7126,22 @@ const char* CompactRequest::_InternalParse(const char* ptr, ::_pbi::ParseContext } else goto handle_unusual; continue; + // .greptime.v1.region.Regular regular = 2; + case 2: + if (PROTOBUF_PREDICT_TRUE(static_cast(tag) == 18)) { + ptr = ctx->ParseMessage(_internal_mutable_regular(), ptr); + CHK_(ptr); + } else + goto handle_unusual; + continue; + // .greptime.v1.region.StrictWindow strict_window = 3; + case 3: + if (PROTOBUF_PREDICT_TRUE(static_cast(tag) == 26)) { + ptr = ctx->ParseMessage(_internal_mutable_strict_window(), ptr); + CHK_(ptr); + } else + goto handle_unusual; + continue; default: goto handle_unusual; } // switch @@ -6805,6 +7177,20 @@ uint8_t* CompactRequest::_InternalSerialize( target = ::_pbi::WireFormatLite::WriteUInt64ToArray(1, this->_internal_region_id(), target); } + // .greptime.v1.region.Regular regular = 2; + if (_internal_has_regular()) { + target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite:: + InternalWriteMessage(2, _Internal::regular(this), + _Internal::regular(this).GetCachedSize(), target, stream); + } + + // .greptime.v1.region.StrictWindow strict_window = 3; + if (_internal_has_strict_window()) { + target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite:: + InternalWriteMessage(3, _Internal::strict_window(this), + _Internal::strict_window(this).GetCachedSize(), target, stream); + } + if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { target = ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray( _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream); @@ -6826,6 +7212,25 @@ size_t CompactRequest::ByteSizeLong() const { total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(this->_internal_region_id()); } + switch (options_case()) { + // .greptime.v1.region.Regular regular = 2; + case kRegular: { + total_size += 1 + + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize( + *_impl_.options_.regular_); + break; + } + // .greptime.v1.region.StrictWindow strict_window = 3; + case kStrictWindow: { + total_size += 1 + + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize( + *_impl_.options_.strict_window_); + break; + } + case OPTIONS_NOT_SET: { + break; + } + } return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_); } @@ -6847,6 +7252,21 @@ void CompactRequest::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const : if (from._internal_region_id() != 0) { _this->_internal_set_region_id(from._internal_region_id()); } + switch (from.options_case()) { + case kRegular: { + _this->_internal_mutable_regular()->::greptime::v1::region::Regular::MergeFrom( + from._internal_regular()); + break; + } + case kStrictWindow: { + _this->_internal_mutable_strict_window()->::greptime::v1::region::StrictWindow::MergeFrom( + from._internal_strict_window()); + break; + } + case OPTIONS_NOT_SET: { + break; + } + } _this->_internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); } @@ -6865,12 +7285,14 @@ void CompactRequest::InternalSwap(CompactRequest* other) { using std::swap; _internal_metadata_.InternalSwap(&other->_internal_metadata_); swap(_impl_.region_id_, other->_impl_.region_id_); + swap(_impl_.options_, other->_impl_.options_); + swap(_impl_._oneof_case_[0], other->_impl_._oneof_case_[0]); } ::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[25]); + file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[27]); } // =================================================================== @@ -7048,7 +7470,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[26]); + file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[28]); } // =================================================================== @@ -7278,7 +7700,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[27]); + file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[29]); } // @@protoc_insertion_point(namespace_scope) @@ -7386,6 +7808,14 @@ template<> PROTOBUF_NOINLINE ::greptime::v1::region::FlushRequest* Arena::CreateMaybeMessage< ::greptime::v1::region::FlushRequest >(Arena* arena) { return Arena::CreateMessageInternal< ::greptime::v1::region::FlushRequest >(arena); } +template<> PROTOBUF_NOINLINE ::greptime::v1::region::Regular* +Arena::CreateMaybeMessage< ::greptime::v1::region::Regular >(Arena* arena) { + return Arena::CreateMessageInternal< ::greptime::v1::region::Regular >(arena); +} +template<> PROTOBUF_NOINLINE ::greptime::v1::region::StrictWindow* +Arena::CreateMaybeMessage< ::greptime::v1::region::StrictWindow >(Arena* arena) { + return Arena::CreateMessageInternal< ::greptime::v1::region::StrictWindow >(arena); +} template<> PROTOBUF_NOINLINE ::greptime::v1::region::CompactRequest* Arena::CreateMaybeMessage< ::greptime::v1::region::CompactRequest >(Arena* arena) { return Arena::CreateMessageInternal< ::greptime::v1::region::CompactRequest >(arena); diff --git a/c++/greptime/v1/region/server.pb.h b/c++/greptime/v1/region/server.pb.h index 5508d5bb..c4a953c6 100644 --- a/c++/greptime/v1/region/server.pb.h +++ b/c++/greptime/v1/region/server.pb.h @@ -23,6 +23,7 @@ #include #include #include +#include #include #include #include @@ -134,6 +135,12 @@ extern RegionResponseDefaultTypeInternal _RegionResponse_default_instance_; class RegionResponse_ExtensionEntry_DoNotUse; struct RegionResponse_ExtensionEntry_DoNotUseDefaultTypeInternal; extern RegionResponse_ExtensionEntry_DoNotUseDefaultTypeInternal _RegionResponse_ExtensionEntry_DoNotUse_default_instance_; +class Regular; +struct RegularDefaultTypeInternal; +extern RegularDefaultTypeInternal _Regular_default_instance_; +class StrictWindow; +struct StrictWindowDefaultTypeInternal; +extern StrictWindowDefaultTypeInternal _StrictWindow_default_instance_; class TruncateRequest; struct TruncateRequestDefaultTypeInternal; extern TruncateRequestDefaultTypeInternal _TruncateRequest_default_instance_; @@ -168,6 +175,8 @@ template<> ::greptime::v1::region::RegionRequestHeader* Arena::CreateMaybeMessag 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::Regular* Arena::CreateMaybeMessage<::greptime::v1::region::Regular>(Arena*); +template<> ::greptime::v1::region::StrictWindow* Arena::CreateMaybeMessage<::greptime::v1::region::StrictWindow>(Arena*); template<> ::greptime::v1::region::TruncateRequest* Arena::CreateMaybeMessage<::greptime::v1::region::TruncateRequest>(Arena*); PROTOBUF_NAMESPACE_CLOSE namespace greptime { @@ -4227,6 +4236,272 @@ class FlushRequest final : }; // ------------------------------------------------------------------- +class Regular final : + public ::PROTOBUF_NAMESPACE_ID::internal::ZeroFieldsBase /* @@protoc_insertion_point(class_definition:greptime.v1.region.Regular) */ { + public: + inline Regular() : Regular(nullptr) {} + explicit PROTOBUF_CONSTEXPR Regular(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized); + + Regular(const Regular& from); + Regular(Regular&& from) noexcept + : Regular() { + *this = ::std::move(from); + } + + inline Regular& operator=(const Regular& from) { + CopyFrom(from); + return *this; + } + inline Regular& operator=(Regular&& from) noexcept { + if (this == &from) return *this; + if (GetOwningArena() == from.GetOwningArena() + #ifdef PROTOBUF_FORCE_COPY_IN_MOVE + && GetOwningArena() != nullptr + #endif // !PROTOBUF_FORCE_COPY_IN_MOVE + ) { + InternalSwap(&from); + } else { + CopyFrom(from); + } + return *this; + } + + static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() { + return GetDescriptor(); + } + static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() { + return default_instance().GetMetadata().descriptor; + } + static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() { + return default_instance().GetMetadata().reflection; + } + static const Regular& default_instance() { + return *internal_default_instance(); + } + static inline const Regular* internal_default_instance() { + return reinterpret_cast( + &_Regular_default_instance_); + } + static constexpr int kIndexInFileMessages = + 25; + + friend void swap(Regular& a, Regular& b) { + a.Swap(&b); + } + inline void Swap(Regular* other) { + if (other == this) return; + #ifdef PROTOBUF_FORCE_COPY_IN_SWAP + if (GetOwningArena() != nullptr && + GetOwningArena() == other->GetOwningArena()) { + #else // PROTOBUF_FORCE_COPY_IN_SWAP + if (GetOwningArena() == other->GetOwningArena()) { + #endif // !PROTOBUF_FORCE_COPY_IN_SWAP + InternalSwap(other); + } else { + ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other); + } + } + void UnsafeArenaSwap(Regular* other) { + if (other == this) return; + GOOGLE_DCHECK(GetOwningArena() == other->GetOwningArena()); + InternalSwap(other); + } + + // implements Message ---------------------------------------------- + + Regular* New(::PROTOBUF_NAMESPACE_ID::Arena* arena = nullptr) const final { + return CreateMaybeMessage(arena); + } + using ::PROTOBUF_NAMESPACE_ID::internal::ZeroFieldsBase::CopyFrom; + inline void CopyFrom(const Regular& from) { + ::PROTOBUF_NAMESPACE_ID::internal::ZeroFieldsBase::CopyImpl(*this, from); + } + using ::PROTOBUF_NAMESPACE_ID::internal::ZeroFieldsBase::MergeFrom; + void MergeFrom(const Regular& from) { + ::PROTOBUF_NAMESPACE_ID::internal::ZeroFieldsBase::MergeImpl(*this, from); + } + public: + + private: + friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata; + static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() { + return "greptime.v1.region.Regular"; + } + protected: + explicit Regular(::PROTOBUF_NAMESPACE_ID::Arena* arena, + bool is_message_owned = false); + public: + + static const ClassData _class_data_; + const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*GetClassData() const final; + + ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final; + + // nested types ---------------------------------------------------- + + // accessors ------------------------------------------------------- + + // @@protoc_insertion_point(class_scope:greptime.v1.region.Regular) + private: + class _Internal; + + template friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper; + typedef void InternalArenaConstructable_; + typedef void DestructorSkippable_; + struct Impl_ { + }; + friend struct ::TableStruct_greptime_2fv1_2fregion_2fserver_2eproto; +}; +// ------------------------------------------------------------------- + +class StrictWindow final : + public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:greptime.v1.region.StrictWindow) */ { + public: + inline StrictWindow() : StrictWindow(nullptr) {} + ~StrictWindow() override; + explicit PROTOBUF_CONSTEXPR StrictWindow(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized); + + StrictWindow(const StrictWindow& from); + StrictWindow(StrictWindow&& from) noexcept + : StrictWindow() { + *this = ::std::move(from); + } + + inline StrictWindow& operator=(const StrictWindow& from) { + CopyFrom(from); + return *this; + } + inline StrictWindow& operator=(StrictWindow&& from) noexcept { + if (this == &from) return *this; + if (GetOwningArena() == from.GetOwningArena() + #ifdef PROTOBUF_FORCE_COPY_IN_MOVE + && GetOwningArena() != nullptr + #endif // !PROTOBUF_FORCE_COPY_IN_MOVE + ) { + InternalSwap(&from); + } else { + CopyFrom(from); + } + return *this; + } + + static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() { + return GetDescriptor(); + } + static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() { + return default_instance().GetMetadata().descriptor; + } + static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() { + return default_instance().GetMetadata().reflection; + } + static const StrictWindow& default_instance() { + return *internal_default_instance(); + } + static inline const StrictWindow* internal_default_instance() { + return reinterpret_cast( + &_StrictWindow_default_instance_); + } + static constexpr int kIndexInFileMessages = + 26; + + friend void swap(StrictWindow& a, StrictWindow& b) { + a.Swap(&b); + } + inline void Swap(StrictWindow* other) { + if (other == this) return; + #ifdef PROTOBUF_FORCE_COPY_IN_SWAP + if (GetOwningArena() != nullptr && + GetOwningArena() == other->GetOwningArena()) { + #else // PROTOBUF_FORCE_COPY_IN_SWAP + if (GetOwningArena() == other->GetOwningArena()) { + #endif // !PROTOBUF_FORCE_COPY_IN_SWAP + InternalSwap(other); + } else { + ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other); + } + } + void UnsafeArenaSwap(StrictWindow* other) { + if (other == this) return; + GOOGLE_DCHECK(GetOwningArena() == other->GetOwningArena()); + InternalSwap(other); + } + + // implements Message ---------------------------------------------- + + StrictWindow* New(::PROTOBUF_NAMESPACE_ID::Arena* arena = nullptr) const final { + return CreateMaybeMessage(arena); + } + using ::PROTOBUF_NAMESPACE_ID::Message::CopyFrom; + void CopyFrom(const StrictWindow& from); + using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom; + void MergeFrom( const StrictWindow& from) { + StrictWindow::MergeImpl(*this, from); + } + private: + static void MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg); + public: + PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final; + bool IsInitialized() const final; + + size_t ByteSizeLong() const final; + const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final; + uint8_t* _InternalSerialize( + uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final; + int GetCachedSize() const final { return _impl_._cached_size_.Get(); } + + private: + void SharedCtor(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned); + void SharedDtor(); + void SetCachedSize(int size) const final; + void InternalSwap(StrictWindow* other); + + private: + friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata; + static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() { + return "greptime.v1.region.StrictWindow"; + } + protected: + explicit StrictWindow(::PROTOBUF_NAMESPACE_ID::Arena* arena, + bool is_message_owned = false); + public: + + static const ClassData _class_data_; + const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*GetClassData() const final; + + ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final; + + // nested types ---------------------------------------------------- + + // accessors ------------------------------------------------------- + + enum : int { + kWindowSecondsFieldNumber = 1, + }; + // int64 window_seconds = 1; + void clear_window_seconds(); + int64_t window_seconds() const; + void set_window_seconds(int64_t value); + private: + int64_t _internal_window_seconds() const; + void _internal_set_window_seconds(int64_t value); + public: + + // @@protoc_insertion_point(class_scope:greptime.v1.region.StrictWindow) + private: + class _Internal; + + template friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper; + typedef void InternalArenaConstructable_; + typedef void DestructorSkippable_; + struct Impl_ { + int64_t window_seconds_; + mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; + }; + union { Impl_ _impl_; }; + friend struct ::TableStruct_greptime_2fv1_2fregion_2fserver_2eproto; +}; +// ------------------------------------------------------------------- + class CompactRequest final : public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:greptime.v1.region.CompactRequest) */ { public: @@ -4270,12 +4545,18 @@ class CompactRequest final : static const CompactRequest& default_instance() { return *internal_default_instance(); } + enum OptionsCase { + kRegular = 2, + kStrictWindow = 3, + OPTIONS_NOT_SET = 0, + }; + static inline const CompactRequest* internal_default_instance() { return reinterpret_cast( &_CompactRequest_default_instance_); } static constexpr int kIndexInFileMessages = - 25; + 27; friend void swap(CompactRequest& a, CompactRequest& b) { a.Swap(&b); @@ -4349,6 +4630,8 @@ class CompactRequest final : enum : int { kRegionIdFieldNumber = 1, + kRegularFieldNumber = 2, + kStrictWindowFieldNumber = 3, }; // uint64 region_id = 1; void clear_region_id(); @@ -4359,16 +4642,67 @@ class CompactRequest final : void _internal_set_region_id(uint64_t value); public: + // .greptime.v1.region.Regular regular = 2; + bool has_regular() const; + private: + bool _internal_has_regular() const; + public: + void clear_regular(); + const ::greptime::v1::region::Regular& regular() const; + PROTOBUF_NODISCARD ::greptime::v1::region::Regular* release_regular(); + ::greptime::v1::region::Regular* mutable_regular(); + void set_allocated_regular(::greptime::v1::region::Regular* regular); + private: + const ::greptime::v1::region::Regular& _internal_regular() const; + ::greptime::v1::region::Regular* _internal_mutable_regular(); + public: + void unsafe_arena_set_allocated_regular( + ::greptime::v1::region::Regular* regular); + ::greptime::v1::region::Regular* unsafe_arena_release_regular(); + + // .greptime.v1.region.StrictWindow strict_window = 3; + bool has_strict_window() const; + private: + bool _internal_has_strict_window() const; + public: + void clear_strict_window(); + const ::greptime::v1::region::StrictWindow& strict_window() const; + PROTOBUF_NODISCARD ::greptime::v1::region::StrictWindow* release_strict_window(); + ::greptime::v1::region::StrictWindow* mutable_strict_window(); + void set_allocated_strict_window(::greptime::v1::region::StrictWindow* strict_window); + private: + const ::greptime::v1::region::StrictWindow& _internal_strict_window() const; + ::greptime::v1::region::StrictWindow* _internal_mutable_strict_window(); + public: + void unsafe_arena_set_allocated_strict_window( + ::greptime::v1::region::StrictWindow* strict_window); + ::greptime::v1::region::StrictWindow* unsafe_arena_release_strict_window(); + + void clear_options(); + OptionsCase options_case() const; // @@protoc_insertion_point(class_scope:greptime.v1.region.CompactRequest) private: class _Internal; + void set_has_regular(); + void set_has_strict_window(); + + inline bool has_options() const; + inline void clear_has_options(); template friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper; typedef void InternalArenaConstructable_; typedef void DestructorSkippable_; struct Impl_ { uint64_t region_id_; + union OptionsUnion { + constexpr OptionsUnion() : _constinit_{} {} + ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized _constinit_; + ::greptime::v1::region::Regular* regular_; + ::greptime::v1::region::StrictWindow* strict_window_; + } options_; mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; + uint32_t _oneof_case_[1]; + }; union { Impl_ _impl_; }; friend struct ::TableStruct_greptime_2fv1_2fregion_2fserver_2eproto; @@ -4423,7 +4757,7 @@ class TruncateRequest final : &_TruncateRequest_default_instance_); } static constexpr int kIndexInFileMessages = - 26; + 28; friend void swap(TruncateRequest& a, TruncateRequest& b) { a.Swap(&b); @@ -4571,7 +4905,7 @@ class RegionColumnDef final : &_RegionColumnDef_default_instance_); } static constexpr int kIndexInFileMessages = - 27; + 29; friend void swap(RegionColumnDef& a, RegionColumnDef& b) { a.Swap(&b); @@ -7732,6 +8066,34 @@ inline void FlushRequest::set_region_id(uint64_t value) { // ------------------------------------------------------------------- +// Regular + +// ------------------------------------------------------------------- + +// StrictWindow + +// int64 window_seconds = 1; +inline void StrictWindow::clear_window_seconds() { + _impl_.window_seconds_ = int64_t{0}; +} +inline int64_t StrictWindow::_internal_window_seconds() const { + return _impl_.window_seconds_; +} +inline int64_t StrictWindow::window_seconds() const { + // @@protoc_insertion_point(field_get:greptime.v1.region.StrictWindow.window_seconds) + return _internal_window_seconds(); +} +inline void StrictWindow::_internal_set_window_seconds(int64_t value) { + + _impl_.window_seconds_ = value; +} +inline void StrictWindow::set_window_seconds(int64_t value) { + _internal_set_window_seconds(value); + // @@protoc_insertion_point(field_set:greptime.v1.region.StrictWindow.window_seconds) +} + +// ------------------------------------------------------------------- + // CompactRequest // uint64 region_id = 1; @@ -7754,6 +8116,163 @@ inline void CompactRequest::set_region_id(uint64_t value) { // @@protoc_insertion_point(field_set:greptime.v1.region.CompactRequest.region_id) } +// .greptime.v1.region.Regular regular = 2; +inline bool CompactRequest::_internal_has_regular() const { + return options_case() == kRegular; +} +inline bool CompactRequest::has_regular() const { + return _internal_has_regular(); +} +inline void CompactRequest::set_has_regular() { + _impl_._oneof_case_[0] = kRegular; +} +inline void CompactRequest::clear_regular() { + if (_internal_has_regular()) { + if (GetArenaForAllocation() == nullptr) { + delete _impl_.options_.regular_; + } + clear_has_options(); + } +} +inline ::greptime::v1::region::Regular* CompactRequest::release_regular() { + // @@protoc_insertion_point(field_release:greptime.v1.region.CompactRequest.regular) + if (_internal_has_regular()) { + clear_has_options(); + ::greptime::v1::region::Regular* temp = _impl_.options_.regular_; + if (GetArenaForAllocation() != nullptr) { + temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp); + } + _impl_.options_.regular_ = nullptr; + return temp; + } else { + return nullptr; + } +} +inline const ::greptime::v1::region::Regular& CompactRequest::_internal_regular() const { + return _internal_has_regular() + ? *_impl_.options_.regular_ + : reinterpret_cast< ::greptime::v1::region::Regular&>(::greptime::v1::region::_Regular_default_instance_); +} +inline const ::greptime::v1::region::Regular& CompactRequest::regular() const { + // @@protoc_insertion_point(field_get:greptime.v1.region.CompactRequest.regular) + return _internal_regular(); +} +inline ::greptime::v1::region::Regular* CompactRequest::unsafe_arena_release_regular() { + // @@protoc_insertion_point(field_unsafe_arena_release:greptime.v1.region.CompactRequest.regular) + if (_internal_has_regular()) { + clear_has_options(); + ::greptime::v1::region::Regular* temp = _impl_.options_.regular_; + _impl_.options_.regular_ = nullptr; + return temp; + } else { + return nullptr; + } +} +inline void CompactRequest::unsafe_arena_set_allocated_regular(::greptime::v1::region::Regular* regular) { + clear_options(); + if (regular) { + set_has_regular(); + _impl_.options_.regular_ = regular; + } + // @@protoc_insertion_point(field_unsafe_arena_set_allocated:greptime.v1.region.CompactRequest.regular) +} +inline ::greptime::v1::region::Regular* CompactRequest::_internal_mutable_regular() { + if (!_internal_has_regular()) { + clear_options(); + set_has_regular(); + _impl_.options_.regular_ = CreateMaybeMessage< ::greptime::v1::region::Regular >(GetArenaForAllocation()); + } + return _impl_.options_.regular_; +} +inline ::greptime::v1::region::Regular* CompactRequest::mutable_regular() { + ::greptime::v1::region::Regular* _msg = _internal_mutable_regular(); + // @@protoc_insertion_point(field_mutable:greptime.v1.region.CompactRequest.regular) + return _msg; +} + +// .greptime.v1.region.StrictWindow strict_window = 3; +inline bool CompactRequest::_internal_has_strict_window() const { + return options_case() == kStrictWindow; +} +inline bool CompactRequest::has_strict_window() const { + return _internal_has_strict_window(); +} +inline void CompactRequest::set_has_strict_window() { + _impl_._oneof_case_[0] = kStrictWindow; +} +inline void CompactRequest::clear_strict_window() { + if (_internal_has_strict_window()) { + if (GetArenaForAllocation() == nullptr) { + delete _impl_.options_.strict_window_; + } + clear_has_options(); + } +} +inline ::greptime::v1::region::StrictWindow* CompactRequest::release_strict_window() { + // @@protoc_insertion_point(field_release:greptime.v1.region.CompactRequest.strict_window) + if (_internal_has_strict_window()) { + clear_has_options(); + ::greptime::v1::region::StrictWindow* temp = _impl_.options_.strict_window_; + if (GetArenaForAllocation() != nullptr) { + temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp); + } + _impl_.options_.strict_window_ = nullptr; + return temp; + } else { + return nullptr; + } +} +inline const ::greptime::v1::region::StrictWindow& CompactRequest::_internal_strict_window() const { + return _internal_has_strict_window() + ? *_impl_.options_.strict_window_ + : reinterpret_cast< ::greptime::v1::region::StrictWindow&>(::greptime::v1::region::_StrictWindow_default_instance_); +} +inline const ::greptime::v1::region::StrictWindow& CompactRequest::strict_window() const { + // @@protoc_insertion_point(field_get:greptime.v1.region.CompactRequest.strict_window) + return _internal_strict_window(); +} +inline ::greptime::v1::region::StrictWindow* CompactRequest::unsafe_arena_release_strict_window() { + // @@protoc_insertion_point(field_unsafe_arena_release:greptime.v1.region.CompactRequest.strict_window) + if (_internal_has_strict_window()) { + clear_has_options(); + ::greptime::v1::region::StrictWindow* temp = _impl_.options_.strict_window_; + _impl_.options_.strict_window_ = nullptr; + return temp; + } else { + return nullptr; + } +} +inline void CompactRequest::unsafe_arena_set_allocated_strict_window(::greptime::v1::region::StrictWindow* strict_window) { + clear_options(); + if (strict_window) { + set_has_strict_window(); + _impl_.options_.strict_window_ = strict_window; + } + // @@protoc_insertion_point(field_unsafe_arena_set_allocated:greptime.v1.region.CompactRequest.strict_window) +} +inline ::greptime::v1::region::StrictWindow* CompactRequest::_internal_mutable_strict_window() { + if (!_internal_has_strict_window()) { + clear_options(); + set_has_strict_window(); + _impl_.options_.strict_window_ = CreateMaybeMessage< ::greptime::v1::region::StrictWindow >(GetArenaForAllocation()); + } + return _impl_.options_.strict_window_; +} +inline ::greptime::v1::region::StrictWindow* CompactRequest::mutable_strict_window() { + ::greptime::v1::region::StrictWindow* _msg = _internal_mutable_strict_window(); + // @@protoc_insertion_point(field_mutable:greptime.v1.region.CompactRequest.strict_window) + return _msg; +} + +inline bool CompactRequest::has_options() const { + return options_case() != OPTIONS_NOT_SET; +} +inline void CompactRequest::clear_has_options() { + _impl_._oneof_case_[0] = OPTIONS_NOT_SET; +} +inline CompactRequest::OptionsCase CompactRequest::options_case() const { + return CompactRequest::OptionsCase(_impl_._oneof_case_[0]); +} // ------------------------------------------------------------------- // TruncateRequest @@ -7944,6 +8463,10 @@ 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 da5ca01a..0e986955 100644 --- a/java/src/main/java/io/greptime/v1/region/Server.java +++ b/java/src/main/java/io/greptime/v1/region/Server.java @@ -21198,6 +21198,933 @@ public io.greptime.v1.region.Server.FlushRequest getDefaultInstanceForType() { } + public interface RegularOrBuilder extends + // @@protoc_insertion_point(interface_extends:greptime.v1.region.Regular) + com.google.protobuf.MessageOrBuilder { + } + /** + * 
+   */ Regular compaction
+   *
+ * + * Protobuf type {@code greptime.v1.region.Regular} + */ + public static final class Regular extends + com.google.protobuf.GeneratedMessageV3 implements + // @@protoc_insertion_point(message_implements:greptime.v1.region.Regular) + RegularOrBuilder { + private static final long serialVersionUID = 0L; + // Use Regular.newBuilder() to construct. + private Regular(com.google.protobuf.GeneratedMessageV3.Builder builder) { + super(builder); + } + private Regular() { + } + + @java.lang.Override + @SuppressWarnings({"unused"}) + protected java.lang.Object newInstance( + UnusedPrivateParameter unused) { + return new Regular(); + } + + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet + getUnknownFields() { + return this.unknownFields; + } + private Regular( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + this(); + if (extensionRegistry == null) { + throw new java.lang.NullPointerException(); + } + com.google.protobuf.UnknownFieldSet.Builder unknownFields = + com.google.protobuf.UnknownFieldSet.newBuilder(); + try { + boolean done = false; + while (!done) { + int tag = input.readTag(); + switch (tag) { + case 0: + done = true; + break; + default: { + if (!parseUnknownField( + input, unknownFields, extensionRegistry, tag)) { + done = true; + } + break; + } + } + } + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(this); + } catch (com.google.protobuf.UninitializedMessageException e) { + throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException( + e).setUnfinishedMessage(this); + } finally { + this.unknownFields = unknownFields.build(); + makeExtensionsImmutable(); + } + } + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return io.greptime.v1.region.Server.internal_static_greptime_v1_region_Regular_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return io.greptime.v1.region.Server.internal_static_greptime_v1_region_Regular_fieldAccessorTable + .ensureFieldAccessorsInitialized( + io.greptime.v1.region.Server.Regular.class, io.greptime.v1.region.Server.Regular.Builder.class); + } + + private byte memoizedIsInitialized = -1; + @java.lang.Override + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized == 1) return true; + if (isInitialized == 0) return false; + + memoizedIsInitialized = 1; + return true; + } + + @java.lang.Override + public void writeTo(com.google.protobuf.CodedOutputStream output) + throws java.io.IOException { + unknownFields.writeTo(output); + } + + @java.lang.Override + public int getSerializedSize() { + int size = memoizedSize; + if (size != -1) return size; + + size = 0; + size += unknownFields.getSerializedSize(); + memoizedSize = size; + return size; + } + + @java.lang.Override + public boolean equals(final java.lang.Object obj) { + if (obj == this) { + return true; + } + if (!(obj instanceof io.greptime.v1.region.Server.Regular)) { + return super.equals(obj); + } + io.greptime.v1.region.Server.Regular other = (io.greptime.v1.region.Server.Regular) obj; + + if (!unknownFields.equals(other.unknownFields)) return false; + return true; + } + + @java.lang.Override + public int hashCode() { + if (memoizedHashCode != 0) { + return memoizedHashCode; + } + int hash = 41; + hash = (19 * hash) + getDescriptor().hashCode(); + hash = (29 * hash) + unknownFields.hashCode(); + memoizedHashCode = hash; + return hash; + } + + public static io.greptime.v1.region.Server.Regular parseFrom( + java.nio.ByteBuffer data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static io.greptime.v1.region.Server.Regular parseFrom( + java.nio.ByteBuffer data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static io.greptime.v1.region.Server.Regular parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static io.greptime.v1.region.Server.Regular parseFrom( + com.google.protobuf.ByteString data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static io.greptime.v1.region.Server.Regular parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static io.greptime.v1.region.Server.Regular parseFrom( + byte[] data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static io.greptime.v1.region.Server.Regular parseFrom(java.io.InputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input); + } + public static io.greptime.v1.region.Server.Regular parseFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input, extensionRegistry); + } + public static io.greptime.v1.region.Server.Regular parseDelimitedFrom(java.io.InputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseDelimitedWithIOException(PARSER, input); + } + public static io.greptime.v1.region.Server.Regular parseDelimitedFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseDelimitedWithIOException(PARSER, input, extensionRegistry); + } + public static io.greptime.v1.region.Server.Regular parseFrom( + com.google.protobuf.CodedInputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input); + } + public static io.greptime.v1.region.Server.Regular parseFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input, extensionRegistry); + } + + @java.lang.Override + public Builder newBuilderForType() { return newBuilder(); } + public static Builder newBuilder() { + return DEFAULT_INSTANCE.toBuilder(); + } + public static Builder newBuilder(io.greptime.v1.region.Server.Regular prototype) { + return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype); + } + @java.lang.Override + public Builder toBuilder() { + return this == DEFAULT_INSTANCE + ? new Builder() : new Builder().mergeFrom(this); + } + + @java.lang.Override + protected Builder newBuilderForType( + com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { + Builder builder = new Builder(parent); + return builder; + } + /** + * 
+     */ Regular compaction
+     *
+ * + * Protobuf type {@code greptime.v1.region.Regular} + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessageV3.Builder implements + // @@protoc_insertion_point(builder_implements:greptime.v1.region.Regular) + io.greptime.v1.region.Server.RegularOrBuilder { + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return io.greptime.v1.region.Server.internal_static_greptime_v1_region_Regular_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return io.greptime.v1.region.Server.internal_static_greptime_v1_region_Regular_fieldAccessorTable + .ensureFieldAccessorsInitialized( + io.greptime.v1.region.Server.Regular.class, io.greptime.v1.region.Server.Regular.Builder.class); + } + + // Construct using io.greptime.v1.region.Server.Regular.newBuilder() + private Builder() { + maybeForceBuilderInitialization(); + } + + private Builder( + com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { + super(parent); + maybeForceBuilderInitialization(); + } + private void maybeForceBuilderInitialization() { + if (com.google.protobuf.GeneratedMessageV3 + .alwaysUseFieldBuilders) { + } + } + @java.lang.Override + public Builder clear() { + super.clear(); + return this; + } + + @java.lang.Override + public com.google.protobuf.Descriptors.Descriptor + getDescriptorForType() { + return io.greptime.v1.region.Server.internal_static_greptime_v1_region_Regular_descriptor; + } + + @java.lang.Override + public io.greptime.v1.region.Server.Regular getDefaultInstanceForType() { + return io.greptime.v1.region.Server.Regular.getDefaultInstance(); + } + + @java.lang.Override + public io.greptime.v1.region.Server.Regular build() { + io.greptime.v1.region.Server.Regular result = buildPartial(); + if (!result.isInitialized()) { + throw newUninitializedMessageException(result); + } + return result; + } + + @java.lang.Override + public io.greptime.v1.region.Server.Regular buildPartial() { + io.greptime.v1.region.Server.Regular result = new io.greptime.v1.region.Server.Regular(this); + onBuilt(); + return result; + } + + @java.lang.Override + public Builder clone() { + return super.clone(); + } + @java.lang.Override + public Builder setField( + com.google.protobuf.Descriptors.FieldDescriptor field, + java.lang.Object value) { + return super.setField(field, value); + } + @java.lang.Override + public Builder clearField( + com.google.protobuf.Descriptors.FieldDescriptor field) { + return super.clearField(field); + } + @java.lang.Override + public Builder clearOneof( + com.google.protobuf.Descriptors.OneofDescriptor oneof) { + return super.clearOneof(oneof); + } + @java.lang.Override + public Builder setRepeatedField( + com.google.protobuf.Descriptors.FieldDescriptor field, + int index, java.lang.Object value) { + return super.setRepeatedField(field, index, value); + } + @java.lang.Override + public Builder addRepeatedField( + com.google.protobuf.Descriptors.FieldDescriptor field, + java.lang.Object value) { + return super.addRepeatedField(field, value); + } + @java.lang.Override + public Builder mergeFrom(com.google.protobuf.Message other) { + if (other instanceof io.greptime.v1.region.Server.Regular) { + return mergeFrom((io.greptime.v1.region.Server.Regular)other); + } else { + super.mergeFrom(other); + return this; + } + } + + public Builder mergeFrom(io.greptime.v1.region.Server.Regular other) { + if (other == io.greptime.v1.region.Server.Regular.getDefaultInstance()) return this; + this.mergeUnknownFields(other.unknownFields); + onChanged(); + return this; + } + + @java.lang.Override + public final boolean isInitialized() { + return true; + } + + @java.lang.Override + public Builder mergeFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + io.greptime.v1.region.Server.Regular parsedMessage = null; + try { + parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + parsedMessage = (io.greptime.v1.region.Server.Regular) e.getUnfinishedMessage(); + throw e.unwrapIOException(); + } finally { + if (parsedMessage != null) { + mergeFrom(parsedMessage); + } + } + return this; + } + @java.lang.Override + public final Builder setUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return super.setUnknownFields(unknownFields); + } + + @java.lang.Override + public final Builder mergeUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return super.mergeUnknownFields(unknownFields); + } + + + // @@protoc_insertion_point(builder_scope:greptime.v1.region.Regular) + } + + // @@protoc_insertion_point(class_scope:greptime.v1.region.Regular) + private static final io.greptime.v1.region.Server.Regular DEFAULT_INSTANCE; + static { + DEFAULT_INSTANCE = new io.greptime.v1.region.Server.Regular(); + } + + public static io.greptime.v1.region.Server.Regular getDefaultInstance() { + return DEFAULT_INSTANCE; + } + + private static final com.google.protobuf.Parser + PARSER = new com.google.protobuf.AbstractParser() { + @java.lang.Override + public Regular parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return new Regular(input, extensionRegistry); + } + }; + + public static com.google.protobuf.Parser parser() { + return PARSER; + } + + @java.lang.Override + public com.google.protobuf.Parser getParserForType() { + return PARSER; + } + + @java.lang.Override + public io.greptime.v1.region.Server.Regular getDefaultInstanceForType() { + return DEFAULT_INSTANCE; + } + + } + + public interface StrictWindowOrBuilder extends + // @@protoc_insertion_point(interface_extends:greptime.v1.region.StrictWindow) + com.google.protobuf.MessageOrBuilder { + + /** + * int64 window_seconds = 1; + * @return The windowSeconds. + */ + long getWindowSeconds(); + } + /** + * 
+   */ Strictly-windowed compaction.
+   *
+ * + * Protobuf type {@code greptime.v1.region.StrictWindow} + */ + public static final class StrictWindow extends + com.google.protobuf.GeneratedMessageV3 implements + // @@protoc_insertion_point(message_implements:greptime.v1.region.StrictWindow) + StrictWindowOrBuilder { + private static final long serialVersionUID = 0L; + // Use StrictWindow.newBuilder() to construct. + private StrictWindow(com.google.protobuf.GeneratedMessageV3.Builder builder) { + super(builder); + } + private StrictWindow() { + } + + @java.lang.Override + @SuppressWarnings({"unused"}) + protected java.lang.Object newInstance( + UnusedPrivateParameter unused) { + return new StrictWindow(); + } + + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet + getUnknownFields() { + return this.unknownFields; + } + private StrictWindow( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + this(); + if (extensionRegistry == null) { + throw new java.lang.NullPointerException(); + } + com.google.protobuf.UnknownFieldSet.Builder unknownFields = + com.google.protobuf.UnknownFieldSet.newBuilder(); + try { + boolean done = false; + while (!done) { + int tag = input.readTag(); + switch (tag) { + case 0: + done = true; + break; + case 8: { + + windowSeconds_ = input.readInt64(); + break; + } + default: { + if (!parseUnknownField( + input, unknownFields, extensionRegistry, tag)) { + done = true; + } + break; + } + } + } + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(this); + } catch (com.google.protobuf.UninitializedMessageException e) { + throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException( + e).setUnfinishedMessage(this); + } finally { + this.unknownFields = unknownFields.build(); + makeExtensionsImmutable(); + } + } + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return io.greptime.v1.region.Server.internal_static_greptime_v1_region_StrictWindow_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return io.greptime.v1.region.Server.internal_static_greptime_v1_region_StrictWindow_fieldAccessorTable + .ensureFieldAccessorsInitialized( + io.greptime.v1.region.Server.StrictWindow.class, io.greptime.v1.region.Server.StrictWindow.Builder.class); + } + + public static final int WINDOW_SECONDS_FIELD_NUMBER = 1; + private long windowSeconds_; + /** + * int64 window_seconds = 1; + * @return The windowSeconds. + */ + @java.lang.Override + public long getWindowSeconds() { + return windowSeconds_; + } + + private byte memoizedIsInitialized = -1; + @java.lang.Override + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized == 1) return true; + if (isInitialized == 0) return false; + + memoizedIsInitialized = 1; + return true; + } + + @java.lang.Override + public void writeTo(com.google.protobuf.CodedOutputStream output) + throws java.io.IOException { + if (windowSeconds_ != 0L) { + output.writeInt64(1, windowSeconds_); + } + unknownFields.writeTo(output); + } + + @java.lang.Override + public int getSerializedSize() { + int size = memoizedSize; + if (size != -1) return size; + + size = 0; + if (windowSeconds_ != 0L) { + size += com.google.protobuf.CodedOutputStream + .computeInt64Size(1, windowSeconds_); + } + size += unknownFields.getSerializedSize(); + memoizedSize = size; + return size; + } + + @java.lang.Override + public boolean equals(final java.lang.Object obj) { + if (obj == this) { + return true; + } + if (!(obj instanceof io.greptime.v1.region.Server.StrictWindow)) { + return super.equals(obj); + } + io.greptime.v1.region.Server.StrictWindow other = (io.greptime.v1.region.Server.StrictWindow) obj; + + if (getWindowSeconds() + != other.getWindowSeconds()) return false; + if (!unknownFields.equals(other.unknownFields)) return false; + return true; + } + + @java.lang.Override + public int hashCode() { + if (memoizedHashCode != 0) { + return memoizedHashCode; + } + int hash = 41; + hash = (19 * hash) + getDescriptor().hashCode(); + hash = (37 * hash) + WINDOW_SECONDS_FIELD_NUMBER; + hash = (53 * hash) + com.google.protobuf.Internal.hashLong( + getWindowSeconds()); + hash = (29 * hash) + unknownFields.hashCode(); + memoizedHashCode = hash; + return hash; + } + + public static io.greptime.v1.region.Server.StrictWindow parseFrom( + java.nio.ByteBuffer data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static io.greptime.v1.region.Server.StrictWindow parseFrom( + java.nio.ByteBuffer data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static io.greptime.v1.region.Server.StrictWindow parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static io.greptime.v1.region.Server.StrictWindow parseFrom( + com.google.protobuf.ByteString data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static io.greptime.v1.region.Server.StrictWindow parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static io.greptime.v1.region.Server.StrictWindow parseFrom( + byte[] data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static io.greptime.v1.region.Server.StrictWindow parseFrom(java.io.InputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input); + } + public static io.greptime.v1.region.Server.StrictWindow parseFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input, extensionRegistry); + } + public static io.greptime.v1.region.Server.StrictWindow parseDelimitedFrom(java.io.InputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseDelimitedWithIOException(PARSER, input); + } + public static io.greptime.v1.region.Server.StrictWindow parseDelimitedFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseDelimitedWithIOException(PARSER, input, extensionRegistry); + } + public static io.greptime.v1.region.Server.StrictWindow parseFrom( + com.google.protobuf.CodedInputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input); + } + public static io.greptime.v1.region.Server.StrictWindow parseFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input, extensionRegistry); + } + + @java.lang.Override + public Builder newBuilderForType() { return newBuilder(); } + public static Builder newBuilder() { + return DEFAULT_INSTANCE.toBuilder(); + } + public static Builder newBuilder(io.greptime.v1.region.Server.StrictWindow prototype) { + return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype); + } + @java.lang.Override + public Builder toBuilder() { + return this == DEFAULT_INSTANCE + ? new Builder() : new Builder().mergeFrom(this); + } + + @java.lang.Override + protected Builder newBuilderForType( + com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { + Builder builder = new Builder(parent); + return builder; + } + /** + * 
+     */ Strictly-windowed compaction.
+     *
+ * + * Protobuf type {@code greptime.v1.region.StrictWindow} + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessageV3.Builder implements + // @@protoc_insertion_point(builder_implements:greptime.v1.region.StrictWindow) + io.greptime.v1.region.Server.StrictWindowOrBuilder { + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return io.greptime.v1.region.Server.internal_static_greptime_v1_region_StrictWindow_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return io.greptime.v1.region.Server.internal_static_greptime_v1_region_StrictWindow_fieldAccessorTable + .ensureFieldAccessorsInitialized( + io.greptime.v1.region.Server.StrictWindow.class, io.greptime.v1.region.Server.StrictWindow.Builder.class); + } + + // Construct using io.greptime.v1.region.Server.StrictWindow.newBuilder() + private Builder() { + maybeForceBuilderInitialization(); + } + + private Builder( + com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { + super(parent); + maybeForceBuilderInitialization(); + } + private void maybeForceBuilderInitialization() { + if (com.google.protobuf.GeneratedMessageV3 + .alwaysUseFieldBuilders) { + } + } + @java.lang.Override + public Builder clear() { + super.clear(); + windowSeconds_ = 0L; + + return this; + } + + @java.lang.Override + public com.google.protobuf.Descriptors.Descriptor + getDescriptorForType() { + return io.greptime.v1.region.Server.internal_static_greptime_v1_region_StrictWindow_descriptor; + } + + @java.lang.Override + public io.greptime.v1.region.Server.StrictWindow getDefaultInstanceForType() { + return io.greptime.v1.region.Server.StrictWindow.getDefaultInstance(); + } + + @java.lang.Override + public io.greptime.v1.region.Server.StrictWindow build() { + io.greptime.v1.region.Server.StrictWindow result = buildPartial(); + if (!result.isInitialized()) { + throw newUninitializedMessageException(result); + } + return result; + } + + @java.lang.Override + public io.greptime.v1.region.Server.StrictWindow buildPartial() { + io.greptime.v1.region.Server.StrictWindow result = new io.greptime.v1.region.Server.StrictWindow(this); + result.windowSeconds_ = windowSeconds_; + onBuilt(); + return result; + } + + @java.lang.Override + public Builder clone() { + return super.clone(); + } + @java.lang.Override + public Builder setField( + com.google.protobuf.Descriptors.FieldDescriptor field, + java.lang.Object value) { + return super.setField(field, value); + } + @java.lang.Override + public Builder clearField( + com.google.protobuf.Descriptors.FieldDescriptor field) { + return super.clearField(field); + } + @java.lang.Override + public Builder clearOneof( + com.google.protobuf.Descriptors.OneofDescriptor oneof) { + return super.clearOneof(oneof); + } + @java.lang.Override + public Builder setRepeatedField( + com.google.protobuf.Descriptors.FieldDescriptor field, + int index, java.lang.Object value) { + return super.setRepeatedField(field, index, value); + } + @java.lang.Override + public Builder addRepeatedField( + com.google.protobuf.Descriptors.FieldDescriptor field, + java.lang.Object value) { + return super.addRepeatedField(field, value); + } + @java.lang.Override + public Builder mergeFrom(com.google.protobuf.Message other) { + if (other instanceof io.greptime.v1.region.Server.StrictWindow) { + return mergeFrom((io.greptime.v1.region.Server.StrictWindow)other); + } else { + super.mergeFrom(other); + return this; + } + } + + public Builder mergeFrom(io.greptime.v1.region.Server.StrictWindow other) { + if (other == io.greptime.v1.region.Server.StrictWindow.getDefaultInstance()) return this; + if (other.getWindowSeconds() != 0L) { + setWindowSeconds(other.getWindowSeconds()); + } + this.mergeUnknownFields(other.unknownFields); + onChanged(); + return this; + } + + @java.lang.Override + public final boolean isInitialized() { + return true; + } + + @java.lang.Override + public Builder mergeFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + io.greptime.v1.region.Server.StrictWindow parsedMessage = null; + try { + parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + parsedMessage = (io.greptime.v1.region.Server.StrictWindow) e.getUnfinishedMessage(); + throw e.unwrapIOException(); + } finally { + if (parsedMessage != null) { + mergeFrom(parsedMessage); + } + } + return this; + } + + private long windowSeconds_ ; + /** + * int64 window_seconds = 1; + * @return The windowSeconds. + */ + @java.lang.Override + public long getWindowSeconds() { + return windowSeconds_; + } + /** + * int64 window_seconds = 1; + * @param value The windowSeconds to set. + * @return This builder for chaining. + */ + public Builder setWindowSeconds(long value) { + + windowSeconds_ = value; + onChanged(); + return this; + } + /** + * int64 window_seconds = 1; + * @return This builder for chaining. + */ + public Builder clearWindowSeconds() { + + windowSeconds_ = 0L; + onChanged(); + return this; + } + @java.lang.Override + public final Builder setUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return super.setUnknownFields(unknownFields); + } + + @java.lang.Override + public final Builder mergeUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return super.mergeUnknownFields(unknownFields); + } + + + // @@protoc_insertion_point(builder_scope:greptime.v1.region.StrictWindow) + } + + // @@protoc_insertion_point(class_scope:greptime.v1.region.StrictWindow) + private static final io.greptime.v1.region.Server.StrictWindow DEFAULT_INSTANCE; + static { + DEFAULT_INSTANCE = new io.greptime.v1.region.Server.StrictWindow(); + } + + public static io.greptime.v1.region.Server.StrictWindow getDefaultInstance() { + return DEFAULT_INSTANCE; + } + + private static final com.google.protobuf.Parser + PARSER = new com.google.protobuf.AbstractParser() { + @java.lang.Override + public StrictWindow parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return new StrictWindow(input, extensionRegistry); + } + }; + + public static com.google.protobuf.Parser parser() { + return PARSER; + } + + @java.lang.Override + public com.google.protobuf.Parser getParserForType() { + return PARSER; + } + + @java.lang.Override + public io.greptime.v1.region.Server.StrictWindow getDefaultInstanceForType() { + return DEFAULT_INSTANCE; + } + + } + public interface CompactRequestOrBuilder extends // @@protoc_insertion_point(interface_extends:greptime.v1.region.CompactRequest) com.google.protobuf.MessageOrBuilder { @@ -21207,6 +22134,38 @@ public interface CompactRequestOrBuilder extends * @return The regionId. */ long getRegionId(); + + /** + * .greptime.v1.region.Regular regular = 2; + * @return Whether the regular field is set. + */ + boolean hasRegular(); + /** + * .greptime.v1.region.Regular regular = 2; + * @return The regular. + */ + io.greptime.v1.region.Server.Regular getRegular(); + /** + * .greptime.v1.region.Regular regular = 2; + */ + io.greptime.v1.region.Server.RegularOrBuilder getRegularOrBuilder(); + + /** + * .greptime.v1.region.StrictWindow strict_window = 3; + * @return Whether the strictWindow field is set. + */ + boolean hasStrictWindow(); + /** + * .greptime.v1.region.StrictWindow strict_window = 3; + * @return The strictWindow. + */ + io.greptime.v1.region.Server.StrictWindow getStrictWindow(); + /** + * .greptime.v1.region.StrictWindow strict_window = 3; + */ + io.greptime.v1.region.Server.StrictWindowOrBuilder getStrictWindowOrBuilder(); + + public io.greptime.v1.region.Server.CompactRequest.OptionsCase getOptionsCase(); } /** * Protobuf type {@code greptime.v1.region.CompactRequest} @@ -21258,6 +22217,34 @@ private CompactRequest( regionId_ = input.readUInt64(); break; } + case 18: { + io.greptime.v1.region.Server.Regular.Builder subBuilder = null; + if (optionsCase_ == 2) { + subBuilder = ((io.greptime.v1.region.Server.Regular) options_).toBuilder(); + } + options_ = + input.readMessage(io.greptime.v1.region.Server.Regular.parser(), extensionRegistry); + if (subBuilder != null) { + subBuilder.mergeFrom((io.greptime.v1.region.Server.Regular) options_); + options_ = subBuilder.buildPartial(); + } + optionsCase_ = 2; + break; + } + case 26: { + io.greptime.v1.region.Server.StrictWindow.Builder subBuilder = null; + if (optionsCase_ == 3) { + subBuilder = ((io.greptime.v1.region.Server.StrictWindow) options_).toBuilder(); + } + options_ = + input.readMessage(io.greptime.v1.region.Server.StrictWindow.parser(), extensionRegistry); + if (subBuilder != null) { + subBuilder.mergeFrom((io.greptime.v1.region.Server.StrictWindow) options_); + options_ = subBuilder.buildPartial(); + } + optionsCase_ = 3; + break; + } default: { if (!parseUnknownField( input, unknownFields, extensionRegistry, tag)) { @@ -21292,6 +22279,47 @@ private CompactRequest( io.greptime.v1.region.Server.CompactRequest.class, io.greptime.v1.region.Server.CompactRequest.Builder.class); } + private int optionsCase_ = 0; + private java.lang.Object options_; + public enum OptionsCase + implements com.google.protobuf.Internal.EnumLite, + com.google.protobuf.AbstractMessage.InternalOneOfEnum { + REGULAR(2), + STRICT_WINDOW(3), + OPTIONS_NOT_SET(0); + private final int value; + private OptionsCase(int value) { + this.value = value; + } + /** + * @param value The number of the enum to look for. + * @return The enum associated with the given number. + * @deprecated Use {@link #forNumber(int)} instead. + */ + @java.lang.Deprecated + public static OptionsCase valueOf(int value) { + return forNumber(value); + } + + public static OptionsCase forNumber(int value) { + switch (value) { + case 2: return REGULAR; + case 3: return STRICT_WINDOW; + case 0: return OPTIONS_NOT_SET; + default: return null; + } + } + public int getNumber() { + return this.value; + } + }; + + public OptionsCase + getOptionsCase() { + return OptionsCase.forNumber( + optionsCase_); + } + public static final int REGION_ID_FIELD_NUMBER = 1; private long regionId_; /** @@ -21303,6 +22331,68 @@ public long getRegionId() { return regionId_; } + public static final int REGULAR_FIELD_NUMBER = 2; + /** + * .greptime.v1.region.Regular regular = 2; + * @return Whether the regular field is set. + */ + @java.lang.Override + public boolean hasRegular() { + return optionsCase_ == 2; + } + /** + * .greptime.v1.region.Regular regular = 2; + * @return The regular. + */ + @java.lang.Override + public io.greptime.v1.region.Server.Regular getRegular() { + if (optionsCase_ == 2) { + return (io.greptime.v1.region.Server.Regular) options_; + } + return io.greptime.v1.region.Server.Regular.getDefaultInstance(); + } + /** + * .greptime.v1.region.Regular regular = 2; + */ + @java.lang.Override + public io.greptime.v1.region.Server.RegularOrBuilder getRegularOrBuilder() { + if (optionsCase_ == 2) { + return (io.greptime.v1.region.Server.Regular) options_; + } + return io.greptime.v1.region.Server.Regular.getDefaultInstance(); + } + + public static final int STRICT_WINDOW_FIELD_NUMBER = 3; + /** + * .greptime.v1.region.StrictWindow strict_window = 3; + * @return Whether the strictWindow field is set. + */ + @java.lang.Override + public boolean hasStrictWindow() { + return optionsCase_ == 3; + } + /** + * .greptime.v1.region.StrictWindow strict_window = 3; + * @return The strictWindow. + */ + @java.lang.Override + public io.greptime.v1.region.Server.StrictWindow getStrictWindow() { + if (optionsCase_ == 3) { + return (io.greptime.v1.region.Server.StrictWindow) options_; + } + return io.greptime.v1.region.Server.StrictWindow.getDefaultInstance(); + } + /** + * .greptime.v1.region.StrictWindow strict_window = 3; + */ + @java.lang.Override + public io.greptime.v1.region.Server.StrictWindowOrBuilder getStrictWindowOrBuilder() { + if (optionsCase_ == 3) { + return (io.greptime.v1.region.Server.StrictWindow) options_; + } + return io.greptime.v1.region.Server.StrictWindow.getDefaultInstance(); + } + private byte memoizedIsInitialized = -1; @java.lang.Override public final boolean isInitialized() { @@ -21320,6 +22410,12 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) if (regionId_ != 0L) { output.writeUInt64(1, regionId_); } + if (optionsCase_ == 2) { + output.writeMessage(2, (io.greptime.v1.region.Server.Regular) options_); + } + if (optionsCase_ == 3) { + output.writeMessage(3, (io.greptime.v1.region.Server.StrictWindow) options_); + } unknownFields.writeTo(output); } @@ -21333,6 +22429,14 @@ public int getSerializedSize() { size += com.google.protobuf.CodedOutputStream .computeUInt64Size(1, regionId_); } + if (optionsCase_ == 2) { + size += com.google.protobuf.CodedOutputStream + .computeMessageSize(2, (io.greptime.v1.region.Server.Regular) options_); + } + if (optionsCase_ == 3) { + size += com.google.protobuf.CodedOutputStream + .computeMessageSize(3, (io.greptime.v1.region.Server.StrictWindow) options_); + } size += unknownFields.getSerializedSize(); memoizedSize = size; return size; @@ -21350,6 +22454,19 @@ public boolean equals(final java.lang.Object obj) { if (getRegionId() != other.getRegionId()) return false; + if (!getOptionsCase().equals(other.getOptionsCase())) return false; + switch (optionsCase_) { + case 2: + if (!getRegular() + .equals(other.getRegular())) return false; + break; + case 3: + if (!getStrictWindow() + .equals(other.getStrictWindow())) return false; + break; + case 0: + default: + } if (!unknownFields.equals(other.unknownFields)) return false; return true; } @@ -21364,6 +22481,18 @@ public int hashCode() { hash = (37 * hash) + REGION_ID_FIELD_NUMBER; hash = (53 * hash) + com.google.protobuf.Internal.hashLong( getRegionId()); + switch (optionsCase_) { + case 2: + hash = (37 * hash) + REGULAR_FIELD_NUMBER; + hash = (53 * hash) + getRegular().hashCode(); + break; + case 3: + hash = (37 * hash) + STRICT_WINDOW_FIELD_NUMBER; + hash = (53 * hash) + getStrictWindow().hashCode(); + break; + case 0: + default: + } hash = (29 * hash) + unknownFields.hashCode(); memoizedHashCode = hash; return hash; @@ -21499,6 +22628,8 @@ public Builder clear() { super.clear(); regionId_ = 0L; + optionsCase_ = 0; + options_ = null; return this; } @@ -21526,6 +22657,21 @@ public io.greptime.v1.region.Server.CompactRequest build() { public io.greptime.v1.region.Server.CompactRequest buildPartial() { io.greptime.v1.region.Server.CompactRequest result = new io.greptime.v1.region.Server.CompactRequest(this); result.regionId_ = regionId_; + if (optionsCase_ == 2) { + if (regularBuilder_ == null) { + result.options_ = options_; + } else { + result.options_ = regularBuilder_.build(); + } + } + if (optionsCase_ == 3) { + if (strictWindowBuilder_ == null) { + result.options_ = options_; + } else { + result.options_ = strictWindowBuilder_.build(); + } + } + result.optionsCase_ = optionsCase_; onBuilt(); return result; } @@ -21577,6 +22723,19 @@ public Builder mergeFrom(io.greptime.v1.region.Server.CompactRequest other) { if (other.getRegionId() != 0L) { setRegionId(other.getRegionId()); } + switch (other.getOptionsCase()) { + case REGULAR: { + mergeRegular(other.getRegular()); + break; + } + case STRICT_WINDOW: { + mergeStrictWindow(other.getStrictWindow()); + break; + } + case OPTIONS_NOT_SET: { + break; + } + } this.mergeUnknownFields(other.unknownFields); onChanged(); return this; @@ -21605,6 +22764,21 @@ public Builder mergeFrom( } return this; } + private int optionsCase_ = 0; + private java.lang.Object options_; + public OptionsCase + getOptionsCase() { + return OptionsCase.forNumber( + optionsCase_); + } + + public Builder clearOptions() { + optionsCase_ = 0; + options_ = null; + onChanged(); + return this; + } + private long regionId_ ; /** @@ -21636,6 +22810,290 @@ public Builder clearRegionId() { onChanged(); return this; } + + private com.google.protobuf.SingleFieldBuilderV3< + io.greptime.v1.region.Server.Regular, io.greptime.v1.region.Server.Regular.Builder, io.greptime.v1.region.Server.RegularOrBuilder> regularBuilder_; + /** + * .greptime.v1.region.Regular regular = 2; + * @return Whether the regular field is set. + */ + @java.lang.Override + public boolean hasRegular() { + return optionsCase_ == 2; + } + /** + * .greptime.v1.region.Regular regular = 2; + * @return The regular. + */ + @java.lang.Override + public io.greptime.v1.region.Server.Regular getRegular() { + if (regularBuilder_ == null) { + if (optionsCase_ == 2) { + return (io.greptime.v1.region.Server.Regular) options_; + } + return io.greptime.v1.region.Server.Regular.getDefaultInstance(); + } else { + if (optionsCase_ == 2) { + return regularBuilder_.getMessage(); + } + return io.greptime.v1.region.Server.Regular.getDefaultInstance(); + } + } + /** + * .greptime.v1.region.Regular regular = 2; + */ + public Builder setRegular(io.greptime.v1.region.Server.Regular value) { + if (regularBuilder_ == null) { + if (value == null) { + throw new NullPointerException(); + } + options_ = value; + onChanged(); + } else { + regularBuilder_.setMessage(value); + } + optionsCase_ = 2; + return this; + } + /** + * .greptime.v1.region.Regular regular = 2; + */ + public Builder setRegular( + io.greptime.v1.region.Server.Regular.Builder builderForValue) { + if (regularBuilder_ == null) { + options_ = builderForValue.build(); + onChanged(); + } else { + regularBuilder_.setMessage(builderForValue.build()); + } + optionsCase_ = 2; + return this; + } + /** + * .greptime.v1.region.Regular regular = 2; + */ + public Builder mergeRegular(io.greptime.v1.region.Server.Regular value) { + if (regularBuilder_ == null) { + if (optionsCase_ == 2 && + options_ != io.greptime.v1.region.Server.Regular.getDefaultInstance()) { + options_ = io.greptime.v1.region.Server.Regular.newBuilder((io.greptime.v1.region.Server.Regular) options_) + .mergeFrom(value).buildPartial(); + } else { + options_ = value; + } + onChanged(); + } else { + if (optionsCase_ == 2) { + regularBuilder_.mergeFrom(value); + } else { + regularBuilder_.setMessage(value); + } + } + optionsCase_ = 2; + return this; + } + /** + * .greptime.v1.region.Regular regular = 2; + */ + public Builder clearRegular() { + if (regularBuilder_ == null) { + if (optionsCase_ == 2) { + optionsCase_ = 0; + options_ = null; + onChanged(); + } + } else { + if (optionsCase_ == 2) { + optionsCase_ = 0; + options_ = null; + } + regularBuilder_.clear(); + } + return this; + } + /** + * .greptime.v1.region.Regular regular = 2; + */ + public io.greptime.v1.region.Server.Regular.Builder getRegularBuilder() { + return getRegularFieldBuilder().getBuilder(); + } + /** + * .greptime.v1.region.Regular regular = 2; + */ + @java.lang.Override + public io.greptime.v1.region.Server.RegularOrBuilder getRegularOrBuilder() { + if ((optionsCase_ == 2) && (regularBuilder_ != null)) { + return regularBuilder_.getMessageOrBuilder(); + } else { + if (optionsCase_ == 2) { + return (io.greptime.v1.region.Server.Regular) options_; + } + return io.greptime.v1.region.Server.Regular.getDefaultInstance(); + } + } + /** + * .greptime.v1.region.Regular regular = 2; + */ + private com.google.protobuf.SingleFieldBuilderV3< + io.greptime.v1.region.Server.Regular, io.greptime.v1.region.Server.Regular.Builder, io.greptime.v1.region.Server.RegularOrBuilder> + getRegularFieldBuilder() { + if (regularBuilder_ == null) { + if (!(optionsCase_ == 2)) { + options_ = io.greptime.v1.region.Server.Regular.getDefaultInstance(); + } + regularBuilder_ = new com.google.protobuf.SingleFieldBuilderV3< + io.greptime.v1.region.Server.Regular, io.greptime.v1.region.Server.Regular.Builder, io.greptime.v1.region.Server.RegularOrBuilder>( + (io.greptime.v1.region.Server.Regular) options_, + getParentForChildren(), + isClean()); + options_ = null; + } + optionsCase_ = 2; + onChanged();; + return regularBuilder_; + } + + private com.google.protobuf.SingleFieldBuilderV3< + io.greptime.v1.region.Server.StrictWindow, io.greptime.v1.region.Server.StrictWindow.Builder, io.greptime.v1.region.Server.StrictWindowOrBuilder> strictWindowBuilder_; + /** + * .greptime.v1.region.StrictWindow strict_window = 3; + * @return Whether the strictWindow field is set. + */ + @java.lang.Override + public boolean hasStrictWindow() { + return optionsCase_ == 3; + } + /** + * .greptime.v1.region.StrictWindow strict_window = 3; + * @return The strictWindow. + */ + @java.lang.Override + public io.greptime.v1.region.Server.StrictWindow getStrictWindow() { + if (strictWindowBuilder_ == null) { + if (optionsCase_ == 3) { + return (io.greptime.v1.region.Server.StrictWindow) options_; + } + return io.greptime.v1.region.Server.StrictWindow.getDefaultInstance(); + } else { + if (optionsCase_ == 3) { + return strictWindowBuilder_.getMessage(); + } + return io.greptime.v1.region.Server.StrictWindow.getDefaultInstance(); + } + } + /** + * .greptime.v1.region.StrictWindow strict_window = 3; + */ + public Builder setStrictWindow(io.greptime.v1.region.Server.StrictWindow value) { + if (strictWindowBuilder_ == null) { + if (value == null) { + throw new NullPointerException(); + } + options_ = value; + onChanged(); + } else { + strictWindowBuilder_.setMessage(value); + } + optionsCase_ = 3; + return this; + } + /** + * .greptime.v1.region.StrictWindow strict_window = 3; + */ + public Builder setStrictWindow( + io.greptime.v1.region.Server.StrictWindow.Builder builderForValue) { + if (strictWindowBuilder_ == null) { + options_ = builderForValue.build(); + onChanged(); + } else { + strictWindowBuilder_.setMessage(builderForValue.build()); + } + optionsCase_ = 3; + return this; + } + /** + * .greptime.v1.region.StrictWindow strict_window = 3; + */ + public Builder mergeStrictWindow(io.greptime.v1.region.Server.StrictWindow value) { + if (strictWindowBuilder_ == null) { + if (optionsCase_ == 3 && + options_ != io.greptime.v1.region.Server.StrictWindow.getDefaultInstance()) { + options_ = io.greptime.v1.region.Server.StrictWindow.newBuilder((io.greptime.v1.region.Server.StrictWindow) options_) + .mergeFrom(value).buildPartial(); + } else { + options_ = value; + } + onChanged(); + } else { + if (optionsCase_ == 3) { + strictWindowBuilder_.mergeFrom(value); + } else { + strictWindowBuilder_.setMessage(value); + } + } + optionsCase_ = 3; + return this; + } + /** + * .greptime.v1.region.StrictWindow strict_window = 3; + */ + public Builder clearStrictWindow() { + if (strictWindowBuilder_ == null) { + if (optionsCase_ == 3) { + optionsCase_ = 0; + options_ = null; + onChanged(); + } + } else { + if (optionsCase_ == 3) { + optionsCase_ = 0; + options_ = null; + } + strictWindowBuilder_.clear(); + } + return this; + } + /** + * .greptime.v1.region.StrictWindow strict_window = 3; + */ + public io.greptime.v1.region.Server.StrictWindow.Builder getStrictWindowBuilder() { + return getStrictWindowFieldBuilder().getBuilder(); + } + /** + * .greptime.v1.region.StrictWindow strict_window = 3; + */ + @java.lang.Override + public io.greptime.v1.region.Server.StrictWindowOrBuilder getStrictWindowOrBuilder() { + if ((optionsCase_ == 3) && (strictWindowBuilder_ != null)) { + return strictWindowBuilder_.getMessageOrBuilder(); + } else { + if (optionsCase_ == 3) { + return (io.greptime.v1.region.Server.StrictWindow) options_; + } + return io.greptime.v1.region.Server.StrictWindow.getDefaultInstance(); + } + } + /** + * .greptime.v1.region.StrictWindow strict_window = 3; + */ + private com.google.protobuf.SingleFieldBuilderV3< + io.greptime.v1.region.Server.StrictWindow, io.greptime.v1.region.Server.StrictWindow.Builder, io.greptime.v1.region.Server.StrictWindowOrBuilder> + getStrictWindowFieldBuilder() { + if (strictWindowBuilder_ == null) { + if (!(optionsCase_ == 3)) { + options_ = io.greptime.v1.region.Server.StrictWindow.getDefaultInstance(); + } + strictWindowBuilder_ = new com.google.protobuf.SingleFieldBuilderV3< + io.greptime.v1.region.Server.StrictWindow, io.greptime.v1.region.Server.StrictWindow.Builder, io.greptime.v1.region.Server.StrictWindowOrBuilder>( + (io.greptime.v1.region.Server.StrictWindow) options_, + getParentForChildren(), + isClean()); + options_ = null; + } + optionsCase_ = 3; + onChanged();; + return strictWindowBuilder_; + } @java.lang.Override public final Builder setUnknownFields( final com.google.protobuf.UnknownFieldSet unknownFields) { @@ -23012,6 +24470,16 @@ public io.greptime.v1.region.Server.RegionColumnDef getDefaultInstanceForType() private static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_greptime_v1_region_FlushRequest_fieldAccessorTable; + private static final com.google.protobuf.Descriptors.Descriptor + internal_static_greptime_v1_region_Regular_descriptor; + private static final + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internal_static_greptime_v1_region_Regular_fieldAccessorTable; + private static final com.google.protobuf.Descriptors.Descriptor + internal_static_greptime_v1_region_StrictWindow_descriptor; + private static final + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internal_static_greptime_v1_region_StrictWindow_fieldAccessorTable; private static final com.google.protobuf.Descriptors.Descriptor internal_static_greptime_v1_region_CompactRequest_descriptor; private static final @@ -23110,16 +24578,20 @@ public io.greptime.v1.region.Server.RegionColumnDef getDefaultInstanceForType() "#.greptime.v1.region.RegionColumnDef\0220\n\010" + "location\030\003 \001(\0132\036.greptime.v1.AddColumnLo" + "cation\"\032\n\nDropColumn\022\014\n\004name\030\001 \001(\t\"!\n\014Fl" + - "ushRequest\022\021\n\tregion_id\030\001 \001(\004\"#\n\016Compact" + - "Request\022\021\n\tregion_id\030\001 \001(\004\"$\n\017TruncateRe" + - "quest\022\021\n\tregion_id\030\001 \001(\004\"P\n\017RegionColumn" + - "Def\022*\n\ncolumn_def\030\001 \001(\0132\026.greptime.v1.Co" + - "lumnDef\022\021\n\tcolumn_id\030\002 \001(\r2Y\n\006Region\022O\n\006" + - "Handle\022!.greptime.v1.region.RegionReques" + - "t\032\".greptime.v1.region.RegionResponseB]\n" + - "\025io.greptime.v1.regionB\006ServerZ