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

Merge branch 'feature/v1.0.3-220707' into 'master'

Browse Source 
Feature/v1.0.3 220707

See merge request project/proto/dataflow!3
This commit is contained in:
黄思敏 2022-07-07 02:46:55 +00:00
commit bc997440f0
11 changed files with 70 additions and 41 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
.vscode/setting.json vendored Normal file
View File

@ -0,0 +1,5 @@
{
"protoc": {
"options": ["-I proto"]
}
}

6
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";
@ -14,8 +16,8 @@ message ApmBaseDataFlow {
uint32 probe_if = 2;
uint32 tuple_source = 3;
uint32 tuple_dest = 4;
uint32 tuple_saddr = 5;
uint32 tuple_daddr = 6;
IPAddress tuple_saddr = 5;
IPAddress tuple_daddr = 6;
string src_mac = 7;
string dst_mac = 8;
uint32 vlan_id = 9;

10
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";
@ -9,10 +11,10 @@ package dataflow;
message AppFlow {
int32 table_id = 1; //编号17
uint32 src_ip = 2
IPAddress src_ip = 2;
uint32 src_port = 3;
uint32 dst_ip = 4;
uint32 dst_port = 5
IPAddress dst_ip = 4;
uint32 dst_port = 5;
uint32 s_tv_sec = 6;
uint32 s_tv_usec = 7;
uint32 l_tv_sec = 8;
@ -26,7 +28,7 @@ message AppFlow {
string protocol = 16;
uint32 app_id = 17;
uint32 app_group_id = 18;
uint32 probe_id = 19;
uint32 probe_if = 19;
uint32 app_style = 20;
uint32 time_flag = 21;
int32 vlan_id = 22;

6
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";
@ -12,8 +14,8 @@ message BacktrackingFlow {
int32 table_id = 1; //编号20
int64 mac_src = 2;
int64 mac_dst = 3;
int64 ip_src = 4;
int64 ip_dst = 5;
IPAddress ip_src = 4;
IPAddress ip_dst = 5;
int32 port_src = 6;
int32 port_dst = 7;
int32 l3_proto = 8;

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);
}

6
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";
@ -32,9 +34,9 @@ uint32 recog_status = 19;
uint32 probe_if = 20;
string channel = 21;
string dbname = 22;
uint32 request_ip = 23;
IPAddress request_ip = 23;
uint32 request_port = 24;
uint32 response_ip = 25;
IPAddress response_ip = 25;
uint32 response_port = 26;
int64 status = 27;
int64 server_translate_time = 28;

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;

6
UsrFlow.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";
@ -11,8 +13,8 @@ message UsrFlow {
int32 table_id = 1; //编号19
uint32 probe_if = 2;
uint32 server_ip = 3;
uint32 client_ip = 4;
IPAddress server_ip = 3;
IPAddress client_ip = 4;
uint32 client_port = 5;
uint32 client_rtt = 6;
uint32 server_rtt = 7;