Add support of generic_task metric type.

Fixes GoogleCloudPlatform#117

Author: yegle

exporter/metric/constants.go

@@ -52,11 +52,14 @@ const (
 	K8SKeyPodName        = "k8s.pod.name"
 	K8SKeyDeploymentName = "k8s.deployment.name"
 
+	TaskID = "task_id"
+
 	// Monitored Resources types
 	K8SContainer   = "k8s_container"
 	K8SNode        = "k8s_node"
 	K8SPod         = "k8s_pod"
 	K8SCluster     = "k8s_cluster"
 	GCEInstance    = "gce_instance"
 	AWSEC2Instance = "aws_ec2_instance"
+	GenericTask    = "generic_task"
 )

exporter/metric/metric.go

@@ -115,6 +115,15 @@ var awsResourceMap = map[string]string{
 	"aws_account": CloudKeyAccountID,
 }
 
+// For generic_task, assume there's no further transformation required. Still
+// provide a map here to check the existence of the required labels.
+var genericTaskMap = map[string]string{
+	"task_id":   "task_id",
+	"location":  "location",
+	"namespace": "namespace",
+	"job":       "job",
+}
+
 // newMetricExporter returns an exporter that uploads OTel metric data to Google Cloud Monitoring.
 func newMetricExporter(o *options) (*metricExporter, error) {
 	if strings.TrimSpace(o.ProjectID) == "" {
@@ -335,6 +344,7 @@ func subdivideGCPTypes(labelMap map[string]string) (string, map[string]string) {
 	_, hasNamespaceName := labelMap[K8SKeyNamespaceName]
 	_, hasPodName := labelMap[K8SKeyPodName]
 	_, hasContainerName := labelMap[ContainerKeyName]
+	_, hasTaskID := labelMap[TaskID]
 
 	if hasLocation && hasClusterName && hasNamespaceName && hasPodName && hasContainerName {
 		return K8SContainer, k8sContainerMap
@@ -354,6 +364,10 @@ func subdivideGCPTypes(labelMap map[string]string) (string, map[string]string) {
 		return K8SCluster, k8sClusterMap
 	}
 
+	if hasTaskID {
+		return GenericTask, genericTaskMap
+	}
+
 	return GCEInstance, gceResourceMap
 }