fix pod aggregation err and fix some bugs about autoscaling

metrics/core/caicloud/caicloud_keys.go

@@ -9,14 +9,6 @@ import (
 // anytime. It it only guaranteed that it is unique for the unique combination of
 // passed parameters.
 
-func PodContainerKey(namespaceName, appName, podName, containerName string) string {
-	return fmt.Sprintf("namespace:%s/app:%s/pod:%s/container:%s", namespaceName, appName, podName, containerName)
-}
-
-func PodKey(namespaceName, appName, podName string) string {
-	return fmt.Sprintf("namespace:%s/app:%s/pod:%s", namespaceName, appName, podName)
-}
-
 func AppKey(namespaceName, appName string) string {
 	return fmt.Sprintf("namespace:%s/app:%s", namespaceName, appName)
 }

metrics/processors/caicloud/pod_aggregator.go

@@ -21,10 +21,10 @@ func (p *PodAggregator) Process(batch *core.DataBatch) (*core.DataBatch, error)
 
 		if metricSetType, found := metricSet.Labels[core.LabelMetricSetType.Key]; found && metricSetType == core.MetricSetTypePodContainer {
 			podName, found := metricSet.Labels[core.LabelPodName.Key]
-			appName, found2 := metricSet.Labels[caicloudcore.LabelAppName.Key]
+			_, found2 := metricSet.Labels[caicloudcore.LabelAppName.Key]
 			namespaceName, found3 := metricSet.Labels[core.LabelNamespaceName.Key]
 			if found && found2 && found3 {
-				podKey := caicloudcore.PodKey(namespaceName, appName, podName)
+				podKey := core.PodKey(namespaceName, podName)
 				pod, found := pods[podKey]
 				if !found {
 					if podFromBatch, found := batch.MetricSets[podKey]; found {

metrics/processors/caicloud/processors.go

@@ -93,5 +93,12 @@ func GetProcessors(url *url.URL) ([]core.DataProcessor, error) {
 		},
 	)
 
+	nodeAutoscalingEnricher, err := kubeprocessors.NewNodeAutoscalingEnricher(url)
+	if err != nil {
+		glog.Fatalf("Failed to create NodeAutoscalingEnricher: %v", err)
+		return nil, err
+	}
+	dataProcessors = append(dataProcessors, nodeAutoscalingEnricher)
+
 	return dataProcessors, nil
 }