github
/
k3s
mirror of https://github.com/k3s-io/k3s
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

refactor parsing cluster autoscaler status

pull/6/head
Aleksandra Malinowska 2017-09-22 10:45:22 +02:00
parent 04673ab614
commit 88da2c1c70
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
test/e2e/autoscaling/cluster_size_autoscaling.go
View File

@ -1365,12 +1365,12 @@ func getStatusTimestamp(status string) (time.Time, error) {
return time.Time{}, err return time.Time{}, err
} }
timestampMatches := timestampMatcher.FindAllStringSubmatch(status, -1) timestampMatch := timestampMatcher.FindStringSubmatch(status)
if len(timestampMatches) < 1 { if len(timestampMatch) < 2 {
return time.Time{}, fmt.Errorf("Failed to parse CA status timestamp, raw status: %v", status) return time.Time{}, fmt.Errorf("Failed to parse CA status timestamp, raw status: %v", status)
} }
timestamp, err := time.Parse(timestampFormat, timestampMatches[0][1]) timestamp, err := time.Parse(timestampFormat, timestampMatch[1])
if err != nil { if err != nil {
return time.Time{}, err return time.Time{}, err
} }

2
test/e2e/framework/util.go
View File

@ -2351,7 +2351,7 @@ func DumpNodeDebugInfo(c clientset.Interface, nodeNames []string, logFunc func(f
logFunc("\nLogging pods the kubelet thinks is on node %v", n) logFunc("\nLogging pods the kubelet thinks is on node %v", n)
podList, err := GetKubeletPods(c, n) podList, err := GetKubeletPods(c, n)
if err != nil { if err != nil {
logFunc("Unable to retrieve kubelet pods for node %v", n) logFunc("Unable to retrieve kubelet pods for node %v: %v", n, err)
continue continue
} }
for _, p := range podList.Items { for _, p := range podList.Items {