tags/tags.go
func (t *Tags) Stat(send helper.StatCallback) {
	helper.SendAndSubstractUint32("queuePutErrors", &t.q.stat.putErrors, send)
	helper.SendAndSubstractUint32("queuePutCount", &t.q.stat.putCount, send)
	helper.SendAndSubstractUint32("queueDeleteErrors", &t.q.stat.deleteErrors, send)
	helper.SendAndSubstractUint32("queueDeleteCount", &t.q.stat.deleteCount, send)
	helper.SendAndSubstractUint32("tagdbSendFail", &t.q.stat.sendFail, send)
	helper.SendAndSubstractUint32("tagdbSendSuccess", &t.q.stat.sendSuccess, send)

	send("queueLag", t.q.Lag().Seconds())
}
func (t *Tags) Stat(send helper.StatCallback) {
	helper.SendAndSubstractUint32("queuePutErrors", &t.q.stat.putErrors, send)
	helper.SendAndSubstractUint32("queuePutCount", &t.q.stat.putCount, send)
	helper.SendAndSubstractUint32("queueDeleteErrors", &t.q.stat.deleteErrors, send)
	helper.SendAndSubstractUint32("queueDeleteCount", &t.q.stat.deleteCount, send)
	helper.SendAndSubstractUint32("tagdbSendFail", &t.q.stat.sendFail, send)
	helper.SendAndSubstractUint32("tagdbSendSuccess", &t.q.stat.sendSuccess, send)

	send("queueLag", t.q.Lag().Seconds())
}
func ( t * Tags ) Stat ( send helper . StatCallback ) { helper . SendAndSubstractUint32 ( " " , & t . q . stat . putErrors , send ) helper . SendAndSubstractUint32 ( " " , & t . q . stat . putCount , send ) helper . SendAndSubstractUint32 ( " " , & t . q . stat . deleteErrors , send ) helper . SendAndSubstractUint32 ( " " , & t . q . stat . deleteCount , send ) helper . SendAndSubstractUint32 ( " " , & t . q . stat . sendFail , send ) helper . SendAndSubstractUint32 ( " " , & t . q . stat . sendSuccess , send ) send ( " " , t . q . Lag ( ) . Seconds ( ) ) }
// Collect metrics
Collect metrics