Function TestIdleService

pkg/util/services/services_test.go:13–39

(t *testing.T)

)

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

	started := false
	stopped := false

	s := NewIdleService(func(ctx context.Context) error {
		started = true
		return nil
	}, func(_ error) error {
		stopped = true
		return nil
	})
	defer s.StopAsync()

	require.False(t, started)
	require.Equal(t, New, s.State())
	require.NoError(t, s.StartAsync(context.Background()))
	require.Error(t, s.StartAsync(context.Background())) // cannot start twice
	require.NoError(t, s.AwaitRunning(context.Background()))
	require.True(t, started)
	require.False(t, stopped)
	require.Equal(t, Running, s.State())
	s.StopAsync()
	require.NoError(t, s.AwaitTerminated(context.Background()))
	require.True(t, stopped)
}

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