github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-25 20:53:33 +00:00
Code Issues Projects Releases Wiki Activity

test: cleanup test logs for deployments

Browse Source
This commit is contained in:
Michail Kargakis 2016-12-09 17:52:58 +01:00
parent 5b37bcc3f3
commit 0d95d71e65
1 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -3429,14 +3429,16 @@ func WaitForDeploymentOldRSsNum(c clientset.Interface, ns, deploymentName string
} }
func logReplicaSetsOfDeployment(deployment *extensions.Deployment, allOldRSs []*extensions.ReplicaSet, newRS *extensions.ReplicaSet) { func logReplicaSetsOfDeployment(deployment *extensions.Deployment, allOldRSs []*extensions.ReplicaSet, newRS *extensions.ReplicaSet) {
Logf("Deployment: %+v. Selector = %+v", *deployment, deployment.Spec.Selector)
for i := range allOldRSs {
Logf("All old ReplicaSets (%d/%d) of deployment %s: %+v. Selector = %+v", i+1, len(allOldRSs), deployment.Name, *allOldRSs[i], allOldRSs[i].Spec.Selector)
}
if newRS != nil { if newRS != nil {
Logf("New ReplicaSet of deployment %s: %+v. Selector = %+v", deployment.Name, *newRS, newRS.Spec.Selector) Logf("New ReplicaSet of Deployment %s:\n%+v", deployment.Name, *newRS)
} else { } else {
Logf("New ReplicaSet of deployment %s is nil.", deployment.Name) Logf("New ReplicaSet of Deployment %s is nil.", deployment.Name)
}
if len(allOldRSs) > 0 {
Logf("All old ReplicaSets of Deployment %s:", deployment.Name)
}
for i := range allOldRSs {
Logf("%+v", *allOldRSs[i])
} }
} }
@ -3470,17 +3472,15 @@ func logPodsOfDeployment(c clientset.Interface, deployment *extensions.Deploymen
return c.Core().Pods(namespace).List(options) return c.Core().Pods(namespace).List(options)
}) })
if err != nil { if err != nil {
Logf("Failed to list pods of deployment %s: %v", deployment.Name, err) Logf("Failed to list Pods of Deployment %s: %v", deployment.Name, err)
return return
} }
if err == nil { for _, pod := range podList.Items {
for _, pod := range podList.Items { availability := "not available"
availability := "not available" if deploymentutil.IsPodAvailable(&pod, minReadySeconds, time.Now()) {
if deploymentutil.IsPodAvailable(&pod, minReadySeconds, time.Now()) { availability = "available"
availability = "available"
}
Logf("Pod %s is %s: %+v", pod.Name, availability, pod)
} }
Logf("Pod %s is %s:\n%+v", pod.Name, availability, pod)
} }
} }