Subscribe + sentinel

[herkyl]

How do I keep a PubSubConn alive when Sentinel is switching masters?

My current code panics right after the master goes down:

func NewRedisDataSub(pool *redis.Pool, subCh chan *msg.RedisMessage) {
	c := pool.Get()
	pubsub := redis.PubSubConn{Conn: c}
	pubsub.Subscribe("data")
	defer func() {
		panic("Exited NewRedisDataSub")
	}()
	for {
		switch v := pubsub.Receive().(type) {
		case redis.Message:
			// Handle message
		case error:
			log.Error(v)
			return
		}
	}
}

[FZambia]

Hello. You can just restart your pubsub routine after error. Get new connection from pool, subscribe it to channel.

[herkyl]

Thanks for the prompt reply @FZambia!
How do I then figure out when all of the masters are down? I need to panic when pubsub stops working.

[FZambia]

Hmm, I am not ready to answer on this question at moment because I don't know for sure can we somehow distinguish case when all masters are down - need investigation on how Sentinel behaves.