From 8b7ea21eaf8f2041291fe398c5d10fc078e871e7 Mon Sep 17 00:00:00 2001 From: matst80 Date: Mon, 11 Nov 2024 13:37:04 +0100 Subject: [PATCH] metrics for latency --- rpc-pool.go | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/rpc-pool.go b/rpc-pool.go index 79ef36a..3819546 100644 --- a/rpc-pool.go +++ b/rpc-pool.go @@ -56,15 +56,19 @@ var ( }) ) +var start time.Time + func MeasureLatency(fn func() ([]byte, error)) ([]byte, error) { - start := time.Now() + start = time.Now() data, err := fn() if err != nil { return data, err } elapsed := time.Since(start).Milliseconds() - remoteCartLatency.Add(float64(elapsed)) - remoteCartCallsTotal.Inc() + go func() { + remoteCartLatency.Add(float64(elapsed)) + remoteCartCallsTotal.Inc() + }() return data, nil }