fix: add export thread id

Prevent data with the same Tag from being exported
deepflowio · Oct 12, 2024 · a06fd06 · a06fd06
1 parent fbc1231
commit a06fd06
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/server/libs/flow-metrics/tag.go b/server/libs/flow-metrics/tag.go
@@ -256,7 +256,7 @@ type Field struct {
 	// 用于区分不同的trident及其不同的pipeline，用于如下场景：
 	//   - agent和ingester之间的数据传输
 	//   - ingester写入clickhouse，作用类似_id，序列化为_tid
-	GlobalThreadID uint8
+	GlobalThreadID uint8 `json:"thread_id" category:"$tag"`
 
 	// structTag  "datasource":"n|nm|a|am" means datasource: network, network_map, application, application_map
 	IP6              net.IP `json:"ip6" map_json:"ip6_0" category:"$tag" sub:"network_layer" to_string:"IPv6String" ` // FIXME: 合并IP6和IP
@@ -1343,6 +1343,7 @@ func (t *Tag) String() string {
 
 func (t *Tag) ReadFromPB(p *pb.MiniTag) {
 	t.Code = Code(p.Code)
+	t.GlobalThreadID = uint8(p.Field.GlobalThreadId)
 	t.IsIPv4 = 1 - uint8(p.Field.IsIpv6)
 	if t.IsIPv4 == 0 {
 		if t.IP6 == nil {