Skip to content

Commit fc73a95

Browse files
authored
Merge pull request #49 from linki/util
Extract utility function into util package
2 parents 9bf8c56 + eedf139 commit fc73a95

File tree

2 files changed

+28
-22
lines changed

2 files changed

+28
-22
lines changed

chaoskube/chaoskube_test.go

Lines changed: 6 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -6,10 +6,11 @@ import (
66
"strings"
77
"testing"
88

9-
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
109
"k8s.io/apimachinery/pkg/labels"
1110
"k8s.io/client-go/kubernetes/fake"
1211
"k8s.io/client-go/pkg/api/v1"
12+
13+
"github.com/linki/chaoskube/util"
1314
)
1415

1516
var logOutput = bytes.NewBuffer([]byte{})
@@ -200,7 +201,7 @@ func TestNoVictimReturnsError(t *testing.T) {
200201
func TestDeletePod(t *testing.T) {
201202
chaoskube := setup(t, labels.Everything(), labels.Everything(), labels.Everything(), false, 0)
202203

203-
victim := newPod("default", "foo")
204+
victim := util.NewPod("default", "foo")
204205

205206
if err := chaoskube.DeletePod(victim); err != nil {
206207
t.Fatal(err)
@@ -217,7 +218,7 @@ func TestDeletePod(t *testing.T) {
217218
func TestDeletePodDryRun(t *testing.T) {
218219
chaoskube := setup(t, labels.Everything(), labels.Everything(), labels.Everything(), true, 0)
219220

220-
victim := newPod("default", "foo")
221+
victim := util.NewPod("default", "foo")
221222

222223
if err := chaoskube.DeletePod(victim); err != nil {
223224
t.Fatal(err)
@@ -300,27 +301,10 @@ func validateLog(t *testing.T, msg string) {
300301
}
301302
}
302303

303-
func newPod(namespace, name string) v1.Pod {
304-
pod := v1.Pod{
305-
ObjectMeta: metav1.ObjectMeta{
306-
Namespace: namespace,
307-
Name: name,
308-
Labels: map[string]string{
309-
"app": name,
310-
},
311-
Annotations: map[string]string{
312-
"chaos": name,
313-
},
314-
},
315-
}
316-
317-
return pod
318-
}
319-
320304
func setup(t *testing.T, labelSelector labels.Selector, annotations labels.Selector, namespaces labels.Selector, dryRun bool, seed int64) *Chaoskube {
321305
pods := []v1.Pod{
322-
newPod("default", "foo"),
323-
newPod("testing", "bar"),
306+
util.NewPod("default", "foo"),
307+
util.NewPod("testing", "bar"),
324308
}
325309

326310
client := fake.NewSimpleClientset()

util/util.go

Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
package util
2+
3+
import (
4+
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
5+
"k8s.io/client-go/pkg/api/v1"
6+
)
7+
8+
// NewPod returns a new pod instance for testing purposes.
9+
func NewPod(namespace, name string) v1.Pod {
10+
return v1.Pod{
11+
ObjectMeta: metav1.ObjectMeta{
12+
Namespace: namespace,
13+
Name: name,
14+
Labels: map[string]string{
15+
"app": name,
16+
},
17+
Annotations: map[string]string{
18+
"chaos": name,
19+
},
20+
},
21+
}
22+
}

0 commit comments

Comments
 (0)