Added support for AWS EC2 instance monitored resources. (#46)

Depends on prometheus/prometheus#4514.

retrieval/resource_map.go

@@ -42,6 +42,21 @@ type ResourceMap struct {
 	LabelMap map[string]labelTranslation
 }
 
+var EC2ResourceMap = ResourceMap{
+	Type: "aws_ec2_instance",
+	LabelMap: map[string]labelTranslation{
+		ProjectIDLabel:           constValue("project_id"),
+		"__meta_ec2_instance_id": constValue("instance_id"),
+		"__meta_ec2_availability_zone": labelTranslation{
+			stackdriverLabelName: "region",
+			convert: func(s string) string {
+				return "aws:" + s
+			},
+		},
+		"__meta_ec2_owner_id": constValue("aws_account"),
+	},
+}
+
 var GCEResourceMap = ResourceMap{
 	Type: "gce_instance",
 	LabelMap: map[string]labelTranslation{
@@ -96,6 +111,7 @@ var ResourceMappings = []ResourceMap{
 			"__meta_kubernetes_node_name": constValue("node_name"),
 		},
 	},
+	EC2ResourceMap,
 	GCEResourceMap,
 }
 

retrieval/resource_map_test.go

@@ -53,6 +53,26 @@ func TestTranslate(t *testing.T) {
 	}
 }
 
+func TestTranslateEc2Instance(t *testing.T) {
+	target := labels.Labels{
+		{ProjectIDLabel, "my-project"},
+		{"__meta_ec2_availability_zone", "us-east-1b"},
+		{"__meta_ec2_instance_id", "i-040c37401c02cb03b"},
+		{"__meta_ec2_owner_id", "12345678"},
+	}
+	expectedLabels := map[string]string{
+		"project_id":  "my-project",
+		"instance_id": "i-040c37401c02cb03b",
+		"region":      "aws:us-east-1b",
+		"aws_account": "12345678",
+	}
+	if labels := EC2ResourceMap.Translate(target); labels == nil {
+		t.Errorf("Expected %v, actual nil", expectedLabels)
+	} else if !reflect.DeepEqual(labels, expectedLabels) {
+		t.Errorf("Expected %v, actual %v", expectedLabels, labels)
+	}
+}
+
 func TestTranslateGceInstance(t *testing.T) {
 	target := labels.Labels{
 		{"__meta_gce_project", "my-project"},