feat: conf.

api/conf/v1/kratos_conf_data.proto

@@ -30,28 +30,47 @@ message Data {
     google.protobuf.Duration write_timeout = 7; // 写入超时时间
   }
 
+  // MongoDB
+  message MongoDB {
+    string address = 1;
+  }
+
+  // ClickHouse
+  message ClickHouse {
+    string address = 1;
+  }
+
+  // InfluxDB
+  message InfluxDB {
+    string address = 1;
+    string token = 2;
+    string orgnization = 3;
+    string bucket = 4;
+  }
+
   // Kafka
   message Kafka {
     repeated string addrs = 1;  // 对端网络地址
     string codec = 2;  // 编解码器
   }
 
-  // MongoDB
-  message MongoDB {
+  message Doris {
+    string address = 1;
   }
 
-  // ClickHouse
-  message ClickHouse {
+  message ElasticSearch {
+    string address = 1;
   }
 
-  // InfluxDB
-  message InfluxDB {
-  }
+  Database database = 1;  // 数据库DSN
 
-  Database database = 1;  // 数据库
-  Redis redis = 2;  // Redis
-  Kafka kafka = 3;  // Kafka服务
-  MongoDB mongodb = 4;  // MongoDB服务
-  ClickHouse clickhouse = 5;  // ClickHouse服务
-  InfluxDB influxdb = 6;  // InfluxDB服务
+  Redis redis = 10;  // Redis
+  MongoDB mongodb = 11;  // MongoDB数据库
+  ElasticSearch elastic_search = 12;  // ElasticSearch数据库
+
+  ClickHouse clickhouse = 20;  // ClickHouse数据库
+  InfluxDB influxdb = 21;  // InfluxDB数据库
+  Doris doris = 22;  // Doris数据库
+
+  Kafka kafka = 30;  // Kafka服务
 }

api/conf/v1/kratos_conf_server.proto

@@ -57,6 +57,48 @@ message Server {
     repeated string addrs = 1;  // 对端网络地址
   }
 
+  message ActiveMQ {
+    string endpoint = 1;  // 对端网络地址
+    string codec = 2;  // 编解码器: json,xml,yaml...
+  }
+
+  message NATS {
+    string endpoint = 1;  // 对端网络地址
+    string codec = 2;  // 编解码器: json,xml,yaml...
+  }
+
+  message NSQ {
+    string endpoint = 1;  // 对端网络地址
+    string codec = 2;  // 编解码器: json,xml,yaml...
+  }
+
+  message Pulsar {
+    string endpoint = 1;  // 对端网络地址
+    string codec = 2;  // 编解码器: json,xml,yaml...
+  }
+
+  message Redis {
+    string endpoint = 1;  // 对端网络地址
+    string codec = 2;  // 编解码器: json,xml,yaml...
+  }
+
+  message RocketMQ {
+    string version = 1; // 驱动版本：aliyun、v2、v5
+    string codec = 2;  // 编解码器: json,xml,yaml...
+    bool enable_trace = 3;
+
+    repeated string name_servers = 4;
+    string name_server_domain = 5;
+
+    string access_key = 6;
+    string secret_key = 7;
+    string security_token = 8;
+
+    string namespace = 9;
+    string instance_name = 10;
+    string group_name = 11;
+  }
+
   // Asynq
   message Asynq {
     string endpoint = 1;  // 对端网络地址
@@ -74,42 +116,86 @@ message Server {
   message SSE {
     string network = 1; // 网络
     string addr = 2;  // 服务监听地址
-    google.protobuf.Duration timeout = 3; // 超时时间
-    string path = 4;  // 路径
-    string codec = 5;  // 编解码器
+    string path = 3;  // 路径
+    string codec = 4;  // 编解码器
+
+    google.protobuf.Duration timeout = 5; // 超时时间
+    google.protobuf.Duration event_ttl = 6; // 超时时间
+
+    bool auto_stream = 7; //
+    bool auto_reply = 8; //
+    bool split_data = 9; //
+    bool encode_base64 = 10; // 进行BASE64编码
   }
 
   // SocketIO
   message SocketIO {
-
+    string network = 1; // 网络
+    string addr = 2;  // 服务监听地址
+    string path = 3;  // 路径
+    string codec = 4;  // 编解码器
   }
 
   // SignalR
   message SignalR {
+    string network = 1; // 网络
+    string addr = 2;  // 服务监听地址
+    string codec = 3;  // 编解码器
 
+    google.protobuf.Duration keep_alive_interval = 4; // 超时时间
+    google.protobuf.Duration chan_receive_timeout = 5; // 超时时间
+    bool debug = 6; // 调试开关
+    uint32 stream_buffer_capacity = 7; //
   }
 
   // GraphQL
   message GraphQL {
-
+    string network = 1; // 网络
+    string addr = 2;  // 服务监听地址
+    string path = 3;  // 路径
+    string codec = 4;  // 编解码器
+    google.protobuf.Duration timeout = 5; // 超时时间
+    bool strict_slash = 6;
   }
 
   // Thrift
   message Thrift {
-
+    string network = 1; // 网络
+    string addr = 2;  // 服务监听地址
+    string protocol = 3;
+    bool buffered = 4;
+    bool framed = 5;
+    bool buffer_size = 6;
   }
 
+  // RPC
+
   REST rest = 1;  // REST服务
   GRPC grpc = 2;  // gRPC服务
-  Websocket websocket = 3;  // Websocket服务
-  Mqtt mqtt = 4;  // MQTT服务
-  Kafka kafka = 5;  // Kafka服务
-  RabbitMQ rabbitmq = 6;  // RabbitMQ服务
-  Asynq asynq = 7;  // Asynq服务
-  Machinery machinery = 8;  // Machinery服务
-  SSE sse = 9;  // SSE服务
-  SocketIO socketio = 10;  // SocketIO服务
-  SignalR signalr = 11;  // SignalR服务
-  GraphQL graphql = 12;  // GraphQL服务
-  Thrift thrift = 13;  // Thrift服务
+  GraphQL graphql = 3;  // GraphQL服务
+  Thrift thrift = 4;  // Thrift服务
+
+  // Message Queue
+
+  Mqtt mqtt = 10;  // MQTT服务
+  Kafka kafka = 11;  // Kafka服务
+  RabbitMQ rabbitmq = 12;  // RabbitMQ服务
+  ActiveMQ activemq = 13; // ActiveMQ
+  NATS nats = 14; // NATS
+  NSQ nsq = 15; // NATS
+  Pulsar pulsar = 16; // Pulsar
+  Redis redis = 17; // Redis
+  RocketMQ rocketmq = 18; // RocketMQ
+
+ // RealTime
+
+  Websocket websocket = 20;  // Websocket服务
+  SSE sse = 21;  // SSE服务
+  SocketIO socketio = 22;  // SocketIO服务
+  SignalR signalr = 23;  // SignalR服务
+
+  // Task Queue
+
+  Asynq asynq = 30;  // Asynq服务
+  Machinery machinery = 31;  // Machinery服务
 }