diff --git a/pkg/plugin/output/gateway/gateway.go b/pkg/plugin/output/gateway/gateway.go index ffaa295..2263075 100644 --- 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) }