Fix test e2e-kind test run

test/pkg/debug/setup.go

@@ -34,13 +34,22 @@ const (
 var m *Monitor
 var e *EventClient
 
-func BeforeEach(ctx context.Context, config *rest.Config, kubeClient client.Client) {
+func BeforeSuite(ctx context.Context, config *rest.Config, kubeClient client.Client) {
 	// If the test is labeled as NoWatch, then the node/pod monitor will just list at the beginning
 	// of the test rather than perform a watch during it
 	if !lo.Contains(ginkgo.CurrentSpecReport().Labels(), NoWatch) {
 		m = New(ctx, config, kubeClient)
 		m.MustStart()
 	}
+}
+
+func AfterSuite(ctx context.Context, config *rest.Config, kubeClient client.Client) {
+	if !lo.Contains(ginkgo.CurrentSpecReport().Labels(), NoWatch) {
+		m.Stop()
+	}
+}
+
+func BeforeEach(ctx context.Context, config *rest.Config, kubeClient client.Client) {
 	if !lo.Contains(ginkgo.CurrentSpecReport().Labels(), NoEvents) {
 		e = NewEventClient(kubeClient)
 	}

test/suites/perf/suite_test.go

@@ -46,12 +46,14 @@ func TestPerf(t *testing.T) {
 	RegisterFailHandler(Fail)
 	BeforeSuite(func() {
 		env = common.NewEnvironment(t)
+		debug.BeforeSuite(env.Context, env.Config, env.Client)
 	})
 	AfterSuite(func() {
 		// Write out the timestamps from our tests
 		if err := debug.WriteTimestamps(env.OutputDir, env.TimeIntervalCollector); err != nil {
 			log.FromContext(env).Info(fmt.Sprintf("Failed to write timestamps to files, %s", err))
 		}
+		debug.AfterSuite(env.Context, env.Config, env.Client)
 		env.Stop()
 	})
 	RunSpecs(t, "Perf")