From a7f585be953b161630406eb31d3b0f9661b4323f Mon Sep 17 00:00:00 2001 From: Andre Medeiros Date: Wed, 26 Oct 2022 20:26:38 -0400 Subject: [PATCH] make measurements more accurate in notifications worker --- internal/worker/notifications.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/worker/notifications.go b/internal/worker/notifications.go index dc806f2..1b439ab 100644 --- a/internal/worker/notifications.go +++ b/internal/worker/notifications.go @@ -145,7 +145,7 @@ func (nc *notificationsConsumer) Consume(delivery rmq.Delivery) { key := fmt.Sprintf("locks:accounts:%s", id) // Measure queue latency - ttl := nc.redis.TTL(nc, key).Val() + ttl := nc.redis.PTTL(nc, key).Val() age := (domain.NotificationCheckTimeout - ttl) _ = nc.statsd.Histogram("apollo.dequeue.latency", float64(age.Milliseconds()), []string{"queue:notifications"}, 0.1)