Function TestNilServiceFailureWatcher

services/failure_watch_test.go:14–38

(t *testing.T)

)

func TestNilServiceFailureWatcher(t *testing.T) {
	var w *FailureWatcher

	// prove it doesn't fail, but returns nil channel.
	require.Nil(t, w.Chan())

	// Ensure WatchService() panics.
	require.Panics(t, func() {
		w.WatchService(NewIdleService(nil, nil))
	})

	// Ensure WatchManager() panics.
	m, err := NewManager(NewIdleService(nil, nil))
	require.NoError(t, err)
	t.Cleanup(func() {
		require.NoError(t, StopManagerAndAwaitStopped(context.Background(), m))
	})

	require.Panics(t, func() {
		w.WatchManager(m)
	})

	// Closing nil watcher doesn't panic.
	w.Close()
}

func TestServiceFailureWatcher(t *testing.T) {
	w := NewFailureWatcher()