.vscode/setting.json

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

ApmBaseDataFlow.proto

@@ -1,7 +1,5 @@
 syntax = "proto3";
 
-import "Base.proto" ;
-
 option java_multiple_files = false;
 option java_package = "com.yuandian.dataflow.proto.msgtype";
 option go_package = "../grpc-gen;grpcgen";
@@ -16,8 +14,8 @@ message ApmBaseDataFlow {
     uint32 probe_if = 2;
     uint32 tuple_source = 3;
     uint32 tuple_dest = 4;
-    IPAddress tuple_saddr = 5;
+    uint32 tuple_saddr = 5;
-    IPAddress tuple_daddr = 6;
+    uint32 tuple_daddr = 6;
     string src_mac = 7;
     string dst_mac = 8;
     uint32 vlan_id = 9;

AppFlow.proto

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

BacktrackingFlow.proto

@@ -1,7 +1,5 @@
 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,22 +10,22 @@ package dataflow;
 message BacktrackingFlow {
 
     int32 table_id = 1;	//编号20
-	int64 mac_src = 2;
+int64 mac_src = 2;
-	int64 mac_dst = 3;
+int64 mac_dst = 3;
-	IPAddress ip_src = 4;
+int64 ip_src = 4;
-	IPAddress ip_dst = 5;
+int64 ip_dst = 5;
-	int32 port_src = 6;
+int32 port_src = 6;
-	int32 port_dst = 7;
+int32 port_dst = 7;
-	int32 l3_proto = 8;
+int32 l3_proto = 8;
-	int32 l4_proto = 9;
+int32 l4_proto = 9;
-	int32 tos = 10;
+int32 tos = 10;
-	int32 vlan_id = 11;
+int32 vlan_id = 11;
-	uint64 bytes = 12;
+uint64 bytes = 12;
-	uint64 packets = 13;
+uint64 packets = 13;
-	uint64 tcp_sp = 14;
+uint64 tcp_sp = 14;
-	uint64 tcp_scpn = 15;
+uint64 tcp_scpn = 15;
-	uint64 tcp_srp = 16;
+uint64 tcp_srp = 16;
-	uint32 app_id = 17;
+uint32 app_id = 17;
-	uint32 app_group_id = 18;
+uint32 app_group_id = 18;
-	int32 mpls_label = 19;
+int32 mpls_label = 19;
 }

Base.proto

@@ -5,6 +5,7 @@ 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;
@@ -21,13 +22,6 @@ 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);
 }

BussFlowDb.proto

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

BussFlowExternal.proto

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

BussFlowMidd.proto

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

BussFlowWeb.proto

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

QoeFlow.proto

@@ -1,7 +1,5 @@
 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 +9,8 @@ package dataflow;
 
 message QoeFlow {
    int32 table_id = 1;	//编号18
-   IPAddress src_ip = 2;
+   uint32 src_ip = 2;
-   IPAddress dst_ip  = 3;
+   uint32 dst_ip  = 3;
    uint32 s_tv_sec = 4;
    uint32 s_tv_usec = 5;
    uint32 l_tv_sec = 6;

UsrFlow.proto

@@ -1,7 +1,5 @@
 syntax = "proto3";
 
-import "Base.proto";
-
 option java_multiple_files = false;
 option java_package = "com.yuandian.dataflow.proto.msgtype";
 option go_package = "../grpc-gen;grpcgen";
@@ -13,8 +11,8 @@ message UsrFlow {
 
     int32 table_id = 1;	//编号19
     uint32 probe_if = 2;
-    IPAddress server_ip = 3;
+    uint32 server_ip = 3;
-    IPAddress client_ip = 4;
+    uint32 client_ip = 4;
     uint32 client_port = 5;
     uint32 client_rtt = 6;
     uint32 server_rtt = 7;