diff --git a/ApmBaseDataFlow.proto b/ApmBaseDataFlow.proto index ec8322f..18f04e4 100644 --- a/ApmBaseDataFlow.proto +++ b/ApmBaseDataFlow.proto @@ -10,164 +10,44 @@ package dataflow; message ApmBaseDataFlow { - int32 table_id = 1; + int32 table_id = 1; //编号28 + uint32 probe_if = 2; + uint32 tuple_source = 3; + uint32 tuple_dest = 4; + uint32 tuple_saddr = 5; + uint32 tuple_daddr = 6; + string src_mac = 7; + string dst_mac = 8; + uint32 vlan_id = 9; + uint32 start_tm_tv_sec = 10; + uint32 start_tm_tv_usec = 11; + uint32 total_bytes = 12; + uint32 total_packets = 13; + uint32 total_drop_packets = 14; + uint32 retran_time_delay = 15; + uint32 client_rtt = 16; + uint32 server_rtt = 17; + uint32 user_response_time = 18; + uint32 server_response_time = 19; + uint32 con_fail = 20; + uint32 bytes_in = 21; + uint32 bytes_out = 22; + uint32 time_flag = 23; + uint32 end_tm_tv_sec = 24; + uint32 end_tm_tv_usec = 25; + uint32 respon_num = 26; + uint32 cs_window = 27; + uint32 sc_window = 28; + uint32 cs_reset = 29; + uint32 sc_reset = 30; + uint32 cs_retran = 31; + uint32 sc_retran = 32; + uint32 conn_setup_tm = 33; + uint32 new_session = 34; + uint32 cs_alert = 35; + uint32 sc_alert = 36; + string protocol = 37; - int32 probe_if = 2; - //四元组 - /** - * 请求端口 - */ - int32 request_port = 3; - /** - * 响应端口 - */ - int32 response_port = 4; - /** - * 请求IP - */ - int32 request_ip = 5; - /** - * 响应ip - */ - int32 response_ip = 6; - - /** - * 源mac - */ - int64 src_mac = 7; - - /** - * 目的mac - */ - int64 dst_mac = 8; - - /** - * 链路编号 - */ - int32 vlan_id = 9; - - int32 tv_sec = 10; - - int32 tv_usec = 11; - - /** - * 开始时间 - */ - int32 start_tm = 12; - - /** - * 总字节数 - */ - int32 total_bytes = 13; - - /** - * 总包数 - */ - int32 total_packets = 14; - /** - * 总丢包数 - */ - int32 total_drop_packets = 15; - /** - * 重传延时 - */ - int32 retran_time_delay = 16; - /** - * 客户端rtt - */ - int32 client_rtt = 17; - - /** - * 服务端Rtt - */ - int32 server_rtt = 18; - - - /** - * 用户响应时间 - */ - int32 user_response_time = 19; - /** - * 服务响应时间 - */ - int32 server_response_time = 20; - - - /** - * tcp回话连接失败数 - */ - int32 con_fail = 21; - - /** - * 会话重置数 - */ - // long reset = 22; - - /** - * 服务端总字节数 - */ - int32 bytes_in = 23; - /** - * 客户端总字节数 - */ - int32 bytes_out = 24; - /** - * 探针推送时间 - */ - int32 time_flag = 25; - - /** - * 结束时间 - */ - int32 end_tm = 26; - - /** - * 结束时间微秒 - */ - int32 end_tm_usec = 27; - - /** - * 总响应数 - */ - int32 respon_num = 28; - /** - * 客户端零窗口数 - */ - int32 cs_window = 29; - /** - * 服务端零窗口数 - */ - int32 sc_window = 30; - /** - * 客户端重置数 - */ - int32 cs_reset = 31; - /** - * 服务端重置数 - */ - int32 sc_reset = 32; - /** - * 客户端重传数 - */ - int32 cs_retran = 33; - /** - * 服务端重传数 - */ - int32 sc_retran = 34; - /** - * 会话建立时间 - */ - int32 conn_setup_tm = 35; - /** - * 新建会话数 - */ - int32 new_session = 36; - - int32 cs_alert = 37; - - int32 sc_alert = 38; - - string protocal = 39; } diff --git a/AppFlow.proto b/AppFlow.proto index fda72d6..1c8fb99 100644 --- a/AppFlow.proto +++ b/AppFlow.proto @@ -8,28 +8,28 @@ option go_package = "../grpc-gen;grpcgen"; package dataflow; message AppFlow { - int32 table_id = 1; - int32 src_ip = 2; - int32 src_port = 3; - int32 dst_ip = 4; - int32 dst_port = 5; - int32 start_tv_sec = 6; - int32 start_tv_usec = 7; - int32 last_tv_sec = 8; - int32 last_tv_usec = 9; - int32 end_tv_sec = 10; - int32 end_tv_usec = 11; - int32 input_packets = 12; - int32 output_packets = 13; - int32 input_bytes = 14; - int32 output_bytes = 15; - string protocaol = 16; - int32 app_id = 17; - int32 app_group_id = 18; - int32 probe_if = 19; - int32 app_style = 20; - int32 time_flag = 21; + int32 table_id = 1; //编号17 + uint32 src_ip = 2 + uint32 src_port = 3; + uint32 dst_ip = 4; + uint32 dst_port = 5 + uint32 s_tv_sec = 6; + uint32 s_tv_usec = 7; + uint32 l_tv_sec = 8; + uint32 l_tv_usec = 9; + uint32 e_tv_sec = 10; + uint32 e_tv_usec = 11; + uint32 input_packets = 12; + uint32 output_packets = 13; + uint32 input_bytes = 14; + uint32 output_bytes = 15; + string protocol = 16; + uint32 app_id = 17; + uint32 app_group_id = 18; + uint32 probe_id = 19; + uint32 app_style = 20; + uint32 time_flag = 21; int32 vlan_id = 22; - int32 mpls_lable = 23; + int32 mpls_label = 23; int32 tos = 24; } \ No newline at end of file diff --git a/BacktrackingFlow.proto b/BacktrackingFlow.proto index 34d0b0c..25be7f1 100644 --- a/BacktrackingFlow.proto +++ b/BacktrackingFlow.proto @@ -9,24 +9,23 @@ package dataflow; message BacktrackingFlow { - int32 table_id = 1; - int64 mac_src = 2; //源MAC 8 - int64 mac_dst = 3; //目的MAC 8 - int64 ip_src = 4; //源IP 8 - int64 ip_dst = 5; //目的IP 8 - int32 port_src = 6; //源端口，如果没有，为-1 - int32 port_dst = 7; //目标端口，如果没有，为-1 - int32 l3_proto = 8; //第三层协议ID，如果没有，为-1 - int32 l4_proto = 9; //第四层协议ID，如果没有，为-1 - int32 tos = 10; //Tos，如果没有，为-1 - int32 vlan_id = 11; //vlan ID，如果没有，为-1 - - int64 bytes = 12; // 8 字节总数 - int64 packets = 13; // 8 数据包总数 - int64 tcp_sp = 14; // 8 tcp同步包数 - int64 tcp_scpn = 15;// 8 tcp同步确认包数 - int64 tcp_srp = 16; // 8 tcp同步重置包数 - int32 app_id = 17; // 4 appID - int32 app_group_id = 18;// 4 app组ID - int32 mpls_label = 19;// 4 + int32 table_id = 1; //编号20 +int64 mac_src = 2; +int64 mac_dst = 3; +int64 ip_src = 4; +int64 ip_dst = 5; +int32 port_src = 6; +int32 port_dst = 7; +int32 l3_proto = 8; +int32 l4_proto = 9; +int32 tos = 10; +int32 vlan_id = 11; +uint64 bytes = 12; +uint64 packets = 13; +uint64 tcp_sp = 14; +uint64 tcp_scpn = 15; +uint64 tcp_srp = 16; +uint32 app_id = 17; +uint32 app_group_id = 18; +int32 mpls_label = 19; } \ No newline at end of file diff --git a/Base.proto b/Base.proto index dbda986..4b00fb3 100644 --- a/Base.proto +++ b/Base.proto @@ -9,17 +9,17 @@ option java_package = "com.yuandian.dataflow.proto"; option go_package = "../grpc-gen;grpcgen"; package dataflow; - + message Response { - int32 code = 1; - string message = 2; - repeated google.protobuf.Any packets = 4; + int32 code = 1; // 返回的状态码 + string message = 2; // 消息 + repeated google.protobuf.Any packets = 4; // 批量数据包 } message Request { int32 type = 1; // 请求类型. 默认 为 1. 暂无意义 string version = 2; // 请求版本. 区分版本. 非必要时不使用 - repeated google.protobuf.Any param = 3; + repeated google.protobuf.Any param = 3; // 请求的可变参数. 暂不使用 } service CollectPacketsServer { diff --git a/BasicTrafficFlow.proto b/BasicTrafficFlow.proto deleted file mode 100644 index 76ec193..0000000 --- a/BasicTrafficFlow.proto +++ /dev/null @@ -1,27 +0,0 @@ -syntax = "proto3"; - -option java_multiple_files = false; -option java_package = "com.yuandian.dataflow.proto.msgtype"; -option go_package = "../grpc-gen;grpcgen"; - - -package dataflow; - -message BasicTrafficFlow { - int32 table_id = 1; - int32 cap_port = 2; - int32 request_port = 3; - int32 response_port = 4; - int32 request_ip = 5; - int32 response_ip = 6; - int32 start_time = 7; - int32 total_bytes = 8; - int32 total_packets = 9; - int32 spackets64 = 10; - int32 spackets128 = 11; - int32 spackets256 = 12; - int32 spackets512 = 13; - int32 spackets1024 = 14; - int32 spackets = 15; - int32 send_time = 16; -} \ No newline at end of file diff --git a/BusinessBodyData.proto b/BusinessBodyData.proto deleted file mode 100644 index 075bff4..0000000 --- a/BusinessBodyData.proto +++ /dev/null @@ -1,34 +0,0 @@ -syntax = "proto3"; - -option java_multiple_files = false; -option java_package = "com.yuandian.dataflow.proto.msgtype"; -option go_package = "../grpc-gen;grpcgen"; - - -package dataflow; - -message BusinessBodyData { - int32 table_id = 1; - - string relvance_data_id = 2; - int64 request_ip = 3; - int32 request_port = 4; - int64 response_ip = 5; - int32 response_port = 6; - - int64 start_tv_sec = 7;//开始时间秒 - int64 start_tv_usec = 8;//开始时间毫秒 - int64 end_tv_sec = 9;//结束时间秒 - int64 end_tv_usec = 10;//结束时间微妙 - - string resource_code = 11; - string no_parameter_recognition = 12; - string original_recognition = 13; - string request_cookie = 14; - - string request_body_context = 15; - string response_body_context = 16; - - int32 filter_id = 17; - string business_detail_mesg = 18; -} \ No newline at end of file diff --git a/BussFlowDb.proto b/BussFlowDb.proto index b090f36..3c15c9c 100644 --- a/BussFlowDb.proto +++ b/BussFlowDb.proto @@ -10,68 +10,55 @@ package dataflow; message BussFlowDb { - int32 table_id = 1; - - // redis资源归并,处理服务资源发现是需要设置识别串(正则表达式) - string redisRegex = 2; + int32 table_id = 1; //编号24 +uint32 msg_type = 2; +string msg_version = 3; +uint32 msg_seq = 4; +uint32 msg_len = 5; +uint64 src_mac = 6; +uint64 dst_mac = 7; +uint32 vlan_id = 8; +uint32 tos = 9; +uint32 retran_count = 10; +uint32 reset_count = 11; +uint32 zerowin_count = 12; +uint32 protocol = 13; +uint32 response_bytes = 14; +uint32 request_bytes = 15; +uint32 response_packets = 16; +uint32 request_packets = 17; +string seq_ack = 18; +uint32 recog_status = 19; +uint32 probe_if = 20; +string channel = 21; +string dbname = 22; +uint32 request_ip = 23; +uint32 request_port = 24; +uint32 response_ip = 25; +uint32 response_port = 26; +int64 status = 27; +int64 server_translate_time = 28; +int64 client_translate_time = 29; +int64 server_response_time = 30; +uint32 server_response_start_time_tv_sec = 31; +uint32 server_response_start_time_tv_usec = 32; +uint32 server_response_end_time_tv_sec = 33; +uint32 server_response_end_time_tv_usec = 34; +uint32 start_time_tv_sec = 35; +uint32 start_time_tv_usec = 36; +uint32 end_time_tv_sec = 37; +uint32 end_time_tv_usec = 38; +int32 is_uncomplete = 39; +uint32 time_flag = 40; +uint32 sql_len = 41; +uint32 detail_msg_len = 42; +uint32 req_len = 43; +uint32 res_len = 44; +uint32 reserved_len = 45; +string sql = 46; +string bussiness_detail_mesg = 47; +string req_data = 48; +string res_data = 49; +string reserved = 50; - string id = 3; //id - int64 msg_len = 4; //消息长度 - int32 msg_type = 5; //消息类型 - int64 src_mac = 6; - int64 dst_mac = 7; - int32 protocol = 8; //协议名 - string session_serial_number = 9;//会话序列号 - string buss_type = 10;//业务服务资源编码（C_01） - int64 request_ip = 11;//Web客户端IP - int32 request_port = 12;//Web客户端端口 - int64 response_ip = 13;//Web服务器IP - int32 response_port = 14;//Web服务器端口 - int64 start_tv_sec = 15;//Web开始时间秒 - int64 start_tv_usec = 16;//开始时间毫秒 - int64 end_tv_sec = 17;//结束时间秒 - int64 end_tv_usec = 18;//结束时间微妙 - string disc_resource_ident = 19; //web：url mid:apiBody db：sql - string name = 20; //web:操作系统 midd：interfaceName db:db_name - //web midd - string session_id = 21;//sessionid - int32 request_msg_length = 22; //请求报文长度 - string request_msg_detail = 23; //请求报文详情 - int32 response_msg_length = 24; //响应报文长度 - string response_msg_detail = 25; //响应报文详情 - //web段 - string reter_url = 26; - string x_requested_with = 27; - int64 req_method = 28; //请求方式 - string content_type = 29; //请求类型 - string accept = 30; //jieshou - int32 req_cookie_leng = 31;//请求cookie报文长度 - string req_cookie_detail = 32;//请求cookie报文详情 - int64 t_intodb_time = 33; - int32 load_or_step = 34; //0: 页面 1：加载项 2：非web段数据 - string business_detail_mesg = 35; - string bussiness_key_mesg = 36; //关键字 格式：key=val|key=val.... - int32 isUncomplete = 37; //组包是否完全 0：组包完整 1：不完整 - int32 deal_state = 38; // 默认值为1 - int32 server_res_code = 39; - int64 server_response_time = 40; - int64 client_translate_time = 41; - string browser = 42; - int64 server_start_tv_sec = 43; - int64 server_start_tv_usec = 44; - int64 server_end_tv_sec = 45; - int64 server_end_tv_usec = 46; - string probe_ip = 47; - int64 probe_if = 48; - int64 server_translate_time = 49; - int64 time_flag = 50; - string base_code = 51; - string ori_sql = 52; - string reserved = 53; - int64 bytes_in = 54; - int64 bytes_out = 55; - int32 package_in = 56; - int32 package_out = 57; - string data_id = 58; - int32 filter_id = 59; } \ No newline at end of file diff --git a/BussFlowExternal.proto b/BussFlowExternal.proto index d4135c3..838f648 100644 --- a/BussFlowExternal.proto +++ b/BussFlowExternal.proto @@ -8,36 +8,35 @@ option go_package = "../grpc-gen;grpcgen"; package dataflow; message BussFlowExternal { - int32 table_id = 1; - string id = 2; - int64 probe_if = 3;//接口号 - string channel = 4;//营业厅渠道：前台或者分析服务器给出,渠道标识 - string system_name = 5; //外部系统名称 - string interface_id = 6;// 业务接口编码 - string session_id = 7;//sessionid - string phone_id = 8;//受理手机号码 - string net_type = 9; - string net_segment = 10;//网段标识(客户-web) - int64 request_ip = 11;//Web客户端IP - int64 request_port = 12;//Web客户端端口 - int64 response_ip = 13;//Web服务器IP - int64 response_port = 14;//Web服务器端口 - - int64 start_tv_sec = 15;//Web开始时间秒 - int64 start_tv_usec = 16;//开始时间微秒 - int64 end_tv_sec = 17;//结束时间秒 - int64 end_tv_usec = 18;//结束时间微妙 - - int32 deal_state = 19;//Web操作成功/失败标识1成功0失败 - int64 server_translate_time = 20;//Web服务器传输耗时 - int64 server_response_time = 21;//Web服务器响应时间 - string begin_url = 22;//url - string operating_sytem = 23;//操作系统 - int32 server_res_code = 24; //Web系统返回码 - string browser = 25;//浏览器 - string business_detail_mesg = 26;//要获取的指标 - int64 insert_time = 27;//插入时间? 没有被使用 - string business_involve_msg = 28; //要关联的指标 - int32 is_uncomplete = 29; - int64 time_flag = 30; + int32 table_id = 1; //编号25 + uint32 msg_type = 2; + uint32 msg_version = 3; + uint32 msg_seq = 4; + uint32 msg_len = 5; + uint64 src_mac = 6; + uint64 dst_mac = 7; + uint32 request_ip = 8; + uint32 request_port = 9; + uint32 response_ip = 10; + uint32 response_port = 11; + uint32 probeif = 12; + uint32 protocol = 13; + uint32 start_time_tv_sec = 14; + uint32 start_time_tv_usec = 15; + uint32 end_time_tv_sec = 16; + uint32 end_time_tv_usec = 17; + uint32 req_len = 18; + uint32 res_len = 19; + uint32 busi_msg_len = 20; + uint32 key_msg_len = 21; + uint32 detail_msg_len = 22; + uint32 remain_len = 23; + string busi_code = 24; + string sessionid = 25; + string req_data = 26; + string res_data = 27; + string busi_msg = 28; + string busi_key_msg = 29; + string busi_detail_msg = 30; + string remain_data = 31; } \ No newline at end of file diff --git a/BussFlowMidd.proto b/BussFlowMidd.proto index a7b3bd6..72ed464 100644 --- a/BussFlowMidd.proto +++ b/BussFlowMidd.proto @@ -8,66 +8,57 @@ option go_package = "../grpc-gen;grpcgen"; package dataflow; message BussFlowMidd { - int32 table_id = 1; - string id = 2; //id - int64 src_mac = 3; - int64 dst_mac = 4; - int32 msg_len = 5; //消息长度 - int32 msg_type = 6; //消息类型 - int32 protocol = 7; //协议名 - string session_serial_number = 8;//会话序列号 - string buss_type = 9;//业务服务资源编码（C_01） - string net_segment = 10;//网段标识(客户-web) - int64 request_ip = 11;//Web客户端IP - int32 request_port = 12;//Web客户端端口 - int64 response_ip = 13;//Web服务器IP - int32 response_port = 14;//Web服务器端口 - int64 start_tv_sec = 15;//Web开始时间秒 - int64 start_tv_usec = 16;//开始时间毫秒 - int64 end_tv_sec = 17;//结束时间秒 - int64 end_tv_usec = 18;//结束时间微妙 - string disc_resource_ident = 19; //web：url mid:apiBody db：sql - string name = 20; //web:操作系统 midd：interfaceName db:db_name - //web midd - string session_id = 21;//sessionid - int32 request_msg_length = 22; //请求报文长度 - string request_msg_detail = 23; //请求报文详情 - int32 response_msg_length = 24; //响应报文长度 - string response_msg_detail = 25; //响应报文详情 - //web段 - string reter_url = 26; - string x_requested_with = 27; - int64 req_method = 28; //请求方式 - string content_type = 29; //请求类型 - string accept = 30; //jieshou - int32 req_cookie_leng = 31;//请求cookie报文长度 - string req_cookie_detail = 32;//请求cookie报文详情 - int64 t_intodb_time = 33; - int32 load_or_step = 34; //0: 页面 1：加载项 2：非web段数据 - string business_detail_mesg = 35; - string bussiness_key_mesg = 36; //关键字 格式：key=val|key=val.... - int32 is_uncomplete = 37; //组包是否完全 0：组包完整 1：不完整 - int32 deal_state = 38; // 默认值1 - int32 server_res_code = 39; - int64 server_response_time = 40; - int64 client_translate_time = 41; - string browser = 42; - int32 server_start_tv_sec = 43; - int64 server_start_tv_usec = 44; - int32 server_end_tv_sec = 45; - int64 server_end_tv_usec = 46; - string probe_ip = 47; - int32 probe_if = 48; - int64 server_translate_time = 49; - int64 time_flag = 50; - string channel = 51; - string base_code = 52; - string ori_api = 53; - string remain_data = 54; - int64 bytes_in = 55; - int64 bytes_out = 56; - int32 package_in = 57; - int32 package_out = 58; - string data_id = 59; - int32 filter_id = 60; + int32 table_id = 1; //编号23 + uint32 msg_type = 2; + string msg_version = 3; + uint32 msg_seq = 4; + uint32 msg_len = 5; + uint64 src_mac = 6; + uint64 dst_mac = 7; + uint32 vlan_id = 8; + uint32 tos = 9; + uint32 retran_count = 10; + uint32 reset_count = 11; + uint32 zerowin_count = 12; + uint32 protocol = 13; + uint32 response_bytes = 14; + uint32 request_bytes = 15; + uint32 response_packets = 16; + uint32 request_packets = 17; + string seq_ack = 18; + uint32 recog_status = 19; + uint32 probe_if = 20; + string channel = 21; + uint32 request_ip = 22; + uint32 request_port = 23; + uint32 response_ip = 24; + uint32 response_port = 25; + uint32 start_time_tv_sec = 26; + uint32 start_time_tv_usec = 27; + uint32 end_time_tv_sec = 28; + uint32 end_time_tv_usec = 29; + uint32 deal_state = 30; + uint32 server_res_code = 31; + int64 server_translate_time = 32; + uint32 server_response_start_time_tv_sec = 33; + uint32 server_response_start_time_tv_usec = 34; + uint32 server_response_end_time_tv_sec = 35; + uint32 server_response_end_time_tv_usec = 36; + int64 server_response_time = 37; + int64 client_translate_time = 38; + int32 is_uncomplete = 39; + uint32 time_flag = 40; + uint32 detail_msg_len = 41; + uint32 key_msg_len = 42; + uint32 api_len = 43; + uint32 req_len = 44; + uint32 res_len = 45; + uint32 remain_len = 46; + string bussiness_detail_mesg = 47; + string bussiness_key_mesg = 48; + string api = 49; + string req_data = 50; + string res_data = 51; + string remain_data = 52; + } \ No newline at end of file diff --git a/BussFlowOrl.proto b/BussFlowOrl.proto deleted file mode 100644 index 8135a91..0000000 --- a/BussFlowOrl.proto +++ /dev/null @@ -1,42 +0,0 @@ -syntax = "proto3"; - -option java_multiple_files = false; -option java_package = "com.yuandian.dataflow.proto.msgtype"; -option go_package = "../grpc-gen;grpcgen"; - - -package dataflow; - -message BussFlowOrl { - int32 table_id = 1; - int32 msg_type = 2; - int32 msg_version = 3; - int32 msg_seq = 4; - int32 msg_len = 5; - int64 request_mac = 6; - int64 response_mac = 7; - int64 request_ip = 8; - int32 request_port = 9; - int64 response_ip = 10; - int32 response_port = 11; - int32 probe_if = 12; - int32 protocol = 13; - int64 start_tv_sec = 14;//Web开始时间秒 - int64 start_tv_usec = 15;//开始时间毫秒 - int64 end_tv_sec = 16;//结束时间秒 - int64 end_tv_usec = 17;//结束时间微妙 - int32 req_len = 18; - int32 res_len = 19; - int32 busi_msg_len = 20; - int32 key_msg_len = 21; - int32 detail_msg_len = 22; - int32 remain_len = 23; - string business_code = 24; - string session_id = 25; - string req_data = 26; - string res_data = 27; - string busi_msg = 28; - string busi_key_msg = 29; - string busi_detail_msg = 30; - string remain_data = 31; -} \ No newline at end of file diff --git a/BussFlowWeb.proto b/BussFlowWeb.proto index dae1bc1..4035110 100644 --- a/BussFlowWeb.proto +++ b/BussFlowWeb.proto @@ -8,75 +8,70 @@ option go_package = "../grpc-gen;grpcgen"; package dataflow; message BussFlowWeb { - int32 table_id = 1; - string id = 2; //id - int32 msg_len = 3; //消息长度 - int32 msg_type = 4; //消息类型 - int64 src_mac = 5; - int64 dst_mac = 6; - int32 protocol = 7; //协议名 - string session_serial_number = 8;//会话序列号 - string buss_type = 9;//业务服务资源编码（C_01） -// string net_segment = 10;//网段标识(客户-web) - int64 request_ip = 11;//Web客户端IP - int32 request_port = 12;//Web客户端端口 - int64 response_ip = 13;//Web服务器IP - int32 response_port = 14;//Web服务器端口 - int64 start_tv_sec = 15;//Web开始时间秒 - int64 start_tv_usec = 16;//开始时间毫秒 - int64 end_tv_sec = 17;//结束时间秒 - int64 end_tv_usec = 18;//结束时间微妙 - string disc_resource_ident = 19; //web：url mid:apiBody db：sql - string operating_system = 20; //web:操作系统 midd：interfaceName db:db_name - //web midd - string session_id = 21;//sessionid - int32 request_msg_length = 22; //请求报文长度 - string request_msg_detail = 23; //请求报文详情 - int32 response_msg_length = 24; //响应报文长度 - string response_msg_detail = 25; //响应报文详情 - //web段 - string reter_url = 26; - string x_requested_with = 27; - int64 req_method = 28; //请求方式 - string content_type = 29; //请求类型 - string accept = 30; //jieshou - int32 req_cookie_leng = 31;//请求cookie报文长度 - string req_cookie_detail = 32;//请求cookie报文详情 - int64 t_intodb_time = 33; - int32 load_or_step = 34; //0: 页面 1：加载项 2：非web段数据 - string business_detail_mesg = 35; - string bussiness_key_mesg = 36; //关键字 格式：key=val|key=val.... - int32 is_uncomplete = 37; //组包是否完全 0：组包完整 1：不完整 - int32 deal_state = 38; // 默认为1 - int32 server_res_code = 39; - int64 server_response_time = 40; - int64 client_translate_time = 41; - string browser = 42; - int32 server_start_tv_sec = 43; - int64 server_start_tv_usec = 44; - int32 server_end_tv_sec = 45; - int64 server_end_tv_usec = 46; - string probe_ip = 47; - int32 probe_if = 48; - int64 server_translate_time = 49; - int64 time_flag = 50; - string channel = 51; - string base_code = 52; - string ori_url = 53; - string remain_data = 54; - int64 bytes_in = 55; - int64 bytes_out = 56; - int32 package_in = 57; - int32 package_out = 58; + int32 table_id = 1; //编号22 + uint32 msg_type = 2; + string msg_version = 3; + uint32 msg_seq = 4; + uint32 msg_len = 5; + uint64 src_mac = 6; + uint64 dst_mac = 7; + uint32 vlan_id = 8; + uint32 tos = 9; + uint32 retran_count = 10; + uint32 reset_count = 11; + uint32 zerowin_count = 12; + uint32 protocol = 13; + uint32 response_bytes = 14; + uint32 request_bytes = 15; + uint32 response_packets = 16; + uint32 request_packets = 17; + string seq_ack = 18; + uint32 recog_status = 19; + uint32 req_method = 20; + string content_type = 21; + string accept = 22; + uint32 probe_if = 23; + string channel = 24; + string sessionid = 25; + uint32 request_ip = 26; + uint32 request_port = 27; + uint32 response_ip = 28; + uint32 response_port = 29; + uint32 start_time_tv_sec = 30; + uint32 start_time_tv_usec = 31; + uint32 end_time_tv_sec = 32; + uint32 end_time_tv_usec = 33; + int64 server_translate_time = 34; + uint32 server_response_start_time_tv_sec = 35; + uint32 server_response_start_time_tv_usec = 36; + uint32 server_response_end_time_tv_sec = 37; + uint32 server_response_end_time_tv_usec = 38; + int64 server_response_time = 39; + int64 client_translate_time = 40; + int64 locate_server_translate_time = 41; + int64 locate_server_response_time = 42; + int64 locate_client_translate_time = 43; + string x_requested_with = 44; + string operating_sytem = 45; + uint32 server_res_code = 46; + string browser = 47; + int32 is_uncomplete = 48; + uint32 time_flag = 49; + uint32 detail_msg_len = 50; + uint32 key_msg_len = 51; + uint32 req_len = 52; + uint32 res_len = 53; + uint32 cookie_len = 54; + uint32 begin_url_len = 55; + uint32 refer_url_len = 56; + uint32 remain_len = 57; + string bussiness_detail_mesg = 58; + string bussiness_key_mesg = 59; + string req_data = 60; + string res_data = 61; + string cookie_data = 62; + string begin_url = 63; + string refer_url = 64; + string remain_data = 65; - string data_id = 59; - - int32 filter_id = 60; - - string white_character = 61; - - // tokenId - string token_id = 62; - // 判断是否是首端资源( 2 ) - int32 segment_id = 63; } \ No newline at end of file diff --git a/DataFlow.proto b/DataFlow.proto deleted file mode 100644 index ce8677b..0000000 --- a/DataFlow.proto +++ /dev/null @@ -1,62 +0,0 @@ -syntax = "proto3"; - -option java_multiple_files = false; -option java_package = "com.yuandian.dataflow.proto.msgtype"; -option go_package = "../grpc-gen;grpcgen"; - - -package dataflow; - - -message DataFlow { - int32 table_id = 1; - - string id = 2; - - int32 msg_type = 3; //消息类型 - int32 msg_version = 4; //消息版本 - int32 msg_seq = 5; //序列号 - int32 msg_len = 6; //消息长度 - int32 probe_if = 7; //接口号 - int64 timestamp = 8; //时间戳 - int64 mac_src = 9; //源物理地址 - int64 mac_dst = 10; //目的物理地址 - int32 vlan_id = 11; //vlan_id - int64 l3_proto = 12; //l3层协议 - int64 l4_proto = 13; //l4层协议 - int32 tos = 14; //tos - int32 retran_count = 15; //重传次数 - int32 reset_count = 16; //重置次数 - int32 zerowin_count = 17; //零窗口次数 - int32 protocol = 18; //协议名 - int64 seq = 19; - int64 ack = 20; - int32 recog_status = 21; //识别类型标识 - int64 bytes = 22; //总字节 - int64 packets = 23; //总包数 - int32 start_tv_sec = 24;//Web开始时间秒 - int64 start_tv_usec = 25;//开始时间毫秒 - int32 end_tv_sec = 26;//结束时间秒 - int64 end_tv_usec = 27;//结束时间微妙 - int32 server_start_tv_sec = 28;//服务器响应开始时间秒 - int64 server_start_tv_usec = 29;//服务器响应开始时间毫秒 - int32 server_end_tv_sec = 30;//服务器响应结束时间秒 - int64 server_end_tv_usec = 31;//服务器响应结束时间微妙 - - int64 server_response_time = 32;//Web服务器响应时间 - int64 client_translate_time = 33;//Web客户端传输耗时 - int64 server_translate_time = 34;//Web服务器传输耗时 - - int64 bytes_in = 35; - int64 bytes_out = 36; - int64 packets_in = 37; - int64 packets_out = 38; - int64 ip_src = 39; //源IP - int64 ip_dst = 40; //目的IP - int64 port_src = 41; //源端口 - int64 port_dst = 42; //目的端口 - int64 probeIP = 43; //探针IP - - int64 intodb_time = 44; - int64 count = 45; // 默认为1 -} \ No newline at end of file diff --git a/QoeFlow.proto b/QoeFlow.proto index eb82a59..3274363 100644 --- a/QoeFlow.proto +++ b/QoeFlow.proto @@ -8,44 +8,44 @@ option go_package = "../grpc-gen;grpcgen"; package dataflow; message QoeFlow { - int32 table_id = 1; - // 字段类型 字段 原始类型 字节数 说明 - int32 src_ip = 2; //uint32_t 4 源ip地址 - int32 dst_ip = 3; //uint32_t 4 目的ip地址 - int32 stv_sec = 4; //uint32_t 4 开始时间秒 - int32 stv_usec = 5; //uint32_t 4 开始时间微秒 - int32 ltv_sec = 6; //uint32_t 4 最后更新时间秒 - int32 ltv_usec = 7; //uint32_t 4 最后更新时间微秒 - int32 dst2_respon_num = 8; //uint32_t 4 响应总量 - int32 dst2_fast = 9; //uint32_t 4 - int32 dst2_fast_expected = 10; //uint32_t 4 - int32 dst2_expected_degrated = 11; //uint32_t 4 - int32 dst2_degrated_service = 12; //uint32_t 4 - int32 dst2_service_availability = 13; //uint32_t 4 - int32 dst2_respon_timeout = 14; //uint32_t 4 响应超时数 - int32 dst2_respon_success = 15; //uint32_t 4 响应成功数 - int32 dst2_respon_fail = 16; //uint32_t 4 响应失败数 - int32 dst2_respon_peek = 17; //uint32_t 4 峰值响应时间 - int32 dst2_respon_average = 18; //uint32_t 4 响应时间均值 - int32 cs_window = 19; //uint32_t 4 - int32 sc_window = 20; //uint32_t 4 - int32 cs_reset = 21; //uint32_t 4 - int32 sc_reset = 22; //uint32_t 4 - int32 cs_retran = 23; //uint32_t 4 - int32 sc_retran = 24; //uint32_t 4 - int32 app_id = 25; //uint32_t 4 Aphid - int32 app_group_id = 26; //uint32_t 4 app组id - int32 probe_if = 27; //uint32_t 4 探针接口id - int32 app_style = 28; //uint32_t 4 - int32 time_flag = 29; //uint32_t 4 发送时间戳 - int32 conn_setup_tm = 30; //uint32_t 4 链接建立时间 - int32 data_transfer_tm = 31; //uint32_t 4 数据传输时间 - int32 retrans_delay_tm = 32; //uint32_t 4 数据重传时延 - int32 network_inbound = 33; //uint32_t 4 网络响应时间（c->s） - int32 network_outbound = 34; //uint32_t 4 网络响应时间（s->c） - int32 new_session = 35; //uint32_t 4 新会话数 - int32 user_events = 36; //uint32_t 4 用户事件 - int32 server_events = 37; //uint32_t 4 服务事件 - int32 conn_setup_peek = 38; //uint32_t 4 连接建立时间峰值 - int32 vlan_id = 39; //uint32_t 4 + int32 table_id = 1; //编号18 + uint32 src_ip = 2; + uint32 dst_ip = 3; + uint32 s_tv_sec = 4; + uint32 s_tv_usec = 5; + uint32 l_tv_sec = 6; + uint32 l_tv_usec = 7; + uint32 dst2_respon_num = 8; + uint32 dst2_fast = 9; + uint32 dst2_fast_expected = 10; + uint32 dst2_expected_degrated = 11; + uint32 dst2_degrated_service = 12; + uint32 dst2_service_availability = 13; + uint32 dst2_respon_timeout = 14; + uint32 dst2_respon_success = 15; + uint32 dst2_respon_fail = 16; + uint32 dst2_respin_peek = 17; + uint32 dst2_respon_average = 18; + uint32 cs_window = 19; + uint32 sc_window = 20; + uint32 cs_reset = 21; + uint32 sc_reset = 22; + uint32 cs_retran = 23; + uint32 sc_retran = 24; + uint32 app_id = 25; + uint32 app_group_id = 26; + uint32 probe_if = 27; + uint32 app_style = 28; + uint32 time_flag = 29; + uint32 conn_setup_tm = 30; + uint32 data_transfer_tm = 31; + uint32 retrans_delay_tm = 32; + uint32 network_inbound = 33; + uint32 network_outbound = 34; + uint32 new_session = 35; + uint32 user_events = 36; + uint32 server_events = 37; + uint32 conn_setup_peek = 38; + int32 vlan_id = 39; + } \ No newline at end of file diff --git a/SstFlow.proto b/SstFlow.proto deleted file mode 100644 index 0b9410f..0000000 --- a/SstFlow.proto +++ /dev/null @@ -1,51 +0,0 @@ -syntax = "proto3"; - -option java_multiple_files = false; -option java_package = "com.yuandian.dataflow.proto.msgtype"; -option go_package = "../grpc-gen;grpcgen"; - - -package dataflow; - -message SstFlow { - int32 table_id = 1; - - int64 mac_src = 2; //源MAC - int64 mac_dst = 3; //目标MAC - int64 ip_src = 4; //源IP - int64 ip_dst = 5; //目标IP - int32 port_src = 6; //源端口，如果没有，为-1 - int32 port_dst = 7; //目标端口，如果没有，为-1 - int32 l3_proto = 8; //第三层协议ID，如果没有，为-1 - int32 l4_proto = 9; //第四层协议ID，如果没有，为-1 - int32 tos = 10; //Tos，一个字节，如果没有，为-1 - int32 vlan_id = 11; //vlan ID，如果没有，为-1 - - int64 bytes = 12; //字节总数 - int64 packets = 13; //数据包总数 - - int64 packets_syn = 14; //TCP同步包数 - int64 packets_syn_ack = 15; //TCP同步确认包数 - int64 packets_syn_rst = 16; //TCP同步重置包数 - - int64 timestamp = 17; //时间戳,秒 - - int64 appid = 18;//应用ID - int64 app_group_id = 19; - int32 mpls_label = 20; - - int64 pkts_syn_rx = 21; //tcp同步包，接收 - int64 pkts_syn_ack_rx = 22;//tcp同步确认包，接收 - int64 pkts_syn_rst_rx = 23; //tcp同步重置包，接收 - int64 pkts_fin = 24;//tcp终止包，接收 - int64 pkts_rst = 25;//tcp重置包，接收 - - int64 bytes_rx = 26;//字节收 - int64 packets_rx = 27;//数据包收 - - int64 probe_time_sec = 28; - int64 probe_time = 29; - int64 create_time = 30; - - int32 probe_if = 31; -} \ No newline at end of file diff --git a/UsrFlow.proto b/UsrFlow.proto new file mode 100644 index 0000000..49995d2 --- /dev/null +++ b/UsrFlow.proto @@ -0,0 +1,43 @@ +syntax = "proto3"; + +option java_multiple_files = false; +option java_package = "com.yuandian.dataflow.proto.msgtype"; +option go_package = "../grpc-gen;grpcgen"; + + +package dataflow; + +message UsrFlow { + + int32 table_id = 1; //编号19 + uint32 probe_if = 2; + uint32 server_ip = 3; + uint32 client_ip = 4; + uint32 client_port = 5; + uint32 client_rtt = 6; + uint32 server_rtt = 7; + uint32 s_tv_sec = 8; + uint32 s_tv_usec = 9; + uint32 e_tv_sec = 10; + uint32 e_tv_usec = 11; + uint32 server_think = 12; + uint32 page_size = 13; + uint32 app_id = 14; + uint32 app_group_id = 15; + string request_url = 16; + string referer_url = 17; + uint32 return_code = 18; + uint32 err_tv_sec = 19; + uint32 err_tv_usec = 20; + uint32 client_loss_pkt = 21; + uint32 server_loss_pkt = 22; + uint32 client_bytes = 23; + uint32 server_bytes = 24; + uint32 client_packets = 25; + uint32 server_packets = 26; + string user_agent = 27; + string content_type = 28; + uint32 request_transfer_tm = 29; + uint32 time_flag = 30; + +} \ No newline at end of file