Fix build issue

uber-archive · May 18, 2017 · 050de4b · 050de4b
1 parent 916e5c9
commit 050de4b
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 3 deletions.
diff --git a/client/cherami/outputhostconnection.go b/client/cherami/outputhostconnection.go
@@ -205,7 +205,7 @@ func (conn *outputHostConnection) readMessagesPump() {
 
 		cmd, err := conn.outputHostStream.Read()
 		if err != nil {
-			conn.reporter.IncCounter(metrics.OutputReadFailedRate, nil, 1)
+			conn.reporter.IncCounter(metrics.ConsumeReadFailedRate, nil, 1)
 			// Error reading from stream.  Time to close and bail out.
 			conn.logger.Infof("Error reading OutputHost Message Stream: %v", err)
 			// Stream is closed.  Close the connection and bail out

diff --git a/common/metrics/names.go b/common/metrics/names.go
@@ -71,10 +71,8 @@ const (
 	PublisherMessageFailed = "cherami.publisher.message.failed"
 	// PublisherMessageTimedout is the number of messages timed out on the publisher
 	PublisherMessageTimedout = "cherami.publisher.message.timedout"
-
 	// ConsumeReadFailedRate is the rate of consume read failures
 	ConsumeReadFailedRate = "cherami.consume.read.failed"
-
 	// ConsumeMessageRate is the rate of message got from output
 	ConsumeMessageRate = "cherami.consume.message.rate"
 	// ConsumeCreditRate is the rate of credit sent to output