From ca8f3dff9ae4a8631d7b588ef0c185a29acffc8b Mon Sep 17 00:00:00 2001 From: zhoumingcheng Date: Thu, 23 Jun 2022 17:57:17 +0800 Subject: [PATCH] add unit test coverage for pkg/kubelet/util/queue Signed-off-by: zhoumingcheng --- pkg/kubelet/util/queue/work_queue_test.go | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) diff --git a/pkg/kubelet/util/queue/work_queue_test.go b/pkg/kubelet/util/queue/work_queue_test.go index af8d2d683cc..47f4635438f 100644 --- a/pkg/kubelet/util/queue/work_queue_test.go +++ b/pkg/kubelet/util/queue/work_queue_test.go @@ -20,8 +20,10 @@ import ( "testing" "time" + "github.com/stretchr/testify/assert" "k8s.io/apimachinery/pkg/types" "k8s.io/apimachinery/pkg/util/sets" + "k8s.io/utils/clock" testingclock "k8s.io/utils/clock/testing" ) @@ -63,3 +65,19 @@ func TestGetWork(t *testing.T) { compareResults(t, expected, q.GetWork()) compareResults(t, []types.UID{}, q.GetWork()) } + +func TestNewBasicWorkQueue(t *testing.T) { + tests := []struct { + clock clock.Clock + expectedWorkQueue WorkQueue + }{ + { + clock: clock.RealClock{}, + expectedWorkQueue: &basicWorkQueue{queue: make(map[types.UID]time.Time), clock: clock.RealClock{}}, + }, + } + for _, test := range tests { + workQueue := NewBasicWorkQueue(test.clock) + assert.Equal(t, test.expectedWorkQueue, workQueue) + } +}