Updating heapster version to v0.9.

Updated the e2e test to work with the new version.

cluster/addons/cluster-monitoring/heapster-controller.yaml

@@ -12,10 +12,21 @@ desiredState:
         id: monitoring-heapster
         containers:
           - name: heapster
-            image: kubernetes/heapster:v0.8
+            image: kubernetes/heapster:v0.9
             env: 
               - name: "INFLUXDB_HOST"
                 value: "monitoring-influxdb"
+              - name: "SINK"
+                value: "influxdb"
+            volumeMounts:
+              - name: ssl-certs
+                mountPath: /etc/ssl/certs
+                readOnly: true
+        volumes:
+          - name: ssl-certs
+            source:
+              hostDir:
+                path: /etc/ssl/certs
     labels: 
       name: heapster
       uses: monitoring-influxdb

cluster/addons/cluster-monitoring/influxdb-grafana-controller.yaml

@@ -22,7 +22,7 @@ desiredState:
               - containerPort: 8086
                 hostPort: 8086
           - name: grafana
-            image: kubernetes/heapster_grafana:v0.4
+            image: kubernetes/heapster_grafana:v0.5
             env: 
               - name: "HTTP_USER"
                 value: "admin"
@@ -31,9 +31,11 @@ desiredState:
               - name: "INFLUXDB_PROTO"
                 value: "https"
               - name: "INFLUXDB_HOST"
-                value: '"+window.location.hostname+"/api/v1beta1/proxy/services/monitoring-influxdb'
+                value: "localhost"
               - name: "INFLUXDB_PORT"
                 value: ""
+              - name: "KUBERNETES_API_PORT"
+                value: ""
 labels:
   name: influxGrafana
   kubernetes.io/cluster-service: "true"

test/e2e/monitoring.go

@@ -54,8 +54,8 @@ const (
 	influxdbDatabaseName = "k8s"
 	influxdbUser         = "root"
 	influxdbPW           = "root"
-	podlistQuery         = "select distinct(pod) from stats"
-	nodelistQuery        = "select distinct(hostname) from machine"
+	podlistQuery         = "select distinct(pod_id) from /cpu.*/"
+	nodelistQuery        = "select distinct(hostname) from /cpu.*/"
 	sleepBetweenAttempts = 5 * time.Second
 	testTimeout          = 5 * time.Minute
 )
@@ -89,7 +89,7 @@ func verifyExpectedRcsExistAndGetExpectedPods(c *client.Client) ([]string, error
 				return nil, err
 			}
 			for _, pod := range podList.Items {
-				expectedPods = append(expectedPods, pod.Name)
+				expectedPods = append(expectedPods, string(pod.UID))
 			}
 		}
 	}