func()

in pubsub.go [130:157]

• 25 lines of code
• 6 McCabe index (conditional complexity)

func (p *Pubsub) Start() {
	backoff := backoff.NewExponentialBackOff()
	backoff.MaxInterval = time.Second * 10

	for {
		cnx, err := p.dialer.Dial()
		if err != nil {
			logrus.WithError(err).Info("redplex/pubsub: error dialing to pubsub master")
			select {
			case <-time.After(backoff.NextBackOff()):
				serverReconnects.Inc()
				continue
			case <-p.closer:
				return
			}
		}

		backoff.Reset()
		err = p.read(cnx)

		select {
		case <-p.closer:
			return
		default:
			logrus.WithError(err).Info("redplex/pubsub: lost connection to pubsub server")
		}
	}
}