Applied review suggestions

reporters/dogstatsd/handlers.go

@@ -71,7 +71,10 @@ func GruStatusHandler(c dogstatsd.Client, event string,
 	if err != nil {
 		return err
 	}
-	return c.Gauge(fmt.Sprintf("gru.%s", opts["status"]), gauge, tags, 1)
+	if err := c.Gauge(fmt.Sprintf("gru.%s", opts["status"]), gauge, tags, 1); err != nil {
+		return fmt.Errorf("dogstatsd failed to GRU Status gauge %s: %w", opts["status"], err)
+	}
+	return nil
 }
 
 // GruTimingHandler calls dogstatsd.Client.Timing with tags formatted as key:value
@@ -134,5 +137,8 @@ func GaugeHandler(
 	if err != nil {
 		return err
 	}
-	return c.Gauge(event, gauge, tags, 1)
+	if err := c.Gauge(event, gauge, tags, 1); err != nil {
+		return fmt.Errorf("dogstatsd failed to gauge %s: %w", opts["status"], err)
+	}
+	return nil
 }

watcher/watcher.go

@@ -286,9 +286,11 @@ func (w *Watcher) reportRoomsStatusesRoutine() {
 		case <-podStateCountTicker.C:
 			w.PodStatesCount()
 		case <-roomStatusTicker.C:
+			w.Logger.Info("Start to report rooms status")
 			if err := w.ReportRoomsStatuses(); err != nil {
 				w.Logger.WithError(err).Error("failed to report room status")
 			}
+			w.Logger.Info("Finished to report rooms status")
 		}
 	}
 }
@@ -423,8 +425,6 @@ func (w *Watcher) ReportRoomsStatuses() error {
 		return nil
 	}
 
-	w.Logger.Info("Start to report RoomsStatuses")
-
 	var roomCountByStatus *models.RoomsStatusCount
 	err := w.MetricsReporter.WithSegment(models.SegmentGroupBy, func() error {
 		var err error
@@ -484,8 +484,6 @@ func (w *Watcher) ReportRoomsStatuses() error {
 		}
 	}
 
-	w.Logger.Info("Finished to report RoomsStatuses")
-
 	return nil
 }