Fixed #TASK_QT-9810 建连时间bug解决。

containers/metrics.go

@@ -100,9 +100,9 @@ var metrics = struct {
 	NetAcceptsSuccessful:     metric("process_net_tcp_successful_accept_total", "Total number of successful TCP accepts", "destination", "actual_destination"),
 	NetAcceptBytesSent:       metric("process_net_tcp_bytes_sent_accept_total", "Total number of bytes sent to the peer", "destination", "actual_destination"),
 	NetAcceptBytesReceived:   metric("process_net_tcp_bytes_received_accept_total", "Total number of bytes received from the peer", "destination", "actual_destination"),
-	NetDataLatency:           metric("process_net_tcp_data_latency", "Data latency", "instance_id", "app_id", "target_app_id", "app_name", "src", "destination", "actual_destination"),
-	NetDataDuration:          metric("process_net_tcp_data_duration", "Data duration", "instance_id", "app_id", "target_app_id", "app_name", "src", "destination", "actual_destination"),
-	NetEstTime:               metric("process_net_tcp_est_time", "Established time", "instance_id", "app_id", "target_app_id", "app_name", "src", "destination", "actual_destination"),
+	NetDataLatency:           metric("process_net_tcp_data_latency_time", "Data latency", "instance_id", "app_id", "target_app_id", "app_name", "src", "destination", "actual_destination"),
+	NetDataDuration:          metric("process_net_tcp_flow_duration_time", "Data duration", "instance_id", "app_id", "target_app_id", "app_name", "src", "destination", "actual_destination"),
+	NetEstTime:               metric("process_net_tcp_connection_establish_time", "Established time", "instance_id", "app_id", "target_app_id", "app_name", "src", "destination", "actual_destination"),
 
 	LogMessages: metric("process_log_messages_total", "Number of messages grouped by the automatically extracted repeated pattern", "source", "level", "pattern_hash", "sample"),
 

main.go

@@ -273,7 +273,7 @@ func main() {
 				metric.GetName() != "process_net_tcp_bytes_sent_total" &&
 				metric.GetName() != "process_net_tcp_data_latency_time" &&
 				metric.GetName() != "process_net_tcp_flow_duration_time" &&
-				metric.GetName() != "process_net_tcp_connection_establish_time" {
+				metric.GetName() != "process_net_tcp_connection_establish_time"{
 				continue
 			}
 
@@ -324,9 +324,9 @@ func main() {
 		// 创建请求
 		urlRoute := "/api/v2/ebpf/receive"
 
-		log.Infoln("send url is ", *flags.DataServer+*flags.ServerPrefix+urlRoute)
+		log.Infoln("send url is ", *flags.DataServer + *flags.ServerPrefix  + urlRoute)
 		// req, err := http.NewRequest("POST", "http://10.0.7.115:18080/api/v2/ebpf/receive", bytes.NewBuffer(jsonData))
-		req, err := http.NewRequest("POST", *flags.DataServer+*flags.ServerPrefix+urlRoute, bytes.NewBuffer(jsonData))
+		req, err := http.NewRequest("POST", *flags.DataServer + *flags.ServerPrefix  + urlRoute, bytes.NewBuffer(jsonData))
 		if err != nil {
 			fmt.Println("Error:", err)
 			return
@@ -351,16 +351,16 @@ func main() {
 		}
 		defer response.Body.Close()
 
-		// 读取响应内容
-		responseData, err := io.ReadAll(response.Body)
-		if err != nil {
-			log.Infoln("Error:", err)
-			return
-		}
+		// 读取响应内容  
+		responseData, err := io.ReadAll(response.Body)  
+		if err != nil {  
+			log.Infoln("Error:", err)  
+			return  
+		}  
 
-		// 输出响应状态码和响应正文
-		log.Infoln("Status Code:", response.StatusCode)
-		log.Infoln("Response Body:", string(responseData))
+		// 输出响应状态码和响应正文  
+		log.Infoln("Status Code:", response.StatusCode)  
+		log.Infoln("Response Body:", string(responseData)) 
 	}
 	sendNetDataDone := make(chan struct{})
 	go func() {
@@ -421,9 +421,9 @@ func main() {
 				metric.GetName() != "process_net_tcp_bytes_sent_per" &&
 				metric.GetName() != "process_net_tcp_bytes_received_total" &&
 				metric.GetName() != "process_net_tcp_bytes_sent_total" &&
-				metric.GetName() != "process_net_tcp_data_latency" &&
-				metric.GetName() != "process_net_tcp_data_duration" &&
-				metric.GetName() != "process_net_tcp_est_time" {
+				metric.GetName() != "process_net_tcp_data_latency_time" &&
+				metric.GetName() != "process_net_tcp_flow_duration_time" &&
+				metric.GetName() != "process_net_tcp_connection_establish_time" {
 				continue
 			}