Method AwaitHealthy

services/manager.go:116–141

AwaitHealthy waits for the ServiceManager to become healthy. Returns nil, if manager is healthy, error otherwise (eg. manager is in a state in which it cannot get healthy anymore).

(ctx context.Context)

// AwaitHealthy waits for the ServiceManager to become healthy. Returns nil, if manager is healthy, error otherwise (eg. manager
// is in a state in which it cannot get healthy anymore).
func (m *Manager) AwaitHealthy(ctx context.Context) error {
	select {
	case <-ctx.Done():
		return ctx.Err()
	case <-m.healthyCh:
	}

	m.mu.Lock()
	defer m.mu.Unlock()

	if m.state != healthy {
		terminated := len(m.byState[Terminated])

		var failedReasons []string
		for _, s := range m.byState[Failed] {
			err := s.FailureCase()
			if err != nil {
				// err is never nil for a failed service.
				failedReasons = append(failedReasons, err.Error())
			}
		}

		return fmt.Errorf("not healthy, %d terminated, %d failed: %v", terminated, len(failedReasons), failedReasons)
	}
	return nil
}

// IsStopped returns true if all services are in terminal state (Terminated or Failed)
func (m *Manager) IsStopped() bool {