Add logs to reporter and watcher

metadata/version.go

@@ -8,7 +8,7 @@
 package metadata
 
 //Version of Maestro
-var Version = "9.6.1"
+var Version = "9.15.1"
 
 //KubeVersion is the desired Kubernetes version
 var KubeVersion = "v1.13.9"

reporters/dogstatsd.go

@@ -49,15 +49,15 @@ func (d *DogStatsD) Report(event string, opts map[string]interface{}) error {
 	defer d.mutex.RUnlock()
 	handlerI, prs := handlers.Find(event)
 	if prs == false {
-		return fmt.Errorf("reportHandler for %s doesn't exist", event)
+		return fmt.Errorf("DogStatsD: reportHandler for %s doesn't exist", event)
 	}
 	opts[constants.TagRegion] = d.region
 	handler := handlerI.(func(dogstatsd.Client, string, map[string]string) error)
 	err := handler(d.client, event, toMapStringString(opts))
 	if err != nil {
-		d.logger.Error(err)
+		return fmt.Errorf("DogStatsD: failed to report event '%s': %w", event, err)
 	}
-	return err
+	return nil
 }
 
 // MakeDogStatsD adds a DogStatsD struct to the Reporters' singleton
@@ -116,7 +116,7 @@ func (d *DogStatsD) restartTicker() {
 	for range d.ticker.C {
 		d.mutex.Lock()
 		if err := d.restartDogStatsdClient(); err != nil {
-			d.logger.Errorf("DogStatsD: failed to close statsd connection during restart: %s", err.Error())
+			d.logger.WithError(err).Errorf("DogStatsD: failed to close statsd connection during restart")
 		}
 		d.mutex.Unlock()
 	}
@@ -133,6 +133,7 @@ func (d *DogStatsD) restartDogStatsdClient() error {
 		return fmt.Errorf("failed to recreate dogstatsd client: %w", err)
 	}
 
+	d.logger.Info("DogStatsD was restarted successfully")
 	d.statsdClient = c.Client.(*statsd.Client)
 	d.client = c
 	return nil

reporters/reporter.go

@@ -52,8 +52,15 @@ func copyOpts(src map[string]interface{}) map[string]interface{} {
 
 // Report is Reporters' implementation of the Reporter interface
 func (r *Reporters) Report(event string, opts map[string]interface{}) error {
+	var aggregatedErrors []error
 	for _, reporter := range r.reporters {
-		reporter.Report(event, copyOpts(opts))
+		if err := reporter.Report(event, copyOpts(opts)); err != nil {
+			aggregatedErrors = append(aggregatedErrors, err)
+		}
+	}
+
+	if len(aggregatedErrors) > 0 {
+		return fmt.Errorf("failed to report '%s' event: %v", event, aggregatedErrors)
 	}
 	return nil
 }
@@ -80,7 +87,7 @@ func MakeReporters(config *viper.Viper, logger *logrus.Logger) {
 	for k := range GetInstance().reporters {
 		correctlySet = append(correctlySet, k)
 	}
-	logger.Info(fmt.Sprintf("Active reporters: %s", strings.Join(correctlySet, ", ")))
+	logger.Infof("Active reporters: %s", strings.Join(correctlySet, ", "))
 }
 
 // NewReporters ctor

watcher/watcher.go

@@ -286,7 +286,9 @@ func (w *Watcher) reportRoomsStatusesRoutine() {
 		case <-podStateCountTicker.C:
 			w.PodStatesCount()
 		case <-roomStatusTicker.C:
-			_ = w.ReportRoomsStatuses()
+			if err := w.ReportRoomsStatuses(); err != nil {
+				w.Logger.WithError(err).Error("failed to report room status")
+			}
 		}
 	}
 }
@@ -461,12 +463,15 @@ func (w *Watcher) ReportRoomsStatuses() error {
 	}
 
 	for _, r := range roomDataSlice {
-		_ = reporters.Report(reportersConstants.EventGruStatus, map[string]interface{}{
+		err := reporters.Report(reportersConstants.EventGruStatus, map[string]interface{}{
 			reportersConstants.TagGame:      w.GameName,
 			reportersConstants.TagScheduler: w.SchedulerName,
 			"status":                        r.Status,
 			"gauge":                         r.Gauge,
 		})
+		if err != nil {
+			w.Logger.Error(err)
+		}
 	}
 
 	return nil