Simpliefied logging + restored json formatter

lambda/forwarder.go

@@ -32,7 +32,7 @@ func CreateForwarder(entry config.AmazonEntry, lambdaClient ...lambdaiface.Lambd
 		client = lambda.New(session.Must(session.NewSession()))
 	}
 	forwarder := Forwarder{entry.Name, client, entry.Target}
-	log.WithFields(log.Fields{"forwarderName": forwarder.Name()}).Info("Created forwarder")
+	log.WithField("forwarderName", forwarder.Name()).Info("Created forwarder")
 	return forwarder
 }
 

mapping/mapping.go

@@ -67,7 +67,7 @@ func (c Client) Load() (map[consumer.Client]forwarder.Client, error) {
 
 func (c Client) loadFile() ([]byte, error) {
 	filePath := os.Getenv(config.MappingFile)
-	log.WithFields(log.Fields{"mappingFile": filePath}).Info("Loading mapping file")
+	log.WithField("mappingFile", filePath).Info("Loading mapping file")
 	return ioutil.ReadFile(filePath)
 }
 

rabbitmq/consumer.go

@@ -75,14 +75,12 @@ func closeRabbitMQ(conn *amqp.Connection, ch *amqp.Channel) {
 	log.Info("Closing RabbitMQ connection and channel")
 	if ch != nil {
 		if err := ch.Close(); err != nil {
-			log.WithFields(log.Fields{
-				"error": err.Error()}).Error("Could not close channel")
+			log.WithField("error", err.Error()).Error("Could not close channel")
 		}
 	}
 	if conn != nil {
 		if err := conn.Close(); err != nil {
-			log.WithFields(log.Fields{
-				"error": err.Error()}).Error("Could not close connection")
+			log.WithField("error", err.Error()).Error("Could not close connection")
 		}
 	}
 }
@@ -180,11 +178,9 @@ func (c Consumer) startForwarding(params *workerParams) error {
 				}
 			}
 		case <-params.check:
-			log.WithFields(log.Fields{
-				"forwarderName": forwarderName}).Info("Checking")
+			log.WithField("forwarderName", forwarderName).Info("Checking")
 		case <-params.stop:
-			log.WithFields(log.Fields{
-				"forwarderName": forwarderName}).Info("Closing")
+			log.WithField("forwarderName", forwarderName).Info("Closing")
 			closeRabbitMQ(params.conn, params.ch)
 			return errors.New(closedBySupervisorMessage)
 		}

server.go

@@ -9,18 +9,16 @@ import (
 )
 
 func main() {
-	log.SetFormatter(&log.TextFormatter{})
+	log.SetFormatter(&log.JSONFormatter{})
 	log.SetOutput(os.Stdout)
 
 	consumerForwarderMap, err := mapping.New().Load()
 	if err != nil {
-		log.WithFields(log.Fields{
-			"error": err.Error()}).Fatalf("Could not load consumer - forwarder pairs. Error: " + err.Error())
+		log.WithField("error", err.Error()).Fatalf("Could not load consumer - forwarder pairs")
 	}
 	supervisor := supervisor.New(consumerForwarderMap)
 	if err := supervisor.Start(); err != nil {
-		log.WithFields(log.Fields{
-			"error": err.Error()}).Fatal("Could not start supervisor")
+		log.WithField("error", err.Error()).Fatal("Could not start supervisor")
 	}
 	http.HandleFunc("/restart", supervisor.Restart)
 	http.HandleFunc("/health", supervisor.Check)

sns/forwarder.go

@@ -33,7 +33,7 @@ func CreateForwarder(entry config.AmazonEntry, snsClient ...snsiface.SNSAPI) for
 		client = sns.New(session.Must(session.NewSession()))
 	}
 	forwarder := Forwarder{entry.Name, client, entry.Target}
-	log.WithFields(log.Fields{"forwarderName": forwarder.Name()}).Info("Created forwarder")
+	log.WithField("forwarderName", forwarder.Name()).Info("Created forwarder")
 	return forwarder
 }
 

sqs/forwarder.go

@@ -33,7 +33,7 @@ func CreateForwarder(entry config.AmazonEntry, sqsClient ...sqsiface.SQSAPI) for
 		client = sqs.New(session.Must(session.NewSession()))
 	}
 	forwarder := Forwarder{entry.Name, client, entry.Target}
-	log.WithFields(log.Fields{"forwarderName": forwarder.Name()}).Info("Created forwarder")
+	log.WithField("forwarderName", forwarder.Name()).Info("Created forwarder")
 	return forwarder
 }
 

supervisor/supervisor.go

@@ -62,8 +62,7 @@ func (c *Client) Check(w http.ResponseWriter, r *http.Request) {
 	if accept := r.Header.Get(acceptHeader); accept != "" &&
 		!strings.Contains(accept, jsonType) &&
 		!strings.Contains(accept, acceptAll) {
-		log.WithFields(log.Fields{
-			"acceptHeader": accept}).Warn("Wrong Accept header")
+		log.WithField("acceptHeader", accept).Warn("Wrong Accept header")
 		notAcceptableResponse(w)
 		return
 	}