yuandian/proto
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

添加 IPAddress结构

Browse Source
This commit is contained in:
huangsimin 2022-07-04 13:42:09 +08:00
parent 4bccad3eec
commit e7efff5fd2
9 changed files with 32 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ApmBaseDataFlow.proto
View File

@ -1,5 +1,7 @@
syntax = "proto3";
import "Base.proto" ;
option java_multiple_files = false;
option java_package = "com.yuandian.dataflow.proto.msgtype";
option go_package = "../grpc-gen;grpcgen";

2
AppFlow.proto
View File

@ -1,5 +1,7 @@
syntax = "proto3";
import "Base.proto" ;
option java_multiple_files = false;
option java_package = "com.yuandian.dataflow.proto.msgtype";
option go_package = "../grpc-gen;grpcgen";

2
BacktrackingFlow.proto
View File

@ -1,5 +1,7 @@
syntax = "proto3";
import "Base.proto" ;
option java_multiple_files = false;
option java_package = "com.yuandian.dataflow.proto.msgtype";
option go_package = "../grpc-gen;grpcgen";

8
Base.proto
View File

@ -5,7 +5,6 @@ import "google/protobuf/any.proto";
option java_multiple_files = false; //不要拆分成多个文件
option java_package = "com.yuandian.dataflow.proto";
option go_package = "../grpc-gen;grpcgen";
package dataflow;
@ -22,6 +21,13 @@ message Request {
repeated google.protobuf.Any param = 3; // 请求的可变参数. 暂不使用
}
message IPAddress {
oneof IP {
bytes v4 = 1;
bytes v6 = 2;
}
}
service CollectPacketsServer {
rpc GetPackets (Request) returns (stream Response);
}

4
BussFlowDb.proto
View File

@ -1,5 +1,7 @@
syntax = "proto3";
import "Base.proto" ;
option java_multiple_files = false;
option java_package = "com.yuandian.dataflow.proto.msgtype";
option go_package = "../grpc-gen;grpcgen";
@ -10,7 +12,7 @@ package dataflow;
message BussFlowDb {
int32 table_id = 1; //编号24
int32 table_id = 1; //编号24
uint32 msg_type = 2;
string msg_version = 3;
uint32 msg_seq = 4;

6
BussFlowExternal.proto
View File

@ -1,5 +1,7 @@
syntax = "proto3";
import "Base.proto" ;
option java_multiple_files = false;
option java_package = "com.yuandian.dataflow.proto.msgtype";
option go_package = "../grpc-gen;grpcgen";
@ -15,9 +17,9 @@ message BussFlowExternal {
uint32 msg_len = 5;
uint64 src_mac = 6;
uint64 dst_mac = 7;
uint32 request_ip = 8;
IPAddress request_ip = 8;
uint32 request_port = 9;
uint32 response_ip = 10;
IPAddress response_ip = 10;
uint32 response_port = 11;
uint32 probeif = 12;
uint32 protocol = 13;

6
BussFlowMidd.proto
View File

@ -1,5 +1,7 @@
syntax = "proto3";
import "Base.proto" ;
option java_multiple_files = false;
option java_package = "com.yuandian.dataflow.proto.msgtype";
option go_package = "../grpc-gen;grpcgen";
@ -29,9 +31,9 @@ message BussFlowMidd {
uint32 recog_status = 19;
uint32 probe_if = 20; //探针编号
string channel = 21; //通道
uint32 request_ip = 22; //请求地址
IPAddress request_ip = 22; //请求地址
uint32 request_port = 23; //请求端口
uint32 response_ip = 24; //响应地址
IPAddress response_ip = 24; //响应地址
uint32 response_port = 25; //响应端口
uint32 start_time_tv_sec = 26; //开始时间（秒）
uint32 start_time_tv_usec = 27; //开始时间（毫秒）

6
BussFlowWeb.proto
View File

@ -1,5 +1,7 @@
syntax = "proto3";
import "Base.proto";
option java_multiple_files = false;
option java_package = "com.yuandian.dataflow.proto.msgtype";
option go_package = "../grpc-gen;grpcgen";
@ -33,9 +35,9 @@ message BussFlowWeb {
uint32 probe_if = 23; //探针编号
string channel = 24; //业务类型
string sessionid = 25; //会话id
uint32 request_ip = 26; //请求ip地址
IPAddress request_ip = 26; //请求ip地址
uint32 request_port = 27; //请求端口
uint32 response_ip = 28; //响应ip地址
IPAddress response_ip = 28; //响应ip地址
uint32 response_port = 29; //响应端口
uint32 start_time_tv_sec = 30; //开始时间（秒）
uint32 start_time_tv_usec = 31; //开始时间（毫秒）

6
QoeFlow.proto
View File

@ -1,5 +1,7 @@
syntax = "proto3";
import "Base.proto";
option java_multiple_files = false;
option java_package = "com.yuandian.dataflow.proto.msgtype";
option go_package = "../grpc-gen;grpcgen";
@ -9,8 +11,8 @@ package dataflow;
message QoeFlow {
int32 table_id = 1; //编号18
uint32 src_ip = 2;
uint32 dst_ip = 3;
IPAddress src_ip = 2;
IPAddress dst_ip = 3;
uint32 s_tv_sec = 4;
uint32 s_tv_usec = 5;
uint32 l_tv_sec = 6;