Skip to content

Commit 797199a

Browse files
authored
Merge pull request #19 from szibis/sending_logging
Log full extended metrics when prefix/tags enabled and verbose mode
2 parents 6b5e160 + be60e79 commit 797199a

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

statsrelay.go

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -250,10 +250,6 @@ func handleBuff(buff []byte) {
250250

251251
target := hashRing.GetNode(metric).Server
252252

253-
if verbose {
254-
log.Printf("Sending %s to %s", metric, target)
255-
}
256-
257253
// check built packet size and send if metric doesn't fit
258254
if packets[target].Len()+size > packetLen {
259255
go sendPacket(packets[target].Bytes(), target, sendproto, TCPtimeout)
@@ -262,12 +258,18 @@ func handleBuff(buff []byte) {
262258
// add to packet
263259
if len(metricsPrefix) != 0 || len(metricTags) != 0 {
264260
buffPrefix, err := extendMetric(buff[offset:offset+size], metricsPrefix, metricTags)
261+
if verbose {
262+
log.Printf("Sending %s to %s", buffPrefix, target)
263+
}
265264
if err != nil {
266265
log.Printf("Error %s when adding prefix %s", err, metricsPrefix)
267266
break
268267
}
269268
packets[target].Write(buffPrefix)
270269
} else {
270+
if verbose {
271+
log.Printf("Sending %s to %s", metric, target)
272+
}
271273
packets[target].Write(buff[offset : offset+size])
272274
}
273275
packets[target].Write(sep)

0 commit comments

Comments
 (0)