tx7do/kratos-bootstrap
Public Access
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: edit pagination api.

Browse Source
This commit is contained in:
tx7do
2024-12-15 12:12:46 +08:00
parent 612a81089c
commit a24d01286b
17 changed files with 494 additions and 1651 deletions
Download Patch File Download Diff File Expand all files Collapse all files

406
api/gen/go/conf/v1/kratos_conf_data.pb.go
View File

@@ -1,6 +1,6 @@
// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.31.0
// protoc-gen-go v1.35.2
// protoc (unknown)
// source: conf/v1/kratos_conf_data.proto
@@ -47,11 +47,9 @@ type Data struct {
func (x *Data) Reset() {
*x = Data{}
if protoimpl.UnsafeEnabled {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[0]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[0]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Data) String() string {
@@ -62,7 +60,7 @@ func (*Data) ProtoMessage() {}
func (x *Data) ProtoReflect() protoreflect.Message {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[0]
if protoimpl.UnsafeEnabled && x != nil {
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -211,11 +209,9 @@ type Data_Database struct {
func (x *Data_Database) Reset() {
*x = Data_Database{}
if protoimpl.UnsafeEnabled {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[1]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[1]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Data_Database) String() string {
@@ -226,7 +222,7 @@ func (*Data_Database) ProtoMessage() {}
func (x *Data_Database) ProtoReflect() protoreflect.Message {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[1]
if protoimpl.UnsafeEnabled && x != nil {
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -344,11 +340,9 @@ type Data_Redis struct {
func (x *Data_Redis) Reset() {
*x = Data_Redis{}
if protoimpl.UnsafeEnabled {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[2]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[2]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Data_Redis) String() string {
@@ -359,7 +353,7 @@ func (*Data_Redis) ProtoMessage() {}
func (x *Data_Redis) ProtoReflect() protoreflect.Message {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[2]
if protoimpl.UnsafeEnabled && x != nil {
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -450,11 +444,9 @@ type Data_MongoDB struct {
func (x *Data_MongoDB) Reset() {
*x = Data_MongoDB{}
if protoimpl.UnsafeEnabled {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[3]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[3]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Data_MongoDB) String() string {
@@ -465,7 +457,7 @@ func (*Data_MongoDB) ProtoMessage() {}
func (x *Data_MongoDB) ProtoReflect() protoreflect.Message {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[3]
if protoimpl.UnsafeEnabled && x != nil {
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -530,11 +522,9 @@ type Data_ClickHouse struct {
func (x *Data_ClickHouse) Reset() {
*x = Data_ClickHouse{}
if protoimpl.UnsafeEnabled {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[4]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[4]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Data_ClickHouse) String() string {
@@ -545,7 +535,7 @@ func (*Data_ClickHouse) ProtoMessage() {}
func (x *Data_ClickHouse) ProtoReflect() protoreflect.Message {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[4]
if protoimpl.UnsafeEnabled && x != nil {
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -707,11 +697,9 @@ type Data_InfluxDB struct {
func (x *Data_InfluxDB) Reset() {
*x = Data_InfluxDB{}
if protoimpl.UnsafeEnabled {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[5]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[5]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Data_InfluxDB) String() string {
@@ -722,7 +710,7 @@ func (*Data_InfluxDB) ProtoMessage() {}
func (x *Data_InfluxDB) ProtoReflect() protoreflect.Message {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[5]
if protoimpl.UnsafeEnabled && x != nil {
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -775,11 +763,9 @@ type Data_Doris struct {
func (x *Data_Doris) Reset() {
*x = Data_Doris{}
if protoimpl.UnsafeEnabled {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[6]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[6]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Data_Doris) String() string {
@@ -790,7 +776,7 @@ func (*Data_Doris) ProtoMessage() {}
func (x *Data_Doris) ProtoReflect() protoreflect.Message {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[6]
if protoimpl.UnsafeEnabled && x != nil {
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -827,11 +813,9 @@ type Data_ElasticSearch struct {
func (x *Data_ElasticSearch) Reset() {
*x = Data_ElasticSearch{}
if protoimpl.UnsafeEnabled {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[7]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[7]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Data_ElasticSearch) String() string {
@@ -842,7 +826,7 @@ func (*Data_ElasticSearch) ProtoMessage() {}
func (x *Data_ElasticSearch) ProtoReflect() protoreflect.Message {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[7]
if protoimpl.UnsafeEnabled && x != nil {
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -918,11 +902,9 @@ type Data_Cassandra struct {
func (x *Data_Cassandra) Reset() {
*x = Data_Cassandra{}
if protoimpl.UnsafeEnabled {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[8]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[8]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Data_Cassandra) String() string {
@@ -933,7 +915,7 @@ func (*Data_Cassandra) ProtoMessage() {}
func (x *Data_Cassandra) ProtoReflect() protoreflect.Message {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[8]
if protoimpl.UnsafeEnabled && x != nil {
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1026,11 +1008,9 @@ type Data_Snowflake struct {
func (x *Data_Snowflake) Reset() {
*x = Data_Snowflake{}
if protoimpl.UnsafeEnabled {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[9]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[9]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Data_Snowflake) String() string {
@@ -1041,7 +1021,7 @@ func (*Data_Snowflake) ProtoMessage() {}
func (x *Data_Snowflake) ProtoReflect() protoreflect.Message {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[9]
if protoimpl.UnsafeEnabled && x != nil {
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1075,11 +1055,9 @@ type Data_Kafka struct {
func (x *Data_Kafka) Reset() {
*x = Data_Kafka{}
if protoimpl.UnsafeEnabled {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[10]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[10]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Data_Kafka) String() string {
@@ -1090,7 +1068,7 @@ func (*Data_Kafka) ProtoMessage() {}
func (x *Data_Kafka) ProtoReflect() protoreflect.Message {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[10]
if protoimpl.UnsafeEnabled && x != nil {
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1179,11 +1157,9 @@ type Data_RabbitMQ struct {
func (x *Data_RabbitMQ) Reset() {
*x = Data_RabbitMQ{}
if protoimpl.UnsafeEnabled {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[11]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[11]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Data_RabbitMQ) String() string {
@@ -1194,7 +1170,7 @@ func (*Data_RabbitMQ) ProtoMessage() {}
func (x *Data_RabbitMQ) ProtoReflect() protoreflect.Message {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[11]
if protoimpl.UnsafeEnabled && x != nil {
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1228,11 +1204,9 @@ type Data_Mqtt struct {
func (x *Data_Mqtt) Reset() {
*x = Data_Mqtt{}
if protoimpl.UnsafeEnabled {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[12]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[12]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Data_Mqtt) String() string {
@@ -1243,7 +1217,7 @@ func (*Data_Mqtt) ProtoMessage() {}
func (x *Data_Mqtt) ProtoReflect() protoreflect.Message {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[12]
if protoimpl.UnsafeEnabled && x != nil {
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1283,11 +1257,9 @@ type Data_ActiveMQ struct {
func (x *Data_ActiveMQ) Reset() {
*x = Data_ActiveMQ{}
if protoimpl.UnsafeEnabled {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[13]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[13]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Data_ActiveMQ) String() string {
@@ -1298,7 +1270,7 @@ func (*Data_ActiveMQ) ProtoMessage() {}
func (x *Data_ActiveMQ) ProtoReflect() protoreflect.Message {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[13]
if protoimpl.UnsafeEnabled && x != nil {
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1338,11 +1310,9 @@ type Data_NATS struct {
func (x *Data_NATS) Reset() {
*x = Data_NATS{}
if protoimpl.UnsafeEnabled {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[14]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[14]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Data_NATS) String() string {
@@ -1353,7 +1323,7 @@ func (*Data_NATS) ProtoMessage() {}
func (x *Data_NATS) ProtoReflect() protoreflect.Message {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[14]
if protoimpl.UnsafeEnabled && x != nil {
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1393,11 +1363,9 @@ type Data_NSQ struct {
func (x *Data_NSQ) Reset() {
*x = Data_NSQ{}
if protoimpl.UnsafeEnabled {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[15]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[15]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Data_NSQ) String() string {
@@ -1408,7 +1376,7 @@ func (*Data_NSQ) ProtoMessage() {}
func (x *Data_NSQ) ProtoReflect() protoreflect.Message {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[15]
if protoimpl.UnsafeEnabled && x != nil {
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1448,11 +1416,9 @@ type Data_Pulsar struct {
func (x *Data_Pulsar) Reset() {
*x = Data_Pulsar{}
if protoimpl.UnsafeEnabled {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[16]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[16]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Data_Pulsar) String() string {
@@ -1463,7 +1429,7 @@ func (*Data_Pulsar) ProtoMessage() {}
func (x *Data_Pulsar) ProtoReflect() protoreflect.Message {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[16]
if protoimpl.UnsafeEnabled && x != nil {
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1512,11 +1478,9 @@ type Data_RocketMQ struct {
func (x *Data_RocketMQ) Reset() {
*x = Data_RocketMQ{}
if protoimpl.UnsafeEnabled {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[17]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[17]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Data_RocketMQ) String() string {
@@ -1527,7 +1491,7 @@ func (*Data_RocketMQ) ProtoMessage() {}
func (x *Data_RocketMQ) ProtoReflect() protoreflect.Message {
mi := &file_conf_v1_kratos_conf_data_proto_msgTypes[17]
if protoimpl.UnsafeEnabled && x != nil {
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1962,7 +1926,7 @@ func file_conf_v1_kratos_conf_data_proto_rawDescGZIP() []byte {
}
var file_conf_v1_kratos_conf_data_proto_msgTypes = make([]protoimpl.MessageInfo, 18)
var file_conf_v1_kratos_conf_data_proto_goTypes = []interface{}{
var file_conf_v1_kratos_conf_data_proto_goTypes = []any{
(*Data)(nil), // 0: conf.Data
(*Data_Database)(nil), // 1: conf.Data.Database
(*Data_Redis)(nil), // 2: conf.Data.Redis
@@ -2029,226 +1993,8 @@ func file_conf_v1_kratos_conf_data_proto_init() {
return
}
file_conf_v1_kratos_conf_tls_proto_init()
if !protoimpl.UnsafeEnabled {
file_conf_v1_kratos_conf_data_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Data); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_conf_v1_kratos_conf_data_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Data_Database); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_conf_v1_kratos_conf_data_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Data_Redis); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_conf_v1_kratos_conf_data_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Data_MongoDB); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_conf_v1_kratos_conf_data_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Data_ClickHouse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_conf_v1_kratos_conf_data_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Data_InfluxDB); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_conf_v1_kratos_conf_data_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Data_Doris); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_conf_v1_kratos_conf_data_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Data_ElasticSearch); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_conf_v1_kratos_conf_data_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Data_Cassandra); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_conf_v1_kratos_conf_data_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Data_Snowflake); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_conf_v1_kratos_conf_data_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Data_Kafka); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_conf_v1_kratos_conf_data_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Data_RabbitMQ); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_conf_v1_kratos_conf_data_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Data_Mqtt); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_conf_v1_kratos_conf_data_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Data_ActiveMQ); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_conf_v1_kratos_conf_data_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Data_NATS); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_conf_v1_kratos_conf_data_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Data_NSQ); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_conf_v1_kratos_conf_data_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Data_Pulsar); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_conf_v1_kratos_conf_data_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Data_RocketMQ); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
}
file_conf_v1_kratos_conf_data_proto_msgTypes[0].OneofWrappers = []interface{}{}
file_conf_v1_kratos_conf_data_proto_msgTypes[1].OneofWrappers = []interface{}{}
file_conf_v1_kratos_conf_data_proto_msgTypes[0].OneofWrappers = []any{}
file_conf_v1_kratos_conf_data_proto_msgTypes[1].OneofWrappers = []any{}
type x struct{}
out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{