lib/protoparser/datadogv2: take into account source_type_name field, since it contains useful value such as kubernetes, docker, system, etc.

app/vmagent/datadogv2/request_handler.go

@@ -58,6 +58,12 @@ func insertRows(at *auth.Token, series []datadogv2.Series, extraLabels []prompbm
 				Value: rs.Name,
 			})
 		}
+		if ss.SourceTypeName != "" {
+			labels = append(labels, prompbmarshal.Label{
+				Name:  "source_type_name",
+				Value: ss.SourceTypeName,
+			})
+		}
 		for _, tag := range ss.Tags {
 			name, value := datadogutils.SplitTag(tag)
 			if name == "host" {

app/vminsert/datadogv2/request_handler.go

@@ -59,6 +59,9 @@ func insertRows(series []datadogv2.Series, extraLabels []prompbmarshal.Label) er
 			}
 			ctx.AddLabel(name, value)
 		}
+		if ss.SourceTypeName != "" {
+			ctx.AddLabel("source_type_name", ss.SourceTypeName)
+		}
 		for j := range extraLabels {
 			label := &extraLabels[j]
 			ctx.AddLabel(label.Name, label.Value)

lib/protoparser/datadogv2/parser.go

@@ -77,10 +77,9 @@ type Series struct {
 
 	// Points points for the given metric
 	Points []Point `json:"points"`
-	Resources []Resource `json:"resources"`
 
-	// Do not decode SourceTypeName, since it isn't used by VictoriaMetrics
+	Resources      []Resource `json:"resources"`
-	// SourceTypeName string     `json:"source_type_name"`
+	SourceTypeName string     `json:"source_type_name"`
 
 	Tags []string
 
@@ -106,6 +105,8 @@ func (s *Series) reset() {
 	}
 	s.Resources = resources[:0]
 
+	s.SourceTypeName = ""
+
 	tags := s.Tags
 	for i := range tags {
 		tags[i] = ""

lib/protoparser/datadogv2/parser_test.go

@@ -50,6 +50,7 @@ func TestRequestUnmarshalJSONSuccess(t *testing.T) {
           "type": "host"
         }
       ],
+      "source_type_name": "kubernetes",
       "tags": ["environment:test"]
     }
   ]
@@ -69,6 +70,7 @@ func TestRequestUnmarshalJSONSuccess(t *testing.T) {
 					Type: "host",
 				},
 			},
+			SourceTypeName: "kubernetes",
 			Tags: []string{
 				"environment:test",
 			},