diff options
| author | Valery Piashchynski <[email protected]> | 2021-09-16 21:24:13 +0300 |
|---|---|---|
| committer | GitHub <[email protected]> | 2021-09-16 21:24:13 +0300 |
| commit | 337d292dd2d6ff0a555098b1970d8194d8df8bc2 (patch) | |
| tree | a2ab31666f95813a592bea2b207f2db0ba188c92 /tests/plugins/jobs | |
| parent | 5d2cd55ab522d4f1e65a833f91146444465a32ac (diff) | |
| parent | cc56349f3ad19aa54ae7900c50e018d757305804 (diff) | |
[#783]: feat(grpc): update GRPC plugin to RR `v2`
[#783]: feat(grpc): update GRPC plugin to RR `v2`
Diffstat (limited to 'tests/plugins/jobs')
| -rw-r--r-- | tests/plugins/jobs/jobs_with_toxics_test.go | 12 |
1 files changed, 10 insertions, 2 deletions
diff --git a/tests/plugins/jobs/jobs_with_toxics_test.go b/tests/plugins/jobs/jobs_with_toxics_test.go index 80fed8eb..84fbec48 100644 --- a/tests/plugins/jobs/jobs_with_toxics_test.go +++ b/tests/plugins/jobs/jobs_with_toxics_test.go @@ -27,10 +27,18 @@ import ( func TestDurabilityAMQP(t *testing.T) { client := toxiproxy.NewClient("127.0.0.1:8474") + proxies, err := client.Proxies() + require.NoError(t, err) + + for p := range proxies { + _ = proxies[p].Delete() + } - _, err := client.CreateProxy("redial", "127.0.0.1:23679", "127.0.0.1:5672") + proxy, err := client.CreateProxy("redial", "127.0.0.1:23679", "127.0.0.1:5672") require.NoError(t, err) - defer deleteProxy("redial", t) + defer func() { + _ = proxy.Delete() + }() cont, err := endure.NewContainer(nil, endure.SetLogLevel(endure.ErrorLevel)) require.NoError(t, err) |