Function TestTicker

internal/controller/runtime/ticker_test.go:26–71

(t *testing.T)

}

func TestTicker(t *testing.T) {
	t.Parallel()

	var called []event.GenericEvent
	expected := event.GenericEvent{Object: new(corev1.ConfigMap)}

	tq := workqueue.NewTypedRateLimitingQueue(workqueue.DefaultTypedItemBasedRateLimiter[reconcile.Request]())
	th := handler.Funcs{GenericFunc: func(ctx context.Context, e event.GenericEvent, q workqueue.TypedRateLimitingInterface[reconcile.Request]) {
		called = append(called, e)

		assert.Equal(t, q, tq, "should be called with the queue passed in Start")
	}}

	t.Run("NotImmediate", func(t *testing.T) {
		called = nil

		ticker := NewTicker(100*time.Millisecond, expected, th)
		ctx, cancel := context.WithTimeout(context.Background(), 250*time.Millisecond)
		t.Cleanup(cancel)

		// Start the ticker and wait for the deadline to pass.
		assert.NilError(t, ticker.Start(ctx, tq))
		<-ctx.Done()

		assert.Equal(t, len(called), 2)
		assert.Equal(t, called[0], expected, "expected at 100ms")
		assert.Equal(t, called[1], expected, "expected at 200ms")
	})

	t.Run("Immediate", func(t *testing.T) {
		called = nil

		ticker := NewTickerImmediate(100*time.Millisecond, expected, th)
		ctx, cancel := context.WithTimeout(context.Background(), 250*time.Millisecond)
		t.Cleanup(cancel)

		// Start the ticker and wait for the deadline to pass.
		assert.NilError(t, ticker.Start(ctx, tq))
		<-ctx.Done()

		assert.Assert(t, len(called) > 2)
		assert.Equal(t, called[0], expected, "expected at 0ms")
		assert.Equal(t, called[1], expected, "expected at 100ms")
		assert.Equal(t, called[2], expected, "expected at 200ms")
	})
}