Преглед изворни кода

Fixed #TASK_QT-9810 优化事件处理-数据结构调整

Carl пре 1 година
родитељ
комит
72f372a616
1 измењених фајлова са 8 додато и 8 уклоњено
  1. 8 8
      pkg/go.opentelemetry.io/otel/exporters/otlp/otlptrace/apm_exporter.go

+ 8 - 8
pkg/go.opentelemetry.io/otel/exporters/otlp/otlptrace/apm_exporter.go

@@ -484,9 +484,9 @@ func buildMapNodeFromEvent(event tracesdk.Event) MapInfoT {
 		case "level":
 		case "level":
 			mNode.Level = int(attr.Value.AsInt64())
 			mNode.Level = int(attr.Value.AsInt64())
 		case "time.start_at":
 		case "time.start_at":
-			mNode.StartTime = uint64(attr.Value.AsInt64()) / 1e6
+			mNode.StartTime = uint64(attr.Value.AsInt64())
 		case "time.end_at":
 		case "time.end_at":
-			mNode.EndTime = uint64(attr.Value.AsInt64()) / 1e6
+			mNode.EndTime = uint64(attr.Value.AsInt64())
 		case "time.duration":
 		case "time.duration":
 			//mNode.PureTime = uint64(attr.Value.AsInt64()) / 1e3
 			//mNode.PureTime = uint64(attr.Value.AsInt64()) / 1e3
 			mNode.WallTime = uint64(attr.Value.AsInt64()) / 1e3
 			mNode.WallTime = uint64(attr.Value.AsInt64()) / 1e3
@@ -585,7 +585,7 @@ func buildAppMapFromEvent(traceRoot *RootDataT, sd apmTraceSpan) {
 		ExceptionMsg:   "",
 		ExceptionMsg:   "",
 		ExceptionStack: "",
 		ExceptionStack: "",
 		Ip:             "",
 		Ip:             "",
-		Level:          2,
+		Level:          1,
 		Pid:            1,
 		Pid:            1,
 		Port:           0,
 		Port:           0,
 		Ps:             []string{},
 		Ps:             []string{},
@@ -595,7 +595,7 @@ func buildAppMapFromEvent(traceRoot *RootDataT, sd apmTraceSpan) {
 	}
 	}
 	mNode.ServiceName = GO_SERVICE_NAME
 	mNode.ServiceName = GO_SERVICE_NAME
 	mNode.ServiceType = APP_SERVICE_TYPE
 	mNode.ServiceType = APP_SERVICE_TYPE
-	mNode.MethodName = "net/http.(*Transport).roundTrip()"
+	mNode.MethodName = "Kernel Endpoint()"
 	mNode.Level = 1
 	mNode.Level = 1
 	mNode.Pid = 0
 	mNode.Pid = 0
 	mNode.Nid = 1
 	mNode.Nid = 1
@@ -631,10 +631,10 @@ func buildAppMapFromEvent(traceRoot *RootDataT, sd apmTraceSpan) {
 		case "server.type_from":
 		case "server.type_from":
 			traceRoot.TypeFrom = attr.Value.AsString()
 			traceRoot.TypeFrom = attr.Value.AsString()
 		case "time.start_at":
 		case "time.start_at":
-			traceRoot.CollTime = uint64(attr.Value.AsInt64()) / 1e6
+			traceRoot.CollTime = uint64(attr.Value.AsInt64())
 			mNode.StartTime = traceRoot.CollTime
 			mNode.StartTime = traceRoot.CollTime
 		case "time.end_at":
 		case "time.end_at":
-			mNode.EndTime = uint64(attr.Value.AsInt64()) / 1e6
+			mNode.EndTime = uint64(attr.Value.AsInt64())
 		case "time.duration":
 		case "time.duration":
 			traceRoot.RespTime = uint64(attr.Value.AsInt64()) / 1e3
 			traceRoot.RespTime = uint64(attr.Value.AsInt64()) / 1e3
 			//mNode.PureTime = traceRoot.RespTime
 			//mNode.PureTime = traceRoot.RespTime
@@ -692,9 +692,9 @@ func buildHttpMapFromEvent(mNode *MapInfoT, event tracesdk.Event) {
 		case "http.span_id":
 		case "http.span_id":
 			mNode.SpanId = attr.Value.AsString()
 			mNode.SpanId = attr.Value.AsString()
 		case "time.start_at":
 		case "time.start_at":
-			mNode.StartTime = uint64(attr.Value.AsInt64()) / 1e6
+			mNode.StartTime = uint64(attr.Value.AsInt64())
 		case "time.end_at":
 		case "time.end_at":
-			mNode.EndTime = uint64(attr.Value.AsInt64()) / 1e6
+			mNode.EndTime = uint64(attr.Value.AsInt64())
 		case "time.duration":
 		case "time.duration":
 			//mNode.PureTime = uint64(attr.Value.AsInt64()) / 1e3
 			//mNode.PureTime = uint64(attr.Value.AsInt64()) / 1e3
 			mNode.WallTime = uint64(attr.Value.AsInt64()) / 1e3
 			mNode.WallTime = uint64(attr.Value.AsInt64()) / 1e3