Add transformLatency and sum metrics to statsd implementation (closes #…

…85)
snowplow · Aug 22, 2022 · 9b219a0 · 9b219a0
1 parent b1063e9
commit 9b219a0
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pkg/statsreceiver/statsd.go b/pkg/statsreceiver/statsd.go
@@ -115,4 +115,7 @@ func (s *statsDStatsReceiver) Send(b *models.ObserverBuffer) {
 	s.client.Incr("invalid_message_failed", b.InvalidMsgFailed)
 	s.client.PrecisionTiming("latency_processing_max", b.MaxProcLatency)
 	s.client.PrecisionTiming("latency_message_max", b.MaxMsgLatency)
+	s.client.PrecisionTiming("latency_transform_min", b.MinTransformLatency)
+	s.client.PrecisionTiming("latency_transform_max", b.MaxTransformLatency)
+	s.client.PrecisionTiming("latency_transform_avg", b.GetAvgTransformLatency())
 }