From 2af8d0bbd77d4dc1564608fd14df2eb122ab600c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Wojciech=20Tyczy=C5=84ski?= Date: Thu, 2 Jun 2022 20:42:11 +0200 Subject: [PATCH] Clean shutdown of events integration tests --- test/integration/events/events_test.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/test/integration/events/events_test.go b/test/integration/events/events_test.go index bce66117840..9a6f3c18f11 100644 --- a/test/integration/events/events_test.go +++ b/test/integration/events/events_test.go @@ -58,13 +58,17 @@ func TestEventCompatibility(t *testing.T) { if err != nil { t.Fatal(err) } + stopCh := make(chan struct{}) + defer close(stopCh) oldBroadcaster := record.NewBroadcaster() + defer oldBroadcaster.Shutdown() oldRecorder := oldBroadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: "integration"}) oldBroadcaster.StartRecordingToSink(&typedv1.EventSinkImpl{Interface: client.CoreV1().Events("")}) oldRecorder.Eventf(regarding, v1.EventTypeNormal, "started", "note") newBroadcaster := events.NewBroadcaster(&events.EventSinkImpl{Interface: client.EventsV1()}) + defer newBroadcaster.Shutdown() newRecorder := newBroadcaster.NewRecorder(scheme.Scheme, "k8s.io/kube-scheduler") newBroadcaster.StartRecordingToSink(stopCh) newRecorder.Eventf(regarding, related, v1.EventTypeNormal, "memoryPressure", "killed", "memory pressure")