feat: add configkey in extension

traas-stack · May 13, 2024 · 0d441fc · 0d441fc
1 parent f49aa48
commit 0d441fc
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/pkg/plugin/output/gateway/gateway.go b/pkg/plugin/output/gateway/gateway.go
@@ -151,6 +151,9 @@ func convertToTaskResult2(configKey, targetKey, metricName string, array []*mode
 
 	a := make([]*pb.WriteMetricsRequestV4_TaskResult, 0, len(taskResultByValueName)+1)
 	for _, r := range taskResultByValueName {
+		r.Extension = map[string]string{
+			"configKey": configKey,
+		}
 		a = append(a, r)
 	}
 
@@ -166,6 +169,9 @@ func convertToTaskResult2(configKey, targetKey, metricName string, array []*mode
 			Completeness: &pb.WriteMetricsRequestV4_Completeness{
 				Ok: completeness.OK,
 			},
+			Extension: map[string]string{
+				"configKey": configKey,
+			},
 		}
 		a = append(a, r)
 	}