Function TestTimerService

pkg/util/services/services_test.go:41–66

(t *testing.T)

}

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

	var iterations atomic.Uint64

	s := NewTimerService(100*time.Millisecond, nil, func(ctx context.Context) error {
		iterations.Inc()
		return nil
	}, nil)
	defer s.StopAsync()

	require.Equal(t, New, s.State())
	require.NoError(t, s.StartAsync(context.Background()))
	require.Error(t, s.StartAsync(context.Background()))
	require.NoError(t, s.AwaitRunning(context.Background()))
	require.Equal(t, Running, s.State())

	time.Sleep(1 * time.Second)

	val := iterations.Load()
	require.NotZero(t, val) // we should observe some iterations now

	s.StopAsync()
	require.NoError(t, s.AwaitTerminated(context.Background()))
	require.Equal(t, Terminated, s.State())
}

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