Function TestOneService

service/pool_test.go:33–74

(t *testing.T)

}

func TestOneService(t *testing.T) {
	pool := service.NewPool(service.NewLifecycleFactory(), log.NewTestLogger(t))
	poolLifecycle := service.NewLifecycle(pool)
	poolStarted := make(chan bool)
	poolStopped := make(chan bool)
	var poolStates []service.State
	var serviceStates []service.State
	poolLifecycle.OnRunning(func(s service.Service, l service.Lifecycle) {
		poolStarted <- true
	})
	poolLifecycle.OnStateChange(func(s service.Service, l service.Lifecycle, state service.State) {
		poolStates = append(poolStates, state)
	})

	s := newTestService("Test service")
	pool.Add(s).OnStateChange(func(s service.Service, l service.Lifecycle, state service.State) {
		serviceStates = append(serviceStates, state)
	})

	go func() {
		err := poolLifecycle.Run()
		if err != nil {
			t.Fail()
		}
		poolStopped <- true
	}()

	<-poolStarted
	poolLifecycle.Stop(context.Background())
	assert.Equal(t, []service.State{
		service.StateStarting,
		service.StateRunning,
		service.StateStopping,
		service.StateStopped,
	}, serviceStates)
	assert.Equal(t, []service.State{
		service.StateStarting,
		service.StateRunning,
		service.StateStopping,
		service.StateStopped,
	}, poolStates)
}

func TestOneServiceCrash(t *testing.T) {
	testLock := &sync.Mutex{}