Remove ES info and debug logging.

content_indexer.go

@@ -151,7 +151,7 @@ func (indexer *contentIndexer) handleMessage(msg consumer.Message) {
 	}
 
 	uuid := combinedPostPublicationEvent.Content.UUID
-	log.Printf("[%s] Processing combined post publication event for uuid [%s]", tid, uuid)
+	log.Infof("[%s] Processing combined post publication event for uuid [%s]", tid, uuid)
 
 	var contentType string
 

es_client.go

@@ -3,9 +3,8 @@ package main
 import (
 	awsauth "github.com/smartystreets/go-aws-auth"
 	"gopkg.in/olivere/elastic.v2"
-	"log"
+	log "github.com/Sirupsen/logrus"
 	"net/http"
-	"os"
 )
 
 type esClientI interface {
@@ -48,8 +47,6 @@ var newAmazonClient = func(config esAccessConfig) (esClientI, error) {
 		elastic.SetScheme("https"),
 		elastic.SetHttpClient(signingClient),
 		elastic.SetSniff(false), //needs to be disabled due to EAS behavior. Healthcheck still operates as normal.
-		elastic.SetInfoLog(log.New(os.Stderr, "", log.LstdFlags)),
-		elastic.SetErrorLog(log.New(os.Stderr, "", log.LstdFlags)),
-		elastic.SetTraceLog(log.New(os.Stderr, "", log.LstdFlags)),
+		elastic.SetErrorLog(log.New()),
 	)
 }

es_service.go

@@ -61,6 +61,10 @@ func (service *esService) getSchemaHealth() (string, error) {
 		}
 	}
 
+	if service.elasticClient == nil {
+		return "not ok, connection to ES couldn't be established", nil
+	}
+
 	liveIndex, err := service.elasticClient.IndexGet().Index(service.indexName).Do()
 	if err != nil {
 		return "", err