Dima/orion_greptime_proto
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

chore: add compaction paramaters (#169)

Browse Source 
* chore: add compaction paramaters

* fix: formatting and field names
This commit is contained in:
Lei, HUANG
2024-05-22 17:24:06 +08:00
committed by GitHub
parent e650f73c0b
commit 3cd71167ee
4 changed files with 2492 additions and 41 deletions
Download Patch File Download Diff File Expand all files Collapse all files
c++/greptime/v1/region/server.pb.cc
+453 -23
View File
@@ -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<github.c"
"om/GreptimeTeam/greptime-proto/go/grepti"
"me/v1/regionb\006proto3"
"ushRequest\022\021\n\tregion_id\030\001 \001(\004\"\t\n\007Regular"
"\"&\n\014StrictWindow\022\026\n\016window_seconds\030\001 \001(\003"
"\"\231\001\n\016CompactRequest\022\021\n\tregion_id\030\001 \001(\004\022."
"\n\007regular\030\002 \001(\0132\033.greptime.v1.region.Reg"
"ularH\000\0229\n\rstrict_window\030\003 \001(\0132 .greptime"
".v1.region.StrictWindowH\000B\t\n\007options\"$\n\017"
"TruncateRequest\022\021\n\tregion_id\030\001 \001(\004\"P\n\017Re"
"gionColumnDef\022*\n\ncolumn_def\030\001 \001(\0132\026.grep"
"time.v1.ColumnDef\022\021\n\tcolumn_id\030\002 \001(\r2Y\n\006"
"Region\022O\n\006Handle\022!.greptime.v1.region.Re"
"gionRequest\032\".greptime.v1.region.RegionR"
"esponseB]\n\025io.greptime.v1.regionB\006Server"
"Z<github.com/GreptimeTeam/greptime-proto"
"/go/greptime/v1/regionb\006proto3"
;
static const ::_pbi::DescriptorTable* const descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_deps[3] = {
&::descriptor_table_greptime_2fv1_2fcommon_2eproto,
@@ -812,9 +862,9 @@ static const ::_pbi::DescriptorTable* const descriptor_table_greptime_2fv1_2freg
};
static ::_pbi::once_flag descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once;
const ::_pbi::DescriptorTable descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto = {
false, false, 3340, descriptor_table_protodef_greptime_2fv1_2fregion_2fserver_2eproto,
false, false, 3510, descriptor_table_protodef_greptime_2fv1_2fregion_2fserver_2eproto,
"greptime/v1/region/server.proto",
&descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_deps, 3, 28,
&descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_deps, 3, 30,
schemas, file_default_instances, TableStruct_greptime_2fv1_2fregion_2fserver_2eproto::offsets,
file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto, file_level_enum_descriptors_greptime_2fv1_2fregion_2fserver_2eproto,
file_level_service_descriptors_greptime_2fv1_2fregion_2fserver_2eproto,
@@ -6697,10 +6747,268 @@ void FlushRequest::InternalSwap(FlushRequest* other) {
// ===================================================================
class CompactRequest::_Internal {
class Regular::_Internal {
public:
};
Regular::Regular(::PROTOBUF_NAMESPACE_ID::Arena* arena,
bool is_message_owned)
: ::PROTOBUF_NAMESPACE_ID::internal::ZeroFieldsBase(arena, is_message_owned) {
// @@protoc_insertion_point(arena_constructor:greptime.v1.region.Regular)
}
Regular::Regular(const Regular& from)
: ::PROTOBUF_NAMESPACE_ID::internal::ZeroFieldsBase() {
Regular* const _this = this; (void)_this;
_internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(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<uint8_t>(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<StrictWindow*>(&to_msg);
auto& from = static_cast<const StrictWindow&>(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<uint8_t>(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<uint8_t>(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);
c++/greptime/v1/region/server.pb.h
+526 -3
View File
@@ -23,6 +23,7 @@
#include <google/protobuf/io/coded_stream.h>
#include <google/protobuf/arena.h>
#include <google/protobuf/arenastring.h>
#include <google/protobuf/generated_message_bases.h>
#include <google/protobuf/generated_message_util.h>
#include <google/protobuf/metadata_lite.h>
#include <google/protobuf/generated_message_reflection.h>
@@ -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<const Regular*>(
&_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<Regular>(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 <typename T> 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<const StrictWindow*>(
&_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<StrictWindow>(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 <typename T> 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<const CompactRequest*>(
&_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 <typename T> 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)