Add module tag to logs from metadata client (#257)

uber-archive · Jul 20, 2017 · 0602edb · 0602edb
1 parent 766d9cd
commit 0602edb
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/clients/metadata/metadata_cassandra.go b/clients/metadata/metadata_cassandra.go
@@ -196,7 +196,10 @@ func NewCassandraMetadataService(cfg configure.CommonMetadataConfig, log bark.Lo
 		log = bark.NewLoggerFromLogrus(logrus.StandardLogger())
 	}
 
-	lowCons, midCons, highCons := gocql.Two, gocql.Two, gocql.ParseConsistency(cfg.GetConsistency())
+	// use a minimum consistency of 'Two', so that reads from a recently added (non-current) cassandra
+	// host, does not result in inconsistent data.
+	lowCons, midCons := gocql.Two, gocql.Two
+	highCons := gocql.ParseConsistency(cfg.GetConsistency())
 
 	if highCons == gocql.One {
 
@@ -256,7 +259,7 @@ func NewCassandraMetadataService(cfg configure.CommonMetadataConfig, log bark.Lo
 		midConsLevel:  midCons,
 		highConsLevel: highCons,
 		clusterName:   clusterName,
-		log:           log,
+		log:           log.WithField(common.TagModule, `metadata`),
 	}, nil
 }