Method initHealthCheck

pubsub.go:714–746

()

}

func (c *channel) initHealthCheck() {
	c.ping = make(chan struct{}, 1)

	go func() {
		timer := time.NewTimer(time.Minute)
		timer.Stop()

		for {
			timer.Reset(c.checkInterval)
			select {
			case <-c.ping:
				select {
				case <-timer.C:
				default:
				}
			case <-timer.C:
				ctx, cancel := context.WithTimeout(context.Background(), c.pingTimeout)
				pingErr := c.pubSub.Ping(ctx)
				cancel()

				if pingErr != nil {
					c.pubSub.mu.Lock()
					reconnectCtx, reconnectCancel := context.WithTimeout(context.Background(), c.reconnectTimeout)
					c.pubSub.reconnect(reconnectCtx, pingErr)
					reconnectCancel()
					c.pubSub.mu.Unlock()
				}
			case <-c.pubSub.exit:
				return
			}
		}
	}()
}

// initMsgChan must be in sync with initAllChan.
func (c *channel) initMsgChan() {