From ebfb5392c52f4cbbcb429dc30bf6d94d033bea7f Mon Sep 17 00:00:00 2001 From: Madhav Jivrajani Date: Tue, 16 Nov 2021 17:26:41 +0530 Subject: [PATCH] Add unit test for Recorder Signed-off-by: Madhav Jivrajani --- .../apimachinery/pkg/watch/filter_test.go | 30 +++++++++++++++++++ 1 file changed, 30 insertions(+) diff --git a/staging/src/k8s.io/apimachinery/pkg/watch/filter_test.go b/staging/src/k8s.io/apimachinery/pkg/watch/filter_test.go index 4b5ae898ac4..106e06b46f5 100644 --- a/staging/src/k8s.io/apimachinery/pkg/watch/filter_test.go +++ b/staging/src/k8s.io/apimachinery/pkg/watch/filter_test.go @@ -82,3 +82,33 @@ func TestFilterStop(t *testing.T) { t.Errorf("got %v, wanted %v", e, a) } } + +func TestRecorder(t *testing.T) { + events := []Event{ + {Type: Added, Object: testType("foo")}, + {Type: Added, Object: testType("bar")}, + {Type: Added, Object: testType("baz")}, + {Type: Added, Object: testType("qux")}, + {Type: Added, Object: testType("zoo")}, + } + + source := NewFake() + go func() { + for _, item := range events { + source.Action(item.Type, item.Object) + } + source.Stop() + }() + + recorder := NewRecorder(source) + for { + _, ok := <-recorder.Interface.ResultChan() + if !ok { + break + } + } + recordedEvents := recorder.Events() + if !reflect.DeepEqual(recordedEvents, events) { + t.Errorf("got %v, expected %v", recordedEvents, events) + } +}