Skip to content

Commit 8961500

Browse files
committed
fix CleanupContainer before error handling and simplify closure
1 parent b136a82 commit 8961500

File tree

1 file changed

+9
-7
lines changed

1 file changed

+9
-7
lines changed

modules/etcd/etcd_test.go

Lines changed: 9 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -33,19 +33,21 @@ func TestRun(t *testing.T) {
3333
func TestPutGet(t *testing.T) {
3434
t.Run("single_node", func(t *testing.T) {
3535
ctr, err := etcd.Run(context.Background(), "gcr.io/etcd-development/etcd:v3.5.14")
36-
require.NoError(t, err)
37-
testPutGet(t, ctr)
36+
testPutGet(t, ctr, err)
3837
})
3938
t.Run("multiple_nodes", func(t *testing.T) {
4039
ctr, err := etcd.Run(context.Background(), "gcr.io/etcd-development/etcd:v3.5.14", etcd.WithNodes("etcd-1", "etcd-2", "etcd-3"))
41-
require.NoError(t, err)
42-
testPutGet(t, ctr)
40+
testPutGet(t, ctr, err)
4341
})
4442
}
4543

46-
func testPutGet(t *testing.T, ctr *etcd.EtcdContainer) {
44+
func testPutGet(t *testing.T, ctr *etcd.EtcdContainer, err error) {
45+
t.Helper()
46+
4747
testcontainers.CleanupContainer(t, ctr)
4848

49+
require.NoError(t, err)
50+
4951
ctx := context.Background()
5052

5153
clientEndpoints, err := ctr.ClientEndpoints(ctx)
@@ -56,9 +58,9 @@ func testPutGet(t *testing.T, ctr *etcd.EtcdContainer) {
5658
DialTimeout: 5 * time.Second,
5759
})
5860
require.NoError(t, err)
59-
defer func(cli *clientv3.Client) {
61+
defer func() {
6062
require.NoError(t, cli.Close())
61-
}(cli)
63+
}()
6264

6365
ctx, cancel := context.WithTimeout(ctx, 2*time.Second)
6466
defer cancel()

0 commit comments

Comments
 (0)