Clean up after tests.

Author: MirahImage

system_tests/exchange_system_test.go

@@ -44,6 +44,10 @@ var _ = Describe("Exchange", func() {
 }
 })
 
+AfterEach(func() {
+_ = k8sClient.Delete(ctx, exchange)
+})
+
 It("declares and deletes a exchange successfully", func() {
 By("declaring exchange")
 Expect(k8sClient.Create(ctx, exchange, &client.CreateOptions{})).To(Succeed())

system_tests/operatorpolicy_system_test.go

@@ -44,6 +44,10 @@ var _ = Describe("OperatorPolicy", func() {
 }
 })
 
+AfterEach(func() {
+_ = k8sClient.Delete(ctx, policy)
+})
+
 It("creates, updates and deletes an operator policy successfully", func() {
 By("creating operator policy")
 Expect(k8sClient.Create(ctx, policy, &client.CreateOptions{})).To(Succeed())

system_tests/policy_system_test.go

@@ -43,6 +43,10 @@ var _ = Describe("Policy", func() {
 }
 })
 
+AfterEach(func() {
+_ = k8sClient.Delete(ctx, policy)
+})
+
 It("creates, updates and deletes a policy successfully", func() {
 By("creating policy")
 Expect(k8sClient.Create(ctx, policy, &client.CreateOptions{})).To(Succeed())

system_tests/queue_system_test.go

@@ -44,6 +44,10 @@ var _ = Describe("Queue Controller", func() {
 }
 })
 
+AfterEach(func() {
+_ = k8sClient.Delete(ctx, q)
+})
+
 It("declares and deletes a queue successfully", func() {
 By("declaring queue")
 Expect(k8sClient.Create(ctx, q, &client.CreateOptions{})).To(Succeed())

system_tests/user_system_test.go

@@ -22,6 +22,10 @@ var _ = Describe("Users", func() {
 user *topology.User
 )
 
+AfterEach(func() {
+_ = k8sClient.Delete(ctx, user)
+})
+
 When("relying on the operator to generate a username and password", func() {
 BeforeEach(func() {
 user = &topology.User{

system_tests/vhost_system_test.go

@@ -38,6 +38,10 @@ var _ = Describe("vhost", func() {
 }
 })
 
+AfterEach(func() {
+_ = k8sClient.Delete(ctx, vhost)
+})
+
 It("creates and deletes a vhost successfully", func() {
 By("creating a vhost")
 Expect(k8sClient.Create(ctx, vhost, &client.CreateOptions{})).To(Succeed())