Add TargetV2 resource map (#273)

Author: googKamaljit

retrieval/resource_map.go

@@ -131,6 +131,22 @@ var ProxyV2ResourceMap = ResourceMap{
 	},
 }
 
+var TargetV2ResourceMap = ResourceMap{
+	Type:       "apigee.googleapis.com/TargetV2",
+	MatchLabel: "__meta_kubernetes_pod_label_type_target_v2",
+	LabelMap: map[string]labelTranslation{
+		ProjectIDLabel:          constValue("resource_container"),
+		KubernetesLocationLabel: constValue("location"),
+		"org":                   constValue("org"),
+		"env":                   constValue("env"),
+		"proxy_name":            constValue("proxy_name"),
+		"target_type":           constValue("target_type"),
+		"target_endpoint":       constValue("target_endpoint"),
+		"runtime_version":       constValue("runtime_version"),
+		"instance_id":           constValue("instance_id"),
+	},
+}
+
 var AnthosL4LBMap = ResourceMap{
 	Type:       "anthos_l4lb",
 	MatchLabel: "__meta_kubernetes_service_annotation_gke_googleapis_com_anthos_l4lb_type",
@@ -148,6 +164,7 @@ type ResourceMapList []ResourceMap
 // When you add new elements, you also probably want to update TestResourceMappingsOrder.
 var ResourceMappings = ResourceMapList{
 	AnthosL4LBMap,
+	TargetV2ResourceMap,
 	ProxyV2ResourceMap,
 	ProxyResourceMap,
 	DevappResourceMap,

retrieval/resource_map_test.go

@@ -205,6 +205,48 @@ func TestTranslateProxy(t *testing.T) {
 	}
 }
 
+func TestTranslateTargetV2(t *testing.T) {
+	discoveredLabels := labels.Labels{
+		{"__meta_kubernetes_pod_label_type_target_v2", "true"},
+		{ProjectIDLabel, "my-project"},
+		{KubernetesLocationLabel, "us-central1-a"},
+	}
+	metricLabels := labels.Labels{
+		{"proxy_name", "my-name"},
+		{"target_type", "my-target"},
+		{"target_endpoint", "my-endpoint"},
+		{"org", "my-org"},
+		{"env", "my-env"},
+		{"runtime_version", "my-revision"},
+		{"instance_id", "my-instance"},
+		{"extra_label", "my-label"},
+	}
+	expectedLabels := map[string]string{
+		"resource_container": "my-project",
+		"location":           "us-central1-a",
+		"org":                "my-org",
+		"env":                "my-env",
+		"proxy_name":         "my-name",
+		"target_type":        "my-target",
+		"target_endpoint":    "my-endpoint",
+		"runtime_version":    "my-revision",
+		"instance_id":        "my-instance",
+	}
+	expectedFinalLabels := labels.Labels{
+		{"extra_label", "my-label"},
+	}
+	if labels, finalLabels := TargetV2ResourceMap.Translate(discoveredLabels, metricLabels); labels == nil {
+		t.Errorf("Expected %v, actual nil", expectedLabels)
+	} else {
+		if diff := cmp.Diff(expectedLabels, labels); len(diff) > 0 {
+			t.Error(diff)
+		}
+		if diff := cmp.Diff(expectedFinalLabels, finalLabels); len(diff) > 0 {
+			t.Error(diff)
+		}
+	}
+}
+
 func TestTranslateProxyV2(t *testing.T) {
 	discoveredLabels := labels.Labels{
 		{"__meta_kubernetes_pod_label_type_proxy_v2", "true"},
@@ -315,6 +357,7 @@ func TestResourceMappingsOrder(t *testing.T) {
 		{"k8s_node", "gce_instance"},
 		{"k8s_node", "aws_ec2_instance"},
 		{"anthos_l4lb", "k8s_container"},
+		{"apigee.googleapis.com/TargetV2", "k8s_container"},
 		{"apigee.googleapis.com/ProxyV2", "k8s_container"},
 		{"apigee.googleapis.com/Proxy", "k8s_container"},
 		{"apigee.googleapis.com/Devapp", "k8s_container"},