@@ -20,8 +20,7 @@ import (
20
20
"fmt"
21
21
"time"
22
22
23
- . "github.com/onsi/ginkgo"
24
- . "github.com/onsi/gomega"
23
+ "github.com/onsi/ginkgo"
25
24
v1 "k8s.io/api/core/v1"
26
25
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
27
26
"k8s.io/apimachinery/pkg/fields"
@@ -39,19 +38,19 @@ func nodeNames(nodes []v1.Node) []string {
39
38
return result
40
39
}
41
40
42
- var _ = Describe ("Recreate [Feature:Recreate]" , func () {
41
+ var _ = ginkgo . Describe ("Recreate [Feature:Recreate]" , func () {
43
42
f := framework .NewDefaultFramework ("recreate" )
44
43
var originalNodes []v1.Node
45
44
var originalPodNames []string
46
45
var ps * testutils.PodStore
47
46
systemNamespace := metav1 .NamespaceSystem
48
- BeforeEach (func () {
47
+ ginkgo . BeforeEach (func () {
49
48
framework .SkipUnlessProviderIs ("gce" , "gke" )
50
49
var err error
51
50
numNodes , err := framework .NumberOfRegisteredNodes (f .ClientSet )
52
- Expect ( err ). NotTo ( HaveOccurred () )
51
+ framework . ExpectNoError ( err )
53
52
originalNodes , err = framework .CheckNodesReady (f .ClientSet , numNodes , framework .NodeReadyInitialTimeout )
54
- Expect ( err ). NotTo ( HaveOccurred () )
53
+ framework . ExpectNoError ( err )
55
54
56
55
framework .Logf ("Got the following nodes before recreate %v" , nodeNames (originalNodes ))
57
56
@@ -69,13 +68,13 @@ var _ = Describe("Recreate [Feature:Recreate]", func() {
69
68
70
69
})
71
70
72
- AfterEach (func () {
73
- if CurrentGinkgoTestDescription ().Failed {
71
+ ginkgo . AfterEach (func () {
72
+ if ginkgo . CurrentGinkgoTestDescription ().Failed {
74
73
// Make sure that addon/system pods are running, so dump
75
74
// events for the kube-system namespace on failures
76
- By (fmt .Sprintf ("Collecting events from namespace %q." , systemNamespace ))
75
+ ginkgo . By (fmt .Sprintf ("Collecting events from namespace %q." , systemNamespace ))
77
76
events , err := f .ClientSet .CoreV1 ().Events (systemNamespace ).List (metav1.ListOptions {})
78
- Expect ( err ). NotTo ( HaveOccurred () )
77
+ framework . ExpectNoError ( err )
79
78
80
79
for _ , e := range events .Items {
81
80
framework .Logf ("event for %v: %v %v: %v" , e .InvolvedObject .Name , e .Source , e .Reason , e .Message )
@@ -86,7 +85,7 @@ var _ = Describe("Recreate [Feature:Recreate]", func() {
86
85
}
87
86
})
88
87
89
- It ("recreate nodes and ensure they function upon restart" , func () {
88
+ ginkgo . It ("recreate nodes and ensure they function upon restart" , func () {
90
89
testRecreate (f .ClientSet , ps , systemNamespace , originalNodes , originalPodNames )
91
90
})
92
91
})
@@ -104,7 +103,7 @@ func testRecreate(c clientset.Interface, ps *testutils.PodStore, systemNamespace
104
103
}
105
104
106
105
nodesAfter , err := framework .CheckNodesReady (c , len (nodes ), framework .RestartNodeReadyAgainTimeout )
107
- Expect ( err ). NotTo ( HaveOccurred () )
106
+ framework . ExpectNoError ( err )
108
107
framework .Logf ("Got the following nodes after recreate: %v" , nodeNames (nodesAfter ))
109
108
110
109
if len (nodes ) != len (nodesAfter ) {
@@ -115,7 +114,7 @@ func testRecreate(c clientset.Interface, ps *testutils.PodStore, systemNamespace
115
114
// Make sure the pods from before node recreation are running/completed
116
115
podCheckStart := time .Now ()
117
116
podNamesAfter , err := framework .WaitForNRestartablePods (ps , len (podNames ), framework .RestartPodReadyAgainTimeout )
118
- Expect ( err ). NotTo ( HaveOccurred () )
117
+ framework . ExpectNoError ( err )
119
118
remaining := framework .RestartPodReadyAgainTimeout - time .Since (podCheckStart )
120
119
if ! framework .CheckPodsRunningReadyOrSucceeded (c , systemNamespace , podNamesAfter , remaining ) {
121
120
framework .Failf ("At least one pod wasn't running and ready after the restart." )
0 commit comments