code: func (observer *Observer) UpdateAllStats() {
  	queues, err := observer.GetAllQueues()
  	if err != nil {
  		log.Fatalf("ERROR FETCHING QUEUES %s", err.Error())
  	}
  
  	for _, queue := range queues {
  		observer.UpdateQueueStats(queue)
  	}
  }
docs: // UpdateAllStats fetches stats for all queues and all their consumers