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

feat: sst_min_sequences in QueryContext (#234)

Browse Source
This commit is contained in:
LFC
2025-05-07 20:59:51 +08:00
committed by GitHub
parent bdca8e50e4
commit 159e92d30b
5 changed files with 937 additions and 367 deletions
Download Patch File Download Diff File Expand all files Collapse all files
c++/greptime/v1/common.pb.h
+103 -19
View File
@@ -110,6 +110,9 @@ extern SnapshotSequencesDefaultTypeInternal _SnapshotSequences_default_instance_
class SnapshotSequences_SnapshotSeqsEntry_DoNotUse;
struct SnapshotSequences_SnapshotSeqsEntry_DoNotUseDefaultTypeInternal;
extern SnapshotSequences_SnapshotSeqsEntry_DoNotUseDefaultTypeInternal _SnapshotSequences_SnapshotSeqsEntry_DoNotUse_default_instance_;
class SnapshotSequences_SstMinSequencesEntry_DoNotUse;
struct SnapshotSequences_SstMinSequencesEntry_DoNotUseDefaultTypeInternal;
extern SnapshotSequences_SstMinSequencesEntry_DoNotUseDefaultTypeInternal _SnapshotSequences_SstMinSequencesEntry_DoNotUse_default_instance_;
class Status;
struct StatusDefaultTypeInternal;
extern StatusDefaultTypeInternal _Status_default_instance_;
@@ -145,6 +148,7 @@ template<> ::greptime::v1::RequestHeader_TracingContextEntry_DoNotUse* Arena::Cr
template<> ::greptime::v1::ResponseHeader* Arena::CreateMaybeMessage<::greptime::v1::ResponseHeader>(Arena*);
template<> ::greptime::v1::SnapshotSequences* Arena::CreateMaybeMessage<::greptime::v1::SnapshotSequences>(Arena*);
template<> ::greptime::v1::SnapshotSequences_SnapshotSeqsEntry_DoNotUse* Arena::CreateMaybeMessage<::greptime::v1::SnapshotSequences_SnapshotSeqsEntry_DoNotUse>(Arena*);
template<> ::greptime::v1::SnapshotSequences_SstMinSequencesEntry_DoNotUse* Arena::CreateMaybeMessage<::greptime::v1::SnapshotSequences_SstMinSequencesEntry_DoNotUse>(Arena*);
template<> ::greptime::v1::Status* Arena::CreateMaybeMessage<::greptime::v1::Status>(Arena*);
template<> ::greptime::v1::TableName* Arena::CreateMaybeMessage<::greptime::v1::TableName>(Arena*);
template<> ::greptime::v1::Token* Arena::CreateMaybeMessage<::greptime::v1::Token>(Arena*);
@@ -547,6 +551,30 @@ class QueryContext final :
};
// -------------------------------------------------------------------
class SnapshotSequences_SstMinSequencesEntry_DoNotUse : public ::PROTOBUF_NAMESPACE_ID::internal::MapEntry<SnapshotSequences_SstMinSequencesEntry_DoNotUse,
uint64_t, uint64_t,
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_UINT64,
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_UINT64> {
public:
typedef ::PROTOBUF_NAMESPACE_ID::internal::MapEntry<SnapshotSequences_SstMinSequencesEntry_DoNotUse,
uint64_t, uint64_t,
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_UINT64,
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_UINT64> SuperType;
SnapshotSequences_SstMinSequencesEntry_DoNotUse();
explicit PROTOBUF_CONSTEXPR SnapshotSequences_SstMinSequencesEntry_DoNotUse(
::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
explicit SnapshotSequences_SstMinSequencesEntry_DoNotUse(::PROTOBUF_NAMESPACE_ID::Arena* arena);
void MergeFrom(const SnapshotSequences_SstMinSequencesEntry_DoNotUse& other);
static const SnapshotSequences_SstMinSequencesEntry_DoNotUse* internal_default_instance() { return reinterpret_cast<const SnapshotSequences_SstMinSequencesEntry_DoNotUse*>(&_SnapshotSequences_SstMinSequencesEntry_DoNotUse_default_instance_); }
static bool ValidateKey(void*) { return true; }
static bool ValidateValue(void*) { return true; }
using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom;
::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
friend struct ::TableStruct_greptime_2fv1_2fcommon_2eproto;
};
// -------------------------------------------------------------------
class SnapshotSequences_SnapshotSeqsEntry_DoNotUse : public ::PROTOBUF_NAMESPACE_ID::internal::MapEntry<SnapshotSequences_SnapshotSeqsEntry_DoNotUse,
uint64_t, uint64_t,
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_UINT64,
@@ -619,7 +647,7 @@ class SnapshotSequences final :
&_SnapshotSequences_default_instance_);
}
static constexpr int kIndexInFileMessages =
3;
4;
friend void swap(SnapshotSequences& a, SnapshotSequences& b) {
a.Swap(&b);
@@ -695,8 +723,26 @@ class SnapshotSequences final :
// accessors -------------------------------------------------------
enum : int {
kSstMinSequencesFieldNumber = 1,
kSnapshotSeqsFieldNumber = 7,
};
// map<uint64, uint64> sst_min_sequences = 1;
int sst_min_sequences_size() const;
private:
int _internal_sst_min_sequences_size() const;
public:
void clear_sst_min_sequences();
private:
const ::PROTOBUF_NAMESPACE_ID::Map< uint64_t, uint64_t >&
_internal_sst_min_sequences() const;
::PROTOBUF_NAMESPACE_ID::Map< uint64_t, uint64_t >*
_internal_mutable_sst_min_sequences();
public:
const ::PROTOBUF_NAMESPACE_ID::Map< uint64_t, uint64_t >&
sst_min_sequences() const;
::PROTOBUF_NAMESPACE_ID::Map< uint64_t, uint64_t >*
mutable_sst_min_sequences();
// map<uint64, uint64> snapshot_seqs = 7;
int snapshot_seqs_size() const;
private:
@@ -722,6 +768,11 @@ class SnapshotSequences final :
typedef void InternalArenaConstructable_;
typedef void DestructorSkippable_;
struct Impl_ {
::PROTOBUF_NAMESPACE_ID::internal::MapField<
SnapshotSequences_SstMinSequencesEntry_DoNotUse,
uint64_t, uint64_t,
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_UINT64,
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_UINT64> sst_min_sequences_;
::PROTOBUF_NAMESPACE_ID::internal::MapField<
SnapshotSequences_SnapshotSeqsEntry_DoNotUse,
uint64_t, uint64_t,
@@ -782,7 +833,7 @@ class ExplainOptions final :
&_ExplainOptions_default_instance_);
}
static constexpr int kIndexInFileMessages =
4;
5;
friend void swap(ExplainOptions& a, ExplainOptions& b) {
a.Swap(&b);
@@ -958,7 +1009,7 @@ class RequestHeader final :
&_RequestHeader_default_instance_);
}
static constexpr int kIndexInFileMessages =
6;
7;
friend void swap(RequestHeader& a, RequestHeader& b) {
a.Swap(&b);
@@ -1205,7 +1256,7 @@ class ResponseHeader final :
&_ResponseHeader_default_instance_);
}
static constexpr int kIndexInFileMessages =
7;
8;
friend void swap(ResponseHeader& a, ResponseHeader& b) {
a.Swap(&b);
@@ -1362,7 +1413,7 @@ class Status final :
&_Status_default_instance_);
}
static constexpr int kIndexInFileMessages =
8;
9;
friend void swap(Status& a, Status& b) {
a.Swap(&b);
@@ -1532,7 +1583,7 @@ class AuthHeader final :
&_AuthHeader_default_instance_);
}
static constexpr int kIndexInFileMessages =
9;
10;
friend void swap(AuthHeader& a, AuthHeader& b) {
a.Swap(&b);
@@ -1722,7 +1773,7 @@ class Basic final :
&_Basic_default_instance_);
}
static constexpr int kIndexInFileMessages =
10;
11;
friend void swap(Basic& a, Basic& b) {
a.Swap(&b);
@@ -1891,7 +1942,7 @@ class Token final :
&_Token_default_instance_);
}
static constexpr int kIndexInFileMessages =
11;
12;
friend void swap(Token& a, Token& b) {
a.Swap(&b);
@@ -2044,7 +2095,7 @@ class TableName final :
&_TableName_default_instance_);
}
static constexpr int kIndexInFileMessages =
12;
13;
friend void swap(TableName& a, TableName& b) {
a.Swap(&b);
@@ -2229,7 +2280,7 @@ class AffectedRows final :
&_AffectedRows_default_instance_);
}
static constexpr int kIndexInFileMessages =
13;
14;
friend void swap(AffectedRows& a, AffectedRows& b) {
a.Swap(&b);
@@ -2377,7 +2428,7 @@ class Metrics final :
&_Metrics_default_instance_);
}
static constexpr int kIndexInFileMessages =
14;
15;
friend void swap(Metrics& a, Metrics& b) {
a.Swap(&b);
@@ -2530,7 +2581,7 @@ class ExpireAfter final :
&_ExpireAfter_default_instance_);
}
static constexpr int kIndexInFileMessages =
15;
16;
friend void swap(ExpireAfter& a, ExpireAfter& b) {
a.Swap(&b);
@@ -2678,7 +2729,7 @@ class FlightMetadata final :
&_FlightMetadata_default_instance_);
}
static constexpr int kIndexInFileMessages =
16;
17;
friend void swap(FlightMetadata& a, FlightMetadata& b) {
a.Swap(&b);
@@ -2855,7 +2906,7 @@ class IntervalMonthDayNano final :
&_IntervalMonthDayNano_default_instance_);
}
static constexpr int kIndexInFileMessages =
17;
18;
friend void swap(IntervalMonthDayNano& a, IntervalMonthDayNano& b) {
a.Swap(&b);
@@ -3025,7 +3076,7 @@ class Decimal128 final :
&_Decimal128_default_instance_);
}
static constexpr int kIndexInFileMessages =
18;
19;
friend void swap(Decimal128& a, Decimal128& b) {
a.Swap(&b);
@@ -3191,7 +3242,7 @@ class ColumnDataTypeExtension final :
&_ColumnDataTypeExtension_default_instance_);
}
static constexpr int kIndexInFileMessages =
19;
20;
friend void swap(ColumnDataTypeExtension& a, ColumnDataTypeExtension& b) {
a.Swap(&b);
@@ -3397,7 +3448,7 @@ class DecimalTypeExtension final :
&_DecimalTypeExtension_default_instance_);
}
static constexpr int kIndexInFileMessages =
20;
21;
friend void swap(DecimalTypeExtension& a, DecimalTypeExtension& b) {
a.Swap(&b);
@@ -3556,7 +3607,7 @@ class VectorTypeExtension final :
&_VectorTypeExtension_default_instance_);
}
static constexpr int kIndexInFileMessages =
21;
22;
friend void swap(VectorTypeExtension& a, VectorTypeExtension& b) {
a.Swap(&b);
@@ -3732,7 +3783,7 @@ class ColumnOptions final :
&_ColumnOptions_default_instance_);
}
static constexpr int kIndexInFileMessages =
23;
24;
friend void swap(ColumnOptions& a, ColumnOptions& b) {
a.Swap(&b);
@@ -4241,8 +4292,39 @@ inline void QueryContext::set_allocated_explain(::greptime::v1::ExplainOptions*
// -------------------------------------------------------------------
// -------------------------------------------------------------------
// SnapshotSequences
// map<uint64, uint64> sst_min_sequences = 1;
inline int SnapshotSequences::_internal_sst_min_sequences_size() const {
return _impl_.sst_min_sequences_.size();
}
inline int SnapshotSequences::sst_min_sequences_size() const {
return _internal_sst_min_sequences_size();
}
inline void SnapshotSequences::clear_sst_min_sequences() {
_impl_.sst_min_sequences_.Clear();
}
inline const ::PROTOBUF_NAMESPACE_ID::Map< uint64_t, uint64_t >&
SnapshotSequences::_internal_sst_min_sequences() const {
return _impl_.sst_min_sequences_.GetMap();
}
inline const ::PROTOBUF_NAMESPACE_ID::Map< uint64_t, uint64_t >&
SnapshotSequences::sst_min_sequences() const {
// @@protoc_insertion_point(field_map:greptime.v1.SnapshotSequences.sst_min_sequences)
return _internal_sst_min_sequences();
}
inline ::PROTOBUF_NAMESPACE_ID::Map< uint64_t, uint64_t >*
SnapshotSequences::_internal_mutable_sst_min_sequences() {
return _impl_.sst_min_sequences_.MutableMap();
}
inline ::PROTOBUF_NAMESPACE_ID::Map< uint64_t, uint64_t >*
SnapshotSequences::mutable_sst_min_sequences() {
// @@protoc_insertion_point(field_mutable_map:greptime.v1.SnapshotSequences.sst_min_sequences)
return _internal_mutable_sst_min_sequences();
}
// map<uint64, uint64> snapshot_seqs = 7;
inline int SnapshotSequences::_internal_snapshot_seqs_size() const {
return _impl_.snapshot_seqs_.size();
@@ -6007,6 +6089,8 @@ ColumnOptions::mutable_options() {
// -------------------------------------------------------------------
// -------------------------------------------------------------------
// @@protoc_insertion_point(namespace_scope)