diff --git a/c++/greptime/v1/ddl.pb.cc b/c++/greptime/v1/ddl.pb.cc index 8ef9d325..dd4832e4 100644 --- a/c++/greptime/v1/ddl.pb.cc +++ b/c++/greptime/v1/ddl.pb.cc @@ -140,9 +140,21 @@ struct CompactTableExprDefaultTypeInternal { }; }; PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 CompactTableExprDefaultTypeInternal _CompactTableExpr_default_instance_; +PROTOBUF_CONSTEXPR CreateDatabaseExpr_OptionsEntry_DoNotUse::CreateDatabaseExpr_OptionsEntry_DoNotUse( + ::_pbi::ConstantInitialized) {} +struct CreateDatabaseExpr_OptionsEntry_DoNotUseDefaultTypeInternal { + PROTOBUF_CONSTEXPR CreateDatabaseExpr_OptionsEntry_DoNotUseDefaultTypeInternal() + : _instance(::_pbi::ConstantInitialized{}) {} + ~CreateDatabaseExpr_OptionsEntry_DoNotUseDefaultTypeInternal() {} + union { + CreateDatabaseExpr_OptionsEntry_DoNotUse _instance; + }; +}; +PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 CreateDatabaseExpr_OptionsEntry_DoNotUseDefaultTypeInternal _CreateDatabaseExpr_OptionsEntry_DoNotUse_default_instance_; PROTOBUF_CONSTEXPR CreateDatabaseExpr::CreateDatabaseExpr( ::_pbi::ConstantInitialized): _impl_{ - /*decltype(_impl_.database_name_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}} + /*decltype(_impl_.options_)*/{::_pbi::ConstantInitialized()} + , /*decltype(_impl_.database_name_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}} , /*decltype(_impl_.create_if_not_exists_)*/false , /*decltype(_impl_._cached_size_)*/{}} {} struct CreateDatabaseExprDefaultTypeInternal { @@ -266,7 +278,7 @@ struct TableIdDefaultTypeInternal { PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 TableIdDefaultTypeInternal _TableId_default_instance_; } // namespace v1 } // namespace greptime -static ::_pb::Metadata file_level_metadata_greptime_2fv1_2fddl_2eproto[16]; +static ::_pb::Metadata file_level_metadata_greptime_2fv1_2fddl_2eproto[17]; static const ::_pb::EnumDescriptor* file_level_enum_descriptors_greptime_2fv1_2fddl_2eproto[1]; static constexpr ::_pb::ServiceDescriptor const** file_level_service_descriptors_greptime_2fv1_2fddl_2eproto = nullptr; @@ -359,6 +371,16 @@ const uint32_t TableStruct_greptime_2fv1_2fddl_2eproto::offsets[] PROTOBUF_SECTI PROTOBUF_FIELD_OFFSET(::greptime::v1::CompactTableExpr, _impl_.schema_name_), PROTOBUF_FIELD_OFFSET(::greptime::v1::CompactTableExpr, _impl_.table_name_), PROTOBUF_FIELD_OFFSET(::greptime::v1::CompactTableExpr, _impl_.region_number_), + PROTOBUF_FIELD_OFFSET(::greptime::v1::CreateDatabaseExpr_OptionsEntry_DoNotUse, _has_bits_), + PROTOBUF_FIELD_OFFSET(::greptime::v1::CreateDatabaseExpr_OptionsEntry_DoNotUse, _internal_metadata_), + ~0u, // no _extensions_ + ~0u, // no _oneof_case_ + ~0u, // no _weak_field_map_ + ~0u, // no _inlined_string_donated_ + PROTOBUF_FIELD_OFFSET(::greptime::v1::CreateDatabaseExpr_OptionsEntry_DoNotUse, key_), + PROTOBUF_FIELD_OFFSET(::greptime::v1::CreateDatabaseExpr_OptionsEntry_DoNotUse, value_), + 0, + 1, ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::greptime::v1::CreateDatabaseExpr, _internal_metadata_), ~0u, // no _extensions_ @@ -367,6 +389,7 @@ const uint32_t TableStruct_greptime_2fv1_2fddl_2eproto::offsets[] PROTOBUF_SECTI ~0u, // no _inlined_string_donated_ PROTOBUF_FIELD_OFFSET(::greptime::v1::CreateDatabaseExpr, _impl_.database_name_), PROTOBUF_FIELD_OFFSET(::greptime::v1::CreateDatabaseExpr, _impl_.create_if_not_exists_), + PROTOBUF_FIELD_OFFSET(::greptime::v1::CreateDatabaseExpr, _impl_.options_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::greptime::v1::TruncateTableExpr, _internal_metadata_), ~0u, // no _extensions_ @@ -438,15 +461,16 @@ static const ::_pbi::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protode { 57, -1, -1, sizeof(::greptime::v1::DropTableExpr)}, { 67, -1, -1, sizeof(::greptime::v1::FlushTableExpr)}, { 78, -1, -1, sizeof(::greptime::v1::CompactTableExpr)}, - { 88, -1, -1, sizeof(::greptime::v1::CreateDatabaseExpr)}, - { 96, -1, -1, sizeof(::greptime::v1::TruncateTableExpr)}, - { 106, -1, -1, sizeof(::greptime::v1::AddColumns)}, - { 113, -1, -1, sizeof(::greptime::v1::DropColumns)}, - { 120, -1, -1, sizeof(::greptime::v1::RenameTable)}, - { 127, -1, -1, sizeof(::greptime::v1::AddColumn_Location)}, - { 135, -1, -1, sizeof(::greptime::v1::AddColumn)}, - { 144, -1, -1, sizeof(::greptime::v1::DropColumn)}, - { 151, -1, -1, sizeof(::greptime::v1::TableId)}, + { 88, 96, -1, sizeof(::greptime::v1::CreateDatabaseExpr_OptionsEntry_DoNotUse)}, + { 98, -1, -1, sizeof(::greptime::v1::CreateDatabaseExpr)}, + { 107, -1, -1, sizeof(::greptime::v1::TruncateTableExpr)}, + { 117, -1, -1, sizeof(::greptime::v1::AddColumns)}, + { 124, -1, -1, sizeof(::greptime::v1::DropColumns)}, + { 131, -1, -1, sizeof(::greptime::v1::RenameTable)}, + { 138, -1, -1, sizeof(::greptime::v1::AddColumn_Location)}, + { 146, -1, -1, sizeof(::greptime::v1::AddColumn)}, + { 155, -1, -1, sizeof(::greptime::v1::DropColumn)}, + { 162, -1, -1, sizeof(::greptime::v1::TableId)}, }; static const ::_pb::Message* const file_default_instances[] = { @@ -457,6 +481,7 @@ static const ::_pb::Message* const file_default_instances[] = { &::greptime::v1::_DropTableExpr_default_instance_._instance, &::greptime::v1::_FlushTableExpr_default_instance_._instance, &::greptime::v1::_CompactTableExpr_default_instance_._instance, + &::greptime::v1::_CreateDatabaseExpr_OptionsEntry_DoNotUse_default_instance_._instance, &::greptime::v1::_CreateDatabaseExpr_default_instance_._instance, &::greptime::v1::_TruncateTableExpr_default_instance_._instance, &::greptime::v1::_AddColumns_default_instance_._instance, @@ -507,35 +532,38 @@ const char descriptor_table_protodef_greptime_2fv1_2fddl_2eproto[] PROTOBUF_SECT "able_id\030\005 \001(\0132\024.greptime.v1.TableId\"h\n\020C" "ompactTableExpr\022\024\n\014catalog_name\030\001 \001(\t\022\023\n" "\013schema_name\030\002 \001(\t\022\022\n\ntable_name\030\003 \001(\t\022\025" - "\n\rregion_number\030\004 \001(\r\"I\n\022CreateDatabaseE" - "xpr\022\025\n\rdatabase_name\030\001 \001(\t\022\034\n\024create_if_" - "not_exists\030\002 \001(\010\"z\n\021TruncateTableExpr\022\024\n" - "\014catalog_name\030\001 \001(\t\022\023\n\013schema_name\030\002 \001(\t" - "\022\022\n\ntable_name\030\003 \001(\t\022&\n\010table_id\030\004 \001(\0132\024" - ".greptime.v1.TableId\"9\n\nAddColumns\022+\n\013ad" - "d_columns\030\001 \003(\0132\026.greptime.v1.AddColumn\"" - "<\n\013DropColumns\022-\n\014drop_columns\030\001 \003(\0132\027.g" - "reptime.v1.DropColumn\"%\n\013RenameTable\022\026\n\016" - "new_table_name\030\001 \001(\t\"\215\002\n\tAddColumn\022*\n\nco" - "lumn_def\030\001 \001(\0132\026.greptime.v1.ColumnDef\022\016" - "\n\006is_key\030\002 \001(\010\0221\n\010location\030\003 \001(\0132\037.grept" - "ime.v1.AddColumn.Location\032\220\001\n\010Location\022C" - "\n\rlocation_type\030\001 \001(\0162,.greptime.v1.AddC" - "olumn.Location.LocationType\022\031\n\021after_clo" - "umn_name\030\002 \001(\t\"$\n\014LocationType\022\t\n\005FIRST\020" - "\000\022\t\n\005AFTER\020\001\"\032\n\nDropColumn\022\014\n\004name\030\001 \001(\t" - "\"\025\n\007TableId\022\n\n\002id\030\001 \001(\rBL\n\016io.greptime.v" - "1B\003DdlZ5github.com/GreptimeTeam/greptime" - "-proto/go/greptime/v1b\006proto3" + "\n\rregion_number\030\004 \001(\r\"\270\001\n\022CreateDatabase" + "Expr\022\025\n\rdatabase_name\030\001 \001(\t\022\034\n\024create_if" + "_not_exists\030\002 \001(\010\022=\n\007options\030\003 \003(\0132,.gre" + "ptime.v1.CreateDatabaseExpr.OptionsEntry" + "\032.\n\014OptionsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002" + " \001(\t:\0028\001\"z\n\021TruncateTableExpr\022\024\n\014catalog" + "_name\030\001 \001(\t\022\023\n\013schema_name\030\002 \001(\t\022\022\n\ntabl" + "e_name\030\003 \001(\t\022&\n\010table_id\030\004 \001(\0132\024.greptim" + "e.v1.TableId\"9\n\nAddColumns\022+\n\013add_column" + "s\030\001 \003(\0132\026.greptime.v1.AddColumn\"<\n\013DropC" + "olumns\022-\n\014drop_columns\030\001 \003(\0132\027.greptime." + "v1.DropColumn\"%\n\013RenameTable\022\026\n\016new_tabl" + "e_name\030\001 \001(\t\"\215\002\n\tAddColumn\022*\n\ncolumn_def" + "\030\001 \001(\0132\026.greptime.v1.ColumnDef\022\016\n\006is_key" + "\030\002 \001(\010\0221\n\010location\030\003 \001(\0132\037.greptime.v1.A" + "ddColumn.Location\032\220\001\n\010Location\022C\n\rlocati" + "on_type\030\001 \001(\0162,.greptime.v1.AddColumn.Lo" + "cation.LocationType\022\031\n\021after_cloumn_name" + "\030\002 \001(\t\"$\n\014LocationType\022\t\n\005FIRST\020\000\022\t\n\005AFT" + "ER\020\001\"\032\n\nDropColumn\022\014\n\004name\030\001 \001(\t\"\025\n\007Tabl" + "eId\022\n\n\002id\030\001 \001(\rBL\n\016io.greptime.v1B\003DdlZ5" + "github.com/GreptimeTeam/greptime-proto/g" + "o/greptime/v1b\006proto3" ; static const ::_pbi::DescriptorTable* const descriptor_table_greptime_2fv1_2fddl_2eproto_deps[1] = { &::descriptor_table_greptime_2fv1_2fcommon_2eproto, }; static ::_pbi::once_flag descriptor_table_greptime_2fv1_2fddl_2eproto_once; const ::_pbi::DescriptorTable descriptor_table_greptime_2fv1_2fddl_2eproto = { - false, false, 2309, descriptor_table_protodef_greptime_2fv1_2fddl_2eproto, + false, false, 2421, descriptor_table_protodef_greptime_2fv1_2fddl_2eproto, "greptime/v1/ddl.proto", - &descriptor_table_greptime_2fv1_2fddl_2eproto_once, descriptor_table_greptime_2fv1_2fddl_2eproto_deps, 1, 16, + &descriptor_table_greptime_2fv1_2fddl_2eproto_once, descriptor_table_greptime_2fv1_2fddl_2eproto_deps, 1, 17, schemas, file_default_instances, TableStruct_greptime_2fv1_2fddl_2eproto::offsets, file_level_metadata_greptime_2fv1_2fddl_2eproto, file_level_enum_descriptors_greptime_2fv1_2fddl_2eproto, file_level_service_descriptors_greptime_2fv1_2fddl_2eproto, @@ -3532,6 +3560,20 @@ ::PROTOBUF_NAMESPACE_ID::Metadata CompactTableExpr::GetMetadata() const { // =================================================================== +CreateDatabaseExpr_OptionsEntry_DoNotUse::CreateDatabaseExpr_OptionsEntry_DoNotUse() {} +CreateDatabaseExpr_OptionsEntry_DoNotUse::CreateDatabaseExpr_OptionsEntry_DoNotUse(::PROTOBUF_NAMESPACE_ID::Arena* arena) + : SuperType(arena) {} +void CreateDatabaseExpr_OptionsEntry_DoNotUse::MergeFrom(const CreateDatabaseExpr_OptionsEntry_DoNotUse& other) { + MergeFromInternal(other); +} +::PROTOBUF_NAMESPACE_ID::Metadata CreateDatabaseExpr_OptionsEntry_DoNotUse::GetMetadata() const { + return ::_pbi::AssignDescriptors( + &descriptor_table_greptime_2fv1_2fddl_2eproto_getter, &descriptor_table_greptime_2fv1_2fddl_2eproto_once, + file_level_metadata_greptime_2fv1_2fddl_2eproto[7]); +} + +// =================================================================== + class CreateDatabaseExpr::_Internal { public: }; @@ -3540,17 +3582,22 @@ CreateDatabaseExpr::CreateDatabaseExpr(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned) : ::PROTOBUF_NAMESPACE_ID::Message(arena, is_message_owned) { SharedCtor(arena, is_message_owned); + if (arena != nullptr && !is_message_owned) { + arena->OwnCustomDestructor(this, &CreateDatabaseExpr::ArenaDtor); + } // @@protoc_insertion_point(arena_constructor:greptime.v1.CreateDatabaseExpr) } CreateDatabaseExpr::CreateDatabaseExpr(const CreateDatabaseExpr& from) : ::PROTOBUF_NAMESPACE_ID::Message() { CreateDatabaseExpr* const _this = this; (void)_this; new (&_impl_) Impl_{ - decltype(_impl_.database_name_){} + /*decltype(_impl_.options_)*/{} + , decltype(_impl_.database_name_){} , decltype(_impl_.create_if_not_exists_){} , /*decltype(_impl_._cached_size_)*/{}}; _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); + _this->_impl_.options_.MergeFrom(from._impl_.options_); _impl_.database_name_.InitDefault(); #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING _impl_.database_name_.Set("", GetArenaForAllocation()); @@ -3568,7 +3615,8 @@ inline void CreateDatabaseExpr::SharedCtor( (void)arena; (void)is_message_owned; new (&_impl_) Impl_{ - decltype(_impl_.database_name_){} + /*decltype(_impl_.options_)*/{::_pbi::ArenaInitialized(), arena} + , decltype(_impl_.database_name_){} , decltype(_impl_.create_if_not_exists_){false} , /*decltype(_impl_._cached_size_)*/{} }; @@ -3582,6 +3630,7 @@ CreateDatabaseExpr::~CreateDatabaseExpr() { // @@protoc_insertion_point(destructor:greptime.v1.CreateDatabaseExpr) if (auto *arena = _internal_metadata_.DeleteReturnArena<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>()) { (void)arena; + ArenaDtor(this); return; } SharedDtor(); @@ -3589,9 +3638,15 @@ CreateDatabaseExpr::~CreateDatabaseExpr() { inline void CreateDatabaseExpr::SharedDtor() { GOOGLE_DCHECK(GetArenaForAllocation() == nullptr); + _impl_.options_.Destruct(); + _impl_.options_.~MapField(); _impl_.database_name_.Destroy(); } +void CreateDatabaseExpr::ArenaDtor(void* object) { + CreateDatabaseExpr* _this = reinterpret_cast< CreateDatabaseExpr* >(object); + _this->_impl_.options_.Destruct(); +} void CreateDatabaseExpr::SetCachedSize(int size) const { _impl_._cached_size_.Set(size); } @@ -3602,6 +3657,7 @@ void CreateDatabaseExpr::Clear() { // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; + _impl_.options_.Clear(); _impl_.database_name_.ClearToEmpty(); _impl_.create_if_not_exists_ = false; _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); @@ -3631,6 +3687,19 @@ const char* CreateDatabaseExpr::_InternalParse(const char* ptr, ::_pbi::ParseCon } else goto handle_unusual; continue; + // map options = 3; + case 3: + if (PROTOBUF_PREDICT_TRUE(static_cast(tag) == 26)) { + ptr -= 1; + do { + ptr += 1; + ptr = ctx->ParseMessage(&_impl_.options_, ptr); + CHK_(ptr); + if (!ctx->DataAvailable(ptr)) break; + } while (::PROTOBUF_NAMESPACE_ID::internal::ExpectTag<26>(ptr)); + } else + goto handle_unusual; + continue; default: goto handle_unusual; } // switch @@ -3676,6 +3745,36 @@ uint8_t* CreateDatabaseExpr::_InternalSerialize( target = ::_pbi::WireFormatLite::WriteBoolToArray(2, this->_internal_create_if_not_exists(), target); } + // map options = 3; + if (!this->_internal_options().empty()) { + using MapType = ::_pb::Map; + using WireHelper = CreateDatabaseExpr_OptionsEntry_DoNotUse::Funcs; + const auto& map_field = this->_internal_options(); + auto check_utf8 = [](const MapType::value_type& entry) { + (void)entry; + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( + entry.first.data(), static_cast(entry.first.length()), + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, + "greptime.v1.CreateDatabaseExpr.OptionsEntry.key"); + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( + entry.second.data(), static_cast(entry.second.length()), + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, + "greptime.v1.CreateDatabaseExpr.OptionsEntry.value"); + }; + + if (stream->IsSerializationDeterministic() && map_field.size() > 1) { + for (const auto& entry : ::_pbi::MapSorterPtr(map_field)) { + target = WireHelper::InternalSerialize(3, entry.first, entry.second, target, stream); + check_utf8(entry); + } + } else { + for (const auto& entry : map_field) { + target = WireHelper::InternalSerialize(3, entry.first, entry.second, target, stream); + check_utf8(entry); + } + } + } + if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { target = ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray( _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream); @@ -3692,6 +3791,15 @@ size_t CreateDatabaseExpr::ByteSizeLong() const { // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; + // map options = 3; + total_size += 1 * + ::PROTOBUF_NAMESPACE_ID::internal::FromIntSize(this->_internal_options_size()); + for (::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >::const_iterator + it = this->_internal_options().begin(); + it != this->_internal_options().end(); ++it) { + total_size += CreateDatabaseExpr_OptionsEntry_DoNotUse::Funcs::ByteSizeLong(it->first, it->second); + } + // string database_name = 1; if (!this->_internal_database_name().empty()) { total_size += 1 + @@ -3722,6 +3830,7 @@ void CreateDatabaseExpr::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, con uint32_t cached_has_bits = 0; (void) cached_has_bits; + _this->_impl_.options_.MergeFrom(from._impl_.options_); if (!from._internal_database_name().empty()) { _this->_internal_set_database_name(from._internal_database_name()); } @@ -3747,6 +3856,7 @@ void CreateDatabaseExpr::InternalSwap(CreateDatabaseExpr* other) { auto* lhs_arena = GetArenaForAllocation(); auto* rhs_arena = other->GetArenaForAllocation(); _internal_metadata_.InternalSwap(&other->_internal_metadata_); + _impl_.options_.InternalSwap(&other->_impl_.options_); ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap( &_impl_.database_name_, lhs_arena, &other->_impl_.database_name_, rhs_arena @@ -3757,7 +3867,7 @@ void CreateDatabaseExpr::InternalSwap(CreateDatabaseExpr* other) { ::PROTOBUF_NAMESPACE_ID::Metadata CreateDatabaseExpr::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fddl_2eproto_getter, &descriptor_table_greptime_2fv1_2fddl_2eproto_once, - file_level_metadata_greptime_2fv1_2fddl_2eproto[7]); + file_level_metadata_greptime_2fv1_2fddl_2eproto[8]); } // =================================================================== @@ -4102,7 +4212,7 @@ void TruncateTableExpr::InternalSwap(TruncateTableExpr* other) { ::PROTOBUF_NAMESPACE_ID::Metadata TruncateTableExpr::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fddl_2eproto_getter, &descriptor_table_greptime_2fv1_2fddl_2eproto_once, - file_level_metadata_greptime_2fv1_2fddl_2eproto[8]); + file_level_metadata_greptime_2fv1_2fddl_2eproto[9]); } // =================================================================== @@ -4287,7 +4397,7 @@ void AddColumns::InternalSwap(AddColumns* other) { ::PROTOBUF_NAMESPACE_ID::Metadata AddColumns::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fddl_2eproto_getter, &descriptor_table_greptime_2fv1_2fddl_2eproto_once, - file_level_metadata_greptime_2fv1_2fddl_2eproto[9]); + file_level_metadata_greptime_2fv1_2fddl_2eproto[10]); } // =================================================================== @@ -4472,7 +4582,7 @@ void DropColumns::InternalSwap(DropColumns* other) { ::PROTOBUF_NAMESPACE_ID::Metadata DropColumns::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fddl_2eproto_getter, &descriptor_table_greptime_2fv1_2fddl_2eproto_once, - file_level_metadata_greptime_2fv1_2fddl_2eproto[10]); + file_level_metadata_greptime_2fv1_2fddl_2eproto[11]); } // =================================================================== @@ -4675,7 +4785,7 @@ void RenameTable::InternalSwap(RenameTable* other) { ::PROTOBUF_NAMESPACE_ID::Metadata RenameTable::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fddl_2eproto_getter, &descriptor_table_greptime_2fv1_2fddl_2eproto_once, - file_level_metadata_greptime_2fv1_2fddl_2eproto[11]); + file_level_metadata_greptime_2fv1_2fddl_2eproto[12]); } // =================================================================== @@ -4908,7 +5018,7 @@ void AddColumn_Location::InternalSwap(AddColumn_Location* other) { ::PROTOBUF_NAMESPACE_ID::Metadata AddColumn_Location::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fddl_2eproto_getter, &descriptor_table_greptime_2fv1_2fddl_2eproto_once, - file_level_metadata_greptime_2fv1_2fddl_2eproto[12]); + file_level_metadata_greptime_2fv1_2fddl_2eproto[13]); } // =================================================================== @@ -5179,7 +5289,7 @@ void AddColumn::InternalSwap(AddColumn* other) { ::PROTOBUF_NAMESPACE_ID::Metadata AddColumn::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fddl_2eproto_getter, &descriptor_table_greptime_2fv1_2fddl_2eproto_once, - file_level_metadata_greptime_2fv1_2fddl_2eproto[13]); + file_level_metadata_greptime_2fv1_2fddl_2eproto[14]); } // =================================================================== @@ -5382,7 +5492,7 @@ void DropColumn::InternalSwap(DropColumn* other) { ::PROTOBUF_NAMESPACE_ID::Metadata DropColumn::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fddl_2eproto_getter, &descriptor_table_greptime_2fv1_2fddl_2eproto_once, - file_level_metadata_greptime_2fv1_2fddl_2eproto[14]); + file_level_metadata_greptime_2fv1_2fddl_2eproto[15]); } // =================================================================== @@ -5560,7 +5670,7 @@ void TableId::InternalSwap(TableId* other) { ::PROTOBUF_NAMESPACE_ID::Metadata TableId::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fddl_2eproto_getter, &descriptor_table_greptime_2fv1_2fddl_2eproto_once, - file_level_metadata_greptime_2fv1_2fddl_2eproto[15]); + file_level_metadata_greptime_2fv1_2fddl_2eproto[16]); } // @@protoc_insertion_point(namespace_scope) @@ -5595,6 +5705,10 @@ template<> PROTOBUF_NOINLINE ::greptime::v1::CompactTableExpr* Arena::CreateMaybeMessage< ::greptime::v1::CompactTableExpr >(Arena* arena) { return Arena::CreateMessageInternal< ::greptime::v1::CompactTableExpr >(arena); } +template<> PROTOBUF_NOINLINE ::greptime::v1::CreateDatabaseExpr_OptionsEntry_DoNotUse* +Arena::CreateMaybeMessage< ::greptime::v1::CreateDatabaseExpr_OptionsEntry_DoNotUse >(Arena* arena) { + return Arena::CreateMessageInternal< ::greptime::v1::CreateDatabaseExpr_OptionsEntry_DoNotUse >(arena); +} template<> PROTOBUF_NOINLINE ::greptime::v1::CreateDatabaseExpr* Arena::CreateMaybeMessage< ::greptime::v1::CreateDatabaseExpr >(Arena* arena) { return Arena::CreateMessageInternal< ::greptime::v1::CreateDatabaseExpr >(arena); diff --git a/c++/greptime/v1/ddl.pb.h b/c++/greptime/v1/ddl.pb.h index a225748e..2061085b 100644 --- a/c++/greptime/v1/ddl.pb.h +++ b/c++/greptime/v1/ddl.pb.h @@ -69,6 +69,9 @@ extern CompactTableExprDefaultTypeInternal _CompactTableExpr_default_instance_; class CreateDatabaseExpr; struct CreateDatabaseExprDefaultTypeInternal; extern CreateDatabaseExprDefaultTypeInternal _CreateDatabaseExpr_default_instance_; +class CreateDatabaseExpr_OptionsEntry_DoNotUse; +struct CreateDatabaseExpr_OptionsEntry_DoNotUseDefaultTypeInternal; +extern CreateDatabaseExpr_OptionsEntry_DoNotUseDefaultTypeInternal _CreateDatabaseExpr_OptionsEntry_DoNotUse_default_instance_; class CreateTableExpr; struct CreateTableExprDefaultTypeInternal; extern CreateTableExprDefaultTypeInternal _CreateTableExpr_default_instance_; @@ -108,6 +111,7 @@ template<> ::greptime::v1::AddColumns* Arena::CreateMaybeMessage<::greptime::v1: template<> ::greptime::v1::AlterExpr* Arena::CreateMaybeMessage<::greptime::v1::AlterExpr>(Arena*); template<> ::greptime::v1::CompactTableExpr* Arena::CreateMaybeMessage<::greptime::v1::CompactTableExpr>(Arena*); template<> ::greptime::v1::CreateDatabaseExpr* Arena::CreateMaybeMessage<::greptime::v1::CreateDatabaseExpr>(Arena*); +template<> ::greptime::v1::CreateDatabaseExpr_OptionsEntry_DoNotUse* Arena::CreateMaybeMessage<::greptime::v1::CreateDatabaseExpr_OptionsEntry_DoNotUse>(Arena*); template<> ::greptime::v1::CreateTableExpr* Arena::CreateMaybeMessage<::greptime::v1::CreateTableExpr>(Arena*); template<> ::greptime::v1::CreateTableExpr_TableOptionsEntry_DoNotUse* Arena::CreateMaybeMessage<::greptime::v1::CreateTableExpr_TableOptionsEntry_DoNotUse>(Arena*); template<> ::greptime::v1::DdlRequest* Arena::CreateMaybeMessage<::greptime::v1::DdlRequest>(Arena*); @@ -1758,6 +1762,34 @@ class CompactTableExpr final : }; // ------------------------------------------------------------------- +class CreateDatabaseExpr_OptionsEntry_DoNotUse : public ::PROTOBUF_NAMESPACE_ID::internal::MapEntry { +public: + typedef ::PROTOBUF_NAMESPACE_ID::internal::MapEntry SuperType; + CreateDatabaseExpr_OptionsEntry_DoNotUse(); + explicit PROTOBUF_CONSTEXPR CreateDatabaseExpr_OptionsEntry_DoNotUse( + ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized); + explicit CreateDatabaseExpr_OptionsEntry_DoNotUse(::PROTOBUF_NAMESPACE_ID::Arena* arena); + void MergeFrom(const CreateDatabaseExpr_OptionsEntry_DoNotUse& other); + static const CreateDatabaseExpr_OptionsEntry_DoNotUse* internal_default_instance() { return reinterpret_cast(&_CreateDatabaseExpr_OptionsEntry_DoNotUse_default_instance_); } + static bool ValidateKey(std::string* s) { + return ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(s->data(), static_cast(s->size()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE, "greptime.v1.CreateDatabaseExpr.OptionsEntry.key"); + } + static bool ValidateValue(std::string* s) { + return ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(s->data(), static_cast(s->size()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE, "greptime.v1.CreateDatabaseExpr.OptionsEntry.value"); + } + using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom; + ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final; + friend struct ::TableStruct_greptime_2fv1_2fddl_2eproto; +}; + +// ------------------------------------------------------------------- + class CreateDatabaseExpr final : public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:greptime.v1.CreateDatabaseExpr) */ { public: @@ -1806,7 +1838,7 @@ class CreateDatabaseExpr final : &_CreateDatabaseExpr_default_instance_); } static constexpr int kIndexInFileMessages = - 7; + 8; friend void swap(CreateDatabaseExpr& a, CreateDatabaseExpr& b) { a.Swap(&b); @@ -1867,6 +1899,8 @@ class CreateDatabaseExpr final : protected: explicit CreateDatabaseExpr(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned = false); + private: + static void ArenaDtor(void* object); public: static const ClassData _class_data_; @@ -1876,12 +1910,31 @@ class CreateDatabaseExpr final : // nested types ---------------------------------------------------- + // accessors ------------------------------------------------------- enum : int { + kOptionsFieldNumber = 3, kDatabaseNameFieldNumber = 1, kCreateIfNotExistsFieldNumber = 2, }; + // map options = 3; + int options_size() const; + private: + int _internal_options_size() const; + public: + void clear_options(); + private: + const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >& + _internal_options() const; + ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >* + _internal_mutable_options(); + public: + const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >& + options() const; + ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >* + mutable_options(); + // string database_name = 1; void clear_database_name(); const std::string& database_name() const; @@ -1913,6 +1966,11 @@ class CreateDatabaseExpr final : typedef void InternalArenaConstructable_; typedef void DestructorSkippable_; struct Impl_ { + ::PROTOBUF_NAMESPACE_ID::internal::MapField< + CreateDatabaseExpr_OptionsEntry_DoNotUse, + std::string, std::string, + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING, + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING> options_; ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr database_name_; bool create_if_not_exists_; mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; @@ -1970,7 +2028,7 @@ class TruncateTableExpr final : &_TruncateTableExpr_default_instance_); } static constexpr int kIndexInFileMessages = - 8; + 9; friend void swap(TruncateTableExpr& a, TruncateTableExpr& b) { a.Swap(&b); @@ -2175,7 +2233,7 @@ class AddColumns final : &_AddColumns_default_instance_); } static constexpr int kIndexInFileMessages = - 9; + 10; friend void swap(AddColumns& a, AddColumns& b) { a.Swap(&b); @@ -2332,7 +2390,7 @@ class DropColumns final : &_DropColumns_default_instance_); } static constexpr int kIndexInFileMessages = - 10; + 11; friend void swap(DropColumns& a, DropColumns& b) { a.Swap(&b); @@ -2489,7 +2547,7 @@ class RenameTable final : &_RenameTable_default_instance_); } static constexpr int kIndexInFileMessages = - 11; + 12; friend void swap(RenameTable& a, RenameTable& b) { a.Swap(&b); @@ -2642,7 +2700,7 @@ class AddColumn_Location final : &_AddColumn_Location_default_instance_); } static constexpr int kIndexInFileMessages = - 12; + 13; friend void swap(AddColumn_Location& a, AddColumn_Location& b) { a.Swap(&b); @@ -2836,7 +2894,7 @@ class AddColumn final : &_AddColumn_default_instance_); } static constexpr int kIndexInFileMessages = - 13; + 14; friend void swap(AddColumn& a, AddColumn& b) { a.Swap(&b); @@ -3026,7 +3084,7 @@ class DropColumn final : &_DropColumn_default_instance_); } static constexpr int kIndexInFileMessages = - 14; + 15; friend void swap(DropColumn& a, DropColumn& b) { a.Swap(&b); @@ -3179,7 +3237,7 @@ class TableId final : &_TableId_default_instance_); } static constexpr int kIndexInFileMessages = - 15; + 16; friend void swap(TableId& a, TableId& b) { a.Swap(&b); @@ -5598,6 +5656,8 @@ inline void CompactTableExpr::set_region_number(uint32_t value) { // ------------------------------------------------------------------- +// ------------------------------------------------------------------- + // CreateDatabaseExpr // string database_name = 1; @@ -5670,6 +5730,35 @@ inline void CreateDatabaseExpr::set_create_if_not_exists(bool value) { // @@protoc_insertion_point(field_set:greptime.v1.CreateDatabaseExpr.create_if_not_exists) } +// map options = 3; +inline int CreateDatabaseExpr::_internal_options_size() const { + return _impl_.options_.size(); +} +inline int CreateDatabaseExpr::options_size() const { + return _internal_options_size(); +} +inline void CreateDatabaseExpr::clear_options() { + _impl_.options_.Clear(); +} +inline const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >& +CreateDatabaseExpr::_internal_options() const { + return _impl_.options_.GetMap(); +} +inline const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >& +CreateDatabaseExpr::options() const { + // @@protoc_insertion_point(field_map:greptime.v1.CreateDatabaseExpr.options) + return _internal_options(); +} +inline ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >* +CreateDatabaseExpr::_internal_mutable_options() { + return _impl_.options_.MutableMap(); +} +inline ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >* +CreateDatabaseExpr::mutable_options() { + // @@protoc_insertion_point(field_mutable_map:greptime.v1.CreateDatabaseExpr.options) + return _internal_mutable_options(); +} + // ------------------------------------------------------------------- // TruncateTableExpr @@ -6440,6 +6529,8 @@ inline void TableId::set_id(uint32_t value) { // ------------------------------------------------------------------- +// ------------------------------------------------------------------- + // @@protoc_insertion_point(namespace_scope) diff --git a/go/greptime/v1/ddl.pb.go b/go/greptime/v1/ddl.pb.go index b3e7533d..938dbe86 100644 --- a/go/greptime/v1/ddl.pb.go +++ b/go/greptime/v1/ddl.pb.go @@ -732,8 +732,9 @@ type CreateDatabaseExpr struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - DatabaseName string `protobuf:"bytes,1,opt,name=database_name,json=databaseName,proto3" json:"database_name,omitempty"` - CreateIfNotExists bool `protobuf:"varint,2,opt,name=create_if_not_exists,json=createIfNotExists,proto3" json:"create_if_not_exists,omitempty"` + DatabaseName string `protobuf:"bytes,1,opt,name=database_name,json=databaseName,proto3" json:"database_name,omitempty"` + CreateIfNotExists bool `protobuf:"varint,2,opt,name=create_if_not_exists,json=createIfNotExists,proto3" json:"create_if_not_exists,omitempty"` + Options map[string]string `protobuf:"bytes,3,rep,name=options,proto3" json:"options,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` } func (x *CreateDatabaseExpr) Reset() { @@ -782,6 +783,13 @@ func (x *CreateDatabaseExpr) GetCreateIfNotExists() bool { return false } +func (x *CreateDatabaseExpr) GetOptions() map[string]string { + if x != nil { + return x.Options + } + return nil +} + type TruncateTableExpr struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache @@ -1163,7 +1171,7 @@ type AddColumn_Location struct { func (x *AddColumn_Location) Reset() { *x = AddColumn_Location{} if protoimpl.UnsafeEnabled { - mi := &file_greptime_v1_ddl_proto_msgTypes[15] + mi := &file_greptime_v1_ddl_proto_msgTypes[16] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1176,7 +1184,7 @@ func (x *AddColumn_Location) String() string { func (*AddColumn_Location) ProtoMessage() {} func (x *AddColumn_Location) ProtoReflect() protoreflect.Message { - mi := &file_greptime_v1_ddl_proto_msgTypes[15] + mi := &file_greptime_v1_ddl_proto_msgTypes[16] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1336,66 +1344,75 @@ var file_greptime_v1_ddl_proto_rawDesc = []byte{ 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x23, 0x0a, 0x0d, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x5f, 0x6e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0c, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x4e, - 0x75, 0x6d, 0x62, 0x65, 0x72, 0x22, 0x6a, 0x0a, 0x12, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x44, - 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x45, 0x78, 0x70, 0x72, 0x12, 0x23, 0x0a, 0x0d, 0x64, - 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, - 0x28, 0x09, 0x52, 0x0c, 0x64, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x4e, 0x61, 0x6d, 0x65, - 0x12, 0x2f, 0x0a, 0x14, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x5f, 0x69, 0x66, 0x5f, 0x6e, 0x6f, - 0x74, 0x5f, 0x65, 0x78, 0x69, 0x73, 0x74, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x52, 0x11, - 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x49, 0x66, 0x4e, 0x6f, 0x74, 0x45, 0x78, 0x69, 0x73, 0x74, - 0x73, 0x22, 0xa7, 0x01, 0x0a, 0x11, 0x54, 0x72, 0x75, 0x6e, 0x63, 0x61, 0x74, 0x65, 0x54, 0x61, - 0x62, 0x6c, 0x65, 0x45, 0x78, 0x70, 0x72, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x61, 0x74, 0x61, 0x6c, - 0x6f, 0x67, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, - 0x61, 0x74, 0x61, 0x6c, 0x6f, 0x67, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x1f, 0x0a, 0x0b, 0x73, 0x63, - 0x68, 0x65, 0x6d, 0x61, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, - 0x0a, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x74, - 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, - 0x09, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x2f, 0x0a, 0x08, 0x74, 0x61, - 0x62, 0x6c, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x14, 0x2e, 0x67, - 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, - 0x49, 0x64, 0x52, 0x07, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x64, 0x22, 0x45, 0x0a, 0x0a, 0x41, - 0x64, 0x64, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x12, 0x37, 0x0a, 0x0b, 0x61, 0x64, 0x64, - 0x5f, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x16, - 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x41, 0x64, 0x64, - 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x52, 0x0a, 0x61, 0x64, 0x64, 0x43, 0x6f, 0x6c, 0x75, 0x6d, - 0x6e, 0x73, 0x22, 0x49, 0x0a, 0x0b, 0x44, 0x72, 0x6f, 0x70, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, - 0x73, 0x12, 0x3a, 0x0a, 0x0c, 0x64, 0x72, 0x6f, 0x70, 0x5f, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, - 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x17, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, - 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x44, 0x72, 0x6f, 0x70, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, - 0x52, 0x0b, 0x64, 0x72, 0x6f, 0x70, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x22, 0x33, 0x0a, - 0x0b, 0x52, 0x65, 0x6e, 0x61, 0x6d, 0x65, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x12, 0x24, 0x0a, 0x0e, - 0x6e, 0x65, 0x77, 0x5f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, - 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x6e, 0x65, 0x77, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x4e, 0x61, - 0x6d, 0x65, 0x22, 0xc8, 0x02, 0x0a, 0x09, 0x41, 0x64, 0x64, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, - 0x12, 0x35, 0x0a, 0x0a, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x5f, 0x64, 0x65, 0x66, 0x18, 0x01, - 0x20, 0x01, 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, - 0x76, 0x31, 0x2e, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x44, 0x65, 0x66, 0x52, 0x09, 0x63, 0x6f, - 0x6c, 0x75, 0x6d, 0x6e, 0x44, 0x65, 0x66, 0x12, 0x15, 0x0a, 0x06, 0x69, 0x73, 0x5f, 0x6b, 0x65, - 0x79, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x52, 0x05, 0x69, 0x73, 0x4b, 0x65, 0x79, 0x12, 0x3b, - 0x0a, 0x08, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, - 0x32, 0x1f, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x41, - 0x64, 0x64, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x2e, 0x4c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, - 0x6e, 0x52, 0x08, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x1a, 0xaf, 0x01, 0x0a, 0x08, - 0x4c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x51, 0x0a, 0x0d, 0x6c, 0x6f, 0x63, 0x61, - 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, - 0x2c, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x41, 0x64, - 0x64, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x2e, 0x4c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, - 0x2e, 0x4c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x54, 0x79, 0x70, 0x65, 0x52, 0x0c, 0x6c, - 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x54, 0x79, 0x70, 0x65, 0x12, 0x2a, 0x0a, 0x11, 0x61, - 0x66, 0x74, 0x65, 0x72, 0x5f, 0x63, 0x6c, 0x6f, 0x75, 0x6d, 0x6e, 0x5f, 0x6e, 0x61, 0x6d, 0x65, - 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0f, 0x61, 0x66, 0x74, 0x65, 0x72, 0x43, 0x6c, 0x6f, - 0x75, 0x6d, 0x6e, 0x4e, 0x61, 0x6d, 0x65, 0x22, 0x24, 0x0a, 0x0c, 0x4c, 0x6f, 0x63, 0x61, 0x74, - 0x69, 0x6f, 0x6e, 0x54, 0x79, 0x70, 0x65, 0x12, 0x09, 0x0a, 0x05, 0x46, 0x49, 0x52, 0x53, 0x54, - 0x10, 0x00, 0x12, 0x09, 0x0a, 0x05, 0x41, 0x46, 0x54, 0x45, 0x52, 0x10, 0x01, 0x22, 0x20, 0x0a, - 0x0a, 0x44, 0x72, 0x6f, 0x70, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x12, 0x12, 0x0a, 0x04, 0x6e, - 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, - 0x19, 0x0a, 0x07, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x64, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, - 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x02, 0x69, 0x64, 0x42, 0x4c, 0x0a, 0x0e, 0x69, 0x6f, - 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x42, 0x03, 0x44, 0x64, - 0x6c, 0x5a, 0x35, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x47, 0x72, - 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x54, 0x65, 0x61, 0x6d, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74, - 0x69, 0x6d, 0x65, 0x2d, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x2f, 0x67, 0x72, 0x65, - 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2f, 0x76, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, + 0x75, 0x6d, 0x62, 0x65, 0x72, 0x22, 0xee, 0x01, 0x0a, 0x12, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, + 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x45, 0x78, 0x70, 0x72, 0x12, 0x23, 0x0a, 0x0d, + 0x64, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, + 0x01, 0x28, 0x09, 0x52, 0x0c, 0x64, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x4e, 0x61, 0x6d, + 0x65, 0x12, 0x2f, 0x0a, 0x14, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x5f, 0x69, 0x66, 0x5f, 0x6e, + 0x6f, 0x74, 0x5f, 0x65, 0x78, 0x69, 0x73, 0x74, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x52, + 0x11, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x49, 0x66, 0x4e, 0x6f, 0x74, 0x45, 0x78, 0x69, 0x73, + 0x74, 0x73, 0x12, 0x46, 0x0a, 0x07, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x03, 0x20, + 0x03, 0x28, 0x0b, 0x32, 0x2c, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, + 0x31, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, + 0x45, 0x78, 0x70, 0x72, 0x2e, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x45, 0x6e, 0x74, 0x72, + 0x79, 0x52, 0x07, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x1a, 0x3a, 0x0a, 0x0c, 0x4f, 0x70, + 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, + 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, + 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, + 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0xa7, 0x01, 0x0a, 0x11, 0x54, 0x72, 0x75, 0x6e, 0x63, + 0x61, 0x74, 0x65, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x45, 0x78, 0x70, 0x72, 0x12, 0x21, 0x0a, 0x0c, + 0x63, 0x61, 0x74, 0x61, 0x6c, 0x6f, 0x67, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, + 0x28, 0x09, 0x52, 0x0b, 0x63, 0x61, 0x74, 0x61, 0x6c, 0x6f, 0x67, 0x4e, 0x61, 0x6d, 0x65, 0x12, + 0x1f, 0x0a, 0x0b, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, + 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x4e, 0x61, 0x6d, 0x65, + 0x12, 0x1d, 0x0a, 0x0a, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x03, + 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x12, + 0x2f, 0x0a, 0x08, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, + 0x0b, 0x32, 0x14, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, + 0x54, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x64, 0x52, 0x07, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x64, + 0x22, 0x45, 0x0a, 0x0a, 0x41, 0x64, 0x64, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x12, 0x37, + 0x0a, 0x0b, 0x61, 0x64, 0x64, 0x5f, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x18, 0x01, 0x20, + 0x03, 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, + 0x31, 0x2e, 0x41, 0x64, 0x64, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x52, 0x0a, 0x61, 0x64, 0x64, + 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x22, 0x49, 0x0a, 0x0b, 0x44, 0x72, 0x6f, 0x70, 0x43, + 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x12, 0x3a, 0x0a, 0x0c, 0x64, 0x72, 0x6f, 0x70, 0x5f, 0x63, + 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x17, 0x2e, 0x67, + 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x44, 0x72, 0x6f, 0x70, 0x43, + 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x52, 0x0b, 0x64, 0x72, 0x6f, 0x70, 0x43, 0x6f, 0x6c, 0x75, 0x6d, + 0x6e, 0x73, 0x22, 0x33, 0x0a, 0x0b, 0x52, 0x65, 0x6e, 0x61, 0x6d, 0x65, 0x54, 0x61, 0x62, 0x6c, + 0x65, 0x12, 0x24, 0x0a, 0x0e, 0x6e, 0x65, 0x77, 0x5f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x6e, + 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x6e, 0x65, 0x77, 0x54, 0x61, + 0x62, 0x6c, 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x22, 0xc8, 0x02, 0x0a, 0x09, 0x41, 0x64, 0x64, 0x43, + 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x12, 0x35, 0x0a, 0x0a, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x5f, + 0x64, 0x65, 0x66, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x67, 0x72, 0x65, 0x70, + 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x44, 0x65, + 0x66, 0x52, 0x09, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x44, 0x65, 0x66, 0x12, 0x15, 0x0a, 0x06, + 0x69, 0x73, 0x5f, 0x6b, 0x65, 0x79, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x52, 0x05, 0x69, 0x73, + 0x4b, 0x65, 0x79, 0x12, 0x3b, 0x0a, 0x08, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, + 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, + 0x2e, 0x76, 0x31, 0x2e, 0x41, 0x64, 0x64, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x2e, 0x4c, 0x6f, + 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x08, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, + 0x1a, 0xaf, 0x01, 0x0a, 0x08, 0x4c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x51, 0x0a, + 0x0d, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x01, + 0x20, 0x01, 0x28, 0x0e, 0x32, 0x2c, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, + 0x76, 0x31, 0x2e, 0x41, 0x64, 0x64, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x2e, 0x4c, 0x6f, 0x63, + 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x4c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x54, 0x79, + 0x70, 0x65, 0x52, 0x0c, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x54, 0x79, 0x70, 0x65, + 0x12, 0x2a, 0x0a, 0x11, 0x61, 0x66, 0x74, 0x65, 0x72, 0x5f, 0x63, 0x6c, 0x6f, 0x75, 0x6d, 0x6e, + 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0f, 0x61, 0x66, 0x74, + 0x65, 0x72, 0x43, 0x6c, 0x6f, 0x75, 0x6d, 0x6e, 0x4e, 0x61, 0x6d, 0x65, 0x22, 0x24, 0x0a, 0x0c, + 0x4c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x54, 0x79, 0x70, 0x65, 0x12, 0x09, 0x0a, 0x05, + 0x46, 0x49, 0x52, 0x53, 0x54, 0x10, 0x00, 0x12, 0x09, 0x0a, 0x05, 0x41, 0x46, 0x54, 0x45, 0x52, + 0x10, 0x01, 0x22, 0x20, 0x0a, 0x0a, 0x44, 0x72, 0x6f, 0x70, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, + 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, + 0x6e, 0x61, 0x6d, 0x65, 0x22, 0x19, 0x0a, 0x07, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x64, 0x12, + 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x02, 0x69, 0x64, 0x42, + 0x4c, 0x0a, 0x0e, 0x69, 0x6f, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, + 0x31, 0x42, 0x03, 0x44, 0x64, 0x6c, 0x5a, 0x35, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, + 0x6f, 0x6d, 0x2f, 0x47, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x54, 0x65, 0x61, 0x6d, 0x2f, + 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2d, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, + 0x6f, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2f, 0x76, 0x31, 0x62, 0x06, 0x70, + 0x72, 0x6f, 0x74, 0x6f, 0x33, } var ( @@ -1411,7 +1428,7 @@ func file_greptime_v1_ddl_proto_rawDescGZIP() []byte { } var file_greptime_v1_ddl_proto_enumTypes = make([]protoimpl.EnumInfo, 1) -var file_greptime_v1_ddl_proto_msgTypes = make([]protoimpl.MessageInfo, 16) +var file_greptime_v1_ddl_proto_msgTypes = make([]protoimpl.MessageInfo, 17) var file_greptime_v1_ddl_proto_goTypes = []interface{}{ (AddColumn_Location_LocationType)(0), // 0: greptime.v1.AddColumn.Location.LocationType (*DdlRequest)(nil), // 1: greptime.v1.DdlRequest @@ -1429,8 +1446,9 @@ var file_greptime_v1_ddl_proto_goTypes = []interface{}{ (*DropColumn)(nil), // 13: greptime.v1.DropColumn (*TableId)(nil), // 14: greptime.v1.TableId nil, // 15: greptime.v1.CreateTableExpr.TableOptionsEntry - (*AddColumn_Location)(nil), // 16: greptime.v1.AddColumn.Location - (*ColumnDef)(nil), // 17: greptime.v1.ColumnDef + nil, // 16: greptime.v1.CreateDatabaseExpr.OptionsEntry + (*AddColumn_Location)(nil), // 17: greptime.v1.AddColumn.Location + (*ColumnDef)(nil), // 18: greptime.v1.ColumnDef } var file_greptime_v1_ddl_proto_depIdxs = []int32{ 7, // 0: greptime.v1.DdlRequest.create_database:type_name -> greptime.v1.CreateDatabaseExpr @@ -1440,7 +1458,7 @@ var file_greptime_v1_ddl_proto_depIdxs = []int32{ 5, // 4: greptime.v1.DdlRequest.flush_table:type_name -> greptime.v1.FlushTableExpr 6, // 5: greptime.v1.DdlRequest.compact_table:type_name -> greptime.v1.CompactTableExpr 8, // 6: greptime.v1.DdlRequest.truncate_table:type_name -> greptime.v1.TruncateTableExpr - 17, // 7: greptime.v1.CreateTableExpr.column_defs:type_name -> greptime.v1.ColumnDef + 18, // 7: greptime.v1.CreateTableExpr.column_defs:type_name -> greptime.v1.ColumnDef 15, // 8: greptime.v1.CreateTableExpr.table_options:type_name -> greptime.v1.CreateTableExpr.TableOptionsEntry 14, // 9: greptime.v1.CreateTableExpr.table_id:type_name -> greptime.v1.TableId 9, // 10: greptime.v1.AlterExpr.add_columns:type_name -> greptime.v1.AddColumns @@ -1449,17 +1467,18 @@ var file_greptime_v1_ddl_proto_depIdxs = []int32{ 14, // 13: greptime.v1.AlterExpr.table_id:type_name -> greptime.v1.TableId 14, // 14: greptime.v1.DropTableExpr.table_id:type_name -> greptime.v1.TableId 14, // 15: greptime.v1.FlushTableExpr.table_id:type_name -> greptime.v1.TableId - 14, // 16: greptime.v1.TruncateTableExpr.table_id:type_name -> greptime.v1.TableId - 12, // 17: greptime.v1.AddColumns.add_columns:type_name -> greptime.v1.AddColumn - 13, // 18: greptime.v1.DropColumns.drop_columns:type_name -> greptime.v1.DropColumn - 17, // 19: greptime.v1.AddColumn.column_def:type_name -> greptime.v1.ColumnDef - 16, // 20: greptime.v1.AddColumn.location:type_name -> greptime.v1.AddColumn.Location - 0, // 21: greptime.v1.AddColumn.Location.location_type:type_name -> greptime.v1.AddColumn.Location.LocationType - 22, // [22:22] is the sub-list for method output_type - 22, // [22:22] is the sub-list for method input_type - 22, // [22:22] is the sub-list for extension type_name - 22, // [22:22] is the sub-list for extension extendee - 0, // [0:22] is the sub-list for field type_name + 16, // 16: greptime.v1.CreateDatabaseExpr.options:type_name -> greptime.v1.CreateDatabaseExpr.OptionsEntry + 14, // 17: greptime.v1.TruncateTableExpr.table_id:type_name -> greptime.v1.TableId + 12, // 18: greptime.v1.AddColumns.add_columns:type_name -> greptime.v1.AddColumn + 13, // 19: greptime.v1.DropColumns.drop_columns:type_name -> greptime.v1.DropColumn + 18, // 20: greptime.v1.AddColumn.column_def:type_name -> greptime.v1.ColumnDef + 17, // 21: greptime.v1.AddColumn.location:type_name -> greptime.v1.AddColumn.Location + 0, // 22: greptime.v1.AddColumn.Location.location_type:type_name -> greptime.v1.AddColumn.Location.LocationType + 23, // [23:23] is the sub-list for method output_type + 23, // [23:23] is the sub-list for method input_type + 23, // [23:23] is the sub-list for extension type_name + 23, // [23:23] is the sub-list for extension extendee + 0, // [0:23] is the sub-list for field type_name } func init() { file_greptime_v1_ddl_proto_init() } @@ -1637,7 +1656,7 @@ func file_greptime_v1_ddl_proto_init() { return nil } } - file_greptime_v1_ddl_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} { + file_greptime_v1_ddl_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*AddColumn_Location); i { case 0: return &v.state @@ -1670,7 +1689,7 @@ func file_greptime_v1_ddl_proto_init() { GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: file_greptime_v1_ddl_proto_rawDesc, NumEnums: 1, - NumMessages: 16, + NumMessages: 17, NumExtensions: 0, NumServices: 0, }, diff --git a/java/src/main/java/io/greptime/v1/Ddl.java b/java/src/main/java/io/greptime/v1/Ddl.java index e18b4060..0f63f6af 100644 --- a/java/src/main/java/io/greptime/v1/Ddl.java +++ b/java/src/main/java/io/greptime/v1/Ddl.java @@ -9933,6 +9933,42 @@ public interface CreateDatabaseExprOrBuilder extends * @return The createIfNotExists. */ boolean getCreateIfNotExists(); + + /** + * map<string, string> options = 3; + */ + int getOptionsCount(); + /** + * map<string, string> options = 3; + */ + boolean containsOptions( + java.lang.String key); + /** + * Use {@link #getOptionsMap()} instead. + */ + @java.lang.Deprecated + java.util.Map + getOptions(); + /** + * map<string, string> options = 3; + */ + java.util.Map + getOptionsMap(); + /** + * map<string, string> options = 3; + */ + + /* nullable */ +java.lang.String getOptionsOrDefault( + java.lang.String key, + /* nullable */ +java.lang.String defaultValue); + /** + * map<string, string> options = 3; + */ + + java.lang.String getOptionsOrThrow( + java.lang.String key); } /** * Protobuf type {@code greptime.v1.CreateDatabaseExpr} @@ -9970,6 +10006,7 @@ private CreateDatabaseExpr( if (extensionRegistry == null) { throw new java.lang.NullPointerException(); } + int mutable_bitField0_ = 0; com.google.protobuf.UnknownFieldSet.Builder unknownFields = com.google.protobuf.UnknownFieldSet.newBuilder(); try { @@ -9991,6 +10028,19 @@ private CreateDatabaseExpr( createIfNotExists_ = input.readBool(); break; } + case 26: { + if (!((mutable_bitField0_ & 0x00000001) != 0)) { + options_ = com.google.protobuf.MapField.newMapField( + OptionsDefaultEntryHolder.defaultEntry); + mutable_bitField0_ |= 0x00000001; + } + com.google.protobuf.MapEntry + options__ = input.readMessage( + OptionsDefaultEntryHolder.defaultEntry.getParserForType(), extensionRegistry); + options_.getMutableMap().put( + options__.getKey(), options__.getValue()); + break; + } default: { if (!parseUnknownField( input, unknownFields, extensionRegistry, tag)) { @@ -10017,6 +10067,18 @@ private CreateDatabaseExpr( return io.greptime.v1.Ddl.internal_static_greptime_v1_CreateDatabaseExpr_descriptor; } + @SuppressWarnings({"rawtypes"}) + @java.lang.Override + protected com.google.protobuf.MapField internalGetMapField( + int number) { + switch (number) { + case 3: + return internalGetOptions(); + default: + throw new RuntimeException( + "Invalid map field number: " + number); + } + } @java.lang.Override protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable() { @@ -10074,6 +10136,87 @@ public boolean getCreateIfNotExists() { return createIfNotExists_; } + public static final int OPTIONS_FIELD_NUMBER = 3; + private static final class OptionsDefaultEntryHolder { + static final com.google.protobuf.MapEntry< + java.lang.String, java.lang.String> defaultEntry = + com.google.protobuf.MapEntry + .newDefaultInstance( + io.greptime.v1.Ddl.internal_static_greptime_v1_CreateDatabaseExpr_OptionsEntry_descriptor, + com.google.protobuf.WireFormat.FieldType.STRING, + "", + com.google.protobuf.WireFormat.FieldType.STRING, + ""); + } + private com.google.protobuf.MapField< + java.lang.String, java.lang.String> options_; + private com.google.protobuf.MapField + internalGetOptions() { + if (options_ == null) { + return com.google.protobuf.MapField.emptyMapField( + OptionsDefaultEntryHolder.defaultEntry); + } + return options_; + } + + public int getOptionsCount() { + return internalGetOptions().getMap().size(); + } + /** + * map<string, string> options = 3; + */ + + @java.lang.Override + public boolean containsOptions( + java.lang.String key) { + if (key == null) { throw new NullPointerException("map key"); } + return internalGetOptions().getMap().containsKey(key); + } + /** + * Use {@link #getOptionsMap()} instead. + */ + @java.lang.Override + @java.lang.Deprecated + public java.util.Map getOptions() { + return getOptionsMap(); + } + /** + * map<string, string> options = 3; + */ + @java.lang.Override + + public java.util.Map getOptionsMap() { + return internalGetOptions().getMap(); + } + /** + * map<string, string> options = 3; + */ + @java.lang.Override + + public java.lang.String getOptionsOrDefault( + java.lang.String key, + java.lang.String defaultValue) { + if (key == null) { throw new NullPointerException("map key"); } + java.util.Map map = + internalGetOptions().getMap(); + return map.containsKey(key) ? map.get(key) : defaultValue; + } + /** + * map<string, string> options = 3; + */ + @java.lang.Override + + public java.lang.String getOptionsOrThrow( + java.lang.String key) { + if (key == null) { throw new NullPointerException("map key"); } + java.util.Map map = + internalGetOptions().getMap(); + if (!map.containsKey(key)) { + throw new java.lang.IllegalArgumentException(); + } + return map.get(key); + } + private byte memoizedIsInitialized = -1; @java.lang.Override public final boolean isInitialized() { @@ -10094,6 +10237,12 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) if (createIfNotExists_ != false) { output.writeBool(2, createIfNotExists_); } + com.google.protobuf.GeneratedMessageV3 + .serializeStringMapTo( + output, + internalGetOptions(), + OptionsDefaultEntryHolder.defaultEntry, + 3); unknownFields.writeTo(output); } @@ -10110,6 +10259,16 @@ public int getSerializedSize() { size += com.google.protobuf.CodedOutputStream .computeBoolSize(2, createIfNotExists_); } + for (java.util.Map.Entry entry + : internalGetOptions().getMap().entrySet()) { + com.google.protobuf.MapEntry + options__ = OptionsDefaultEntryHolder.defaultEntry.newBuilderForType() + .setKey(entry.getKey()) + .setValue(entry.getValue()) + .build(); + size += com.google.protobuf.CodedOutputStream + .computeMessageSize(3, options__); + } size += unknownFields.getSerializedSize(); memoizedSize = size; return size; @@ -10129,6 +10288,8 @@ public boolean equals(final java.lang.Object obj) { .equals(other.getDatabaseName())) return false; if (getCreateIfNotExists() != other.getCreateIfNotExists()) return false; + if (!internalGetOptions().equals( + other.internalGetOptions())) return false; if (!unknownFields.equals(other.unknownFields)) return false; return true; } @@ -10145,6 +10306,10 @@ public int hashCode() { hash = (37 * hash) + CREATE_IF_NOT_EXISTS_FIELD_NUMBER; hash = (53 * hash) + com.google.protobuf.Internal.hashBoolean( getCreateIfNotExists()); + if (!internalGetOptions().getMap().isEmpty()) { + hash = (37 * hash) + OPTIONS_FIELD_NUMBER; + hash = (53 * hash) + internalGetOptions().hashCode(); + } hash = (29 * hash) + unknownFields.hashCode(); memoizedHashCode = hash; return hash; @@ -10252,6 +10417,28 @@ public static final class Builder extends return io.greptime.v1.Ddl.internal_static_greptime_v1_CreateDatabaseExpr_descriptor; } + @SuppressWarnings({"rawtypes"}) + protected com.google.protobuf.MapField internalGetMapField( + int number) { + switch (number) { + case 3: + return internalGetOptions(); + default: + throw new RuntimeException( + "Invalid map field number: " + number); + } + } + @SuppressWarnings({"rawtypes"}) + protected com.google.protobuf.MapField internalGetMutableMapField( + int number) { + switch (number) { + case 3: + return internalGetMutableOptions(); + default: + throw new RuntimeException( + "Invalid map field number: " + number); + } + } @java.lang.Override protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable() { @@ -10282,6 +10469,7 @@ public Builder clear() { createIfNotExists_ = false; + internalGetMutableOptions().clear(); return this; } @@ -10308,8 +10496,11 @@ public io.greptime.v1.Ddl.CreateDatabaseExpr build() { @java.lang.Override public io.greptime.v1.Ddl.CreateDatabaseExpr buildPartial() { io.greptime.v1.Ddl.CreateDatabaseExpr result = new io.greptime.v1.Ddl.CreateDatabaseExpr(this); + int from_bitField0_ = bitField0_; result.databaseName_ = databaseName_; result.createIfNotExists_ = createIfNotExists_; + result.options_ = internalGetOptions(); + result.options_.makeImmutable(); onBuilt(); return result; } @@ -10365,6 +10556,8 @@ public Builder mergeFrom(io.greptime.v1.Ddl.CreateDatabaseExpr other) { if (other.getCreateIfNotExists() != false) { setCreateIfNotExists(other.getCreateIfNotExists()); } + internalGetMutableOptions().mergeFrom( + other.internalGetOptions()); this.mergeUnknownFields(other.unknownFields); onChanged(); return this; @@ -10393,6 +10586,7 @@ public Builder mergeFrom( } return this; } + private int bitField0_; private java.lang.Object databaseName_ = ""; /** @@ -10500,6 +10694,137 @@ public Builder clearCreateIfNotExists() { onChanged(); return this; } + + private com.google.protobuf.MapField< + java.lang.String, java.lang.String> options_; + private com.google.protobuf.MapField + internalGetOptions() { + if (options_ == null) { + return com.google.protobuf.MapField.emptyMapField( + OptionsDefaultEntryHolder.defaultEntry); + } + return options_; + } + private com.google.protobuf.MapField + internalGetMutableOptions() { + onChanged();; + if (options_ == null) { + options_ = com.google.protobuf.MapField.newMapField( + OptionsDefaultEntryHolder.defaultEntry); + } + if (!options_.isMutable()) { + options_ = options_.copy(); + } + return options_; + } + + public int getOptionsCount() { + return internalGetOptions().getMap().size(); + } + /** + * map<string, string> options = 3; + */ + + @java.lang.Override + public boolean containsOptions( + java.lang.String key) { + if (key == null) { throw new NullPointerException("map key"); } + return internalGetOptions().getMap().containsKey(key); + } + /** + * Use {@link #getOptionsMap()} instead. + */ + @java.lang.Override + @java.lang.Deprecated + public java.util.Map getOptions() { + return getOptionsMap(); + } + /** + * map<string, string> options = 3; + */ + @java.lang.Override + + public java.util.Map getOptionsMap() { + return internalGetOptions().getMap(); + } + /** + * map<string, string> options = 3; + */ + @java.lang.Override + + public java.lang.String getOptionsOrDefault( + java.lang.String key, + java.lang.String defaultValue) { + if (key == null) { throw new NullPointerException("map key"); } + java.util.Map map = + internalGetOptions().getMap(); + return map.containsKey(key) ? map.get(key) : defaultValue; + } + /** + * map<string, string> options = 3; + */ + @java.lang.Override + + public java.lang.String getOptionsOrThrow( + java.lang.String key) { + if (key == null) { throw new NullPointerException("map key"); } + java.util.Map map = + internalGetOptions().getMap(); + if (!map.containsKey(key)) { + throw new java.lang.IllegalArgumentException(); + } + return map.get(key); + } + + public Builder clearOptions() { + internalGetMutableOptions().getMutableMap() + .clear(); + return this; + } + /** + * map<string, string> options = 3; + */ + + public Builder removeOptions( + java.lang.String key) { + if (key == null) { throw new NullPointerException("map key"); } + internalGetMutableOptions().getMutableMap() + .remove(key); + return this; + } + /** + * Use alternate mutation accessors instead. + */ + @java.lang.Deprecated + public java.util.Map + getMutableOptions() { + return internalGetMutableOptions().getMutableMap(); + } + /** + * map<string, string> options = 3; + */ + public Builder putOptions( + java.lang.String key, + java.lang.String value) { + if (key == null) { throw new NullPointerException("map key"); } + if (value == null) { + throw new NullPointerException("map value"); +} + + internalGetMutableOptions().getMutableMap() + .put(key, value); + return this; + } + /** + * map<string, string> options = 3; + */ + + public Builder putAllOptions( + java.util.Map values) { + internalGetMutableOptions().getMutableMap() + .putAll(values); + return this; + } @java.lang.Override public final Builder setUnknownFields( final com.google.protobuf.UnknownFieldSet unknownFields) { @@ -16568,6 +16893,11 @@ public io.greptime.v1.Ddl.TableId getDefaultInstanceForType() { private static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_greptime_v1_CreateDatabaseExpr_fieldAccessorTable; + private static final com.google.protobuf.Descriptors.Descriptor + internal_static_greptime_v1_CreateDatabaseExpr_OptionsEntry_descriptor; + private static final + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internal_static_greptime_v1_CreateDatabaseExpr_OptionsEntry_fieldAccessorTable; private static final com.google.protobuf.Descriptors.Descriptor internal_static_greptime_v1_TruncateTableExpr_descriptor; private static final @@ -16655,26 +16985,29 @@ public io.greptime.v1.Ddl.TableId getDefaultInstanceForType() { "able_id\030\005 \001(\0132\024.greptime.v1.TableId\"h\n\020C" + "ompactTableExpr\022\024\n\014catalog_name\030\001 \001(\t\022\023\n" + "\013schema_name\030\002 \001(\t\022\022\n\ntable_name\030\003 \001(\t\022\025" + - "\n\rregion_number\030\004 \001(\r\"I\n\022CreateDatabaseE" + - "xpr\022\025\n\rdatabase_name\030\001 \001(\t\022\034\n\024create_if_" + - "not_exists\030\002 \001(\010\"z\n\021TruncateTableExpr\022\024\n" + - "\014catalog_name\030\001 \001(\t\022\023\n\013schema_name\030\002 \001(\t" + - "\022\022\n\ntable_name\030\003 \001(\t\022&\n\010table_id\030\004 \001(\0132\024" + - ".greptime.v1.TableId\"9\n\nAddColumns\022+\n\013ad" + - "d_columns\030\001 \003(\0132\026.greptime.v1.AddColumn\"" + - "<\n\013DropColumns\022-\n\014drop_columns\030\001 \003(\0132\027.g" + - "reptime.v1.DropColumn\"%\n\013RenameTable\022\026\n\016" + - "new_table_name\030\001 \001(\t\"\215\002\n\tAddColumn\022*\n\nco" + - "lumn_def\030\001 \001(\0132\026.greptime.v1.ColumnDef\022\016" + - "\n\006is_key\030\002 \001(\010\0221\n\010location\030\003 \001(\0132\037.grept" + - "ime.v1.AddColumn.Location\032\220\001\n\010Location\022C" + - "\n\rlocation_type\030\001 \001(\0162,.greptime.v1.AddC" + - "olumn.Location.LocationType\022\031\n\021after_clo" + - "umn_name\030\002 \001(\t\"$\n\014LocationType\022\t\n\005FIRST\020" + - "\000\022\t\n\005AFTER\020\001\"\032\n\nDropColumn\022\014\n\004name\030\001 \001(\t" + - "\"\025\n\007TableId\022\n\n\002id\030\001 \001(\rBL\n\016io.greptime.v" + - "1B\003DdlZ5github.com/GreptimeTeam/greptime" + - "-proto/go/greptime/v1b\006proto3" + "\n\rregion_number\030\004 \001(\r\"\270\001\n\022CreateDatabase" + + "Expr\022\025\n\rdatabase_name\030\001 \001(\t\022\034\n\024create_if" + + "_not_exists\030\002 \001(\010\022=\n\007options\030\003 \003(\0132,.gre" + + "ptime.v1.CreateDatabaseExpr.OptionsEntry" + + "\032.\n\014OptionsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002" + + " \001(\t:\0028\001\"z\n\021TruncateTableExpr\022\024\n\014catalog" + + "_name\030\001 \001(\t\022\023\n\013schema_name\030\002 \001(\t\022\022\n\ntabl" + + "e_name\030\003 \001(\t\022&\n\010table_id\030\004 \001(\0132\024.greptim" + + "e.v1.TableId\"9\n\nAddColumns\022+\n\013add_column" + + "s\030\001 \003(\0132\026.greptime.v1.AddColumn\"<\n\013DropC" + + "olumns\022-\n\014drop_columns\030\001 \003(\0132\027.greptime." + + "v1.DropColumn\"%\n\013RenameTable\022\026\n\016new_tabl" + + "e_name\030\001 \001(\t\"\215\002\n\tAddColumn\022*\n\ncolumn_def" + + "\030\001 \001(\0132\026.greptime.v1.ColumnDef\022\016\n\006is_key" + + "\030\002 \001(\010\0221\n\010location\030\003 \001(\0132\037.greptime.v1.A" + + "ddColumn.Location\032\220\001\n\010Location\022C\n\rlocati" + + "on_type\030\001 \001(\0162,.greptime.v1.AddColumn.Lo" + + "cation.LocationType\022\031\n\021after_cloumn_name" + + "\030\002 \001(\t\"$\n\014LocationType\022\t\n\005FIRST\020\000\022\t\n\005AFT" + + "ER\020\001\"\032\n\nDropColumn\022\014\n\004name\030\001 \001(\t\"\025\n\007Tabl" + + "eId\022\n\n\002id\030\001 \001(\rBL\n\016io.greptime.v1B\003DdlZ5" + + "github.com/GreptimeTeam/greptime-proto/g" + + "o/greptime/v1b\006proto3" }; descriptor = com.google.protobuf.Descriptors.FileDescriptor .internalBuildGeneratedFileFrom(descriptorData, @@ -16728,7 +17061,13 @@ public io.greptime.v1.Ddl.TableId getDefaultInstanceForType() { internal_static_greptime_v1_CreateDatabaseExpr_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_greptime_v1_CreateDatabaseExpr_descriptor, - new java.lang.String[] { "DatabaseName", "CreateIfNotExists", }); + new java.lang.String[] { "DatabaseName", "CreateIfNotExists", "Options", }); + internal_static_greptime_v1_CreateDatabaseExpr_OptionsEntry_descriptor = + internal_static_greptime_v1_CreateDatabaseExpr_descriptor.getNestedTypes().get(0); + internal_static_greptime_v1_CreateDatabaseExpr_OptionsEntry_fieldAccessorTable = new + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( + internal_static_greptime_v1_CreateDatabaseExpr_OptionsEntry_descriptor, + new java.lang.String[] { "Key", "Value", }); internal_static_greptime_v1_TruncateTableExpr_descriptor = getDescriptor().getMessageTypes().get(7); internal_static_greptime_v1_TruncateTableExpr_fieldAccessorTable = new diff --git a/proto/greptime/v1/ddl.proto b/proto/greptime/v1/ddl.proto index d150654b..31ab9a4d 100644 --- a/proto/greptime/v1/ddl.proto +++ b/proto/greptime/v1/ddl.proto @@ -92,6 +92,7 @@ message CompactTableExpr { message CreateDatabaseExpr { string database_name = 1; bool create_if_not_exists = 2; + map options = 3; } message TruncateTableExpr {