func (s *StatsRPC) watchConnection() {
heartbeatTicker := time.NewTicker(10 * time.Second).C
atomic.StoreUint32(&s.available, 1)
func (s *StatsRPC) watchConnection() {
heartbeatTicker := time.NewTicker(10 * time.Second).C
atomic.StoreUint32(&s.available, 1)
case core.Connected:
if !s.serviceAvailable() {
atomic.StoreUint32(&s.available, 1)
case core.Connected:
if !s.serviceAvailable() {
atomic.StoreUint32(&s.available, 1)