Commit dafb0fdf authored by Node- 门 忠鑫's avatar Node- 门 忠鑫

将kind和host存入tags

parent 9d5a412e
...@@ -52,9 +52,15 @@ func msgInfluxProcess(traceMsgs []TraceMsg) { ...@@ -52,9 +52,15 @@ func msgInfluxProcess(traceMsgs []TraceMsg) {
fields := make(map[string]interface{}) fields := make(map[string]interface{})
fields["duration"] = traceMsg.Duration / 1000 fields["duration"] = traceMsg.Duration / 1000
tags := make(map[string]string) fields["traceId"] = traceMsg.TraceId
tags := make(map[string]string,)
tags["sys_name"] = sysName tags["sys_name"] = sysName
tags["path"] = path tags["path"] = path
tags["host"] = traceMsg.LocalEndpoint.Ipv4
tags["kind"] = traceMsg.Kind
tags["duration_tag"] = strconv.Itoa(traceMsg.Duration)
bytes, err := json.Marshal(traceMsg) bytes, err := json.Marshal(traceMsg)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment