Function TestManagerThatFailsToStart

pkg/util/services/manager_test.go:164–203

(t *testing.T)

}

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

	s1 := serviceThatDoesntDoAnything()
	s2 := serviceThatDoesntDoAnything()
	s3 := serviceThatFailsToStart()
	gl := newGatheringManagerListener(t)

	m, err := NewManager(s1, s2, s3)
	require.NoError(t, err)
	m.AddListener(gl)

	states := m.ServicesByState()
	require.Equal(t, states, map[State][]Service{New: {s1, s2, s3}})

	require.NoError(t, m.StartAsync(context.Background()))
	err = m.AwaitHealthy(context.Background())
	require.Error(t, err) // will never get healthy, since one service fails to start
	require.EqualError(t, err, "not healthy, 0 terminated, 1 failed: [failed to start]")

	states = m.ServicesByState()
	// check that failed state contains s3.
	require.ElementsMatch(t, states[Failed], []Service{s3})

	// s1 and s2 can be in New (if Starting state transition wasn't observed yet), Starting or Running state.
	require.ElementsMatch(t, mergeStates(states, New, Starting, Running), []Service{s1, s2})

	// stop remaining services
	m.StopAsync()
	require.NoError(t, m.AwaitStopped(context.Background()))

	states = m.ServicesByState()
	equalStatesMap(t, states, map[State][]Service{
		Terminated: {s1, s2},
		Failed:     {s3},
	})

	require.NoError(t, gl.AwaitTerminated(context.Background()))
	require.Equal(t, []string{"failed", "stopped"}, gl.log)
}

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