metrics for latency

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()
+	go func() {
 		remoteCartLatency.Add(float64(elapsed))
 		remoteCartCallsTotal.Inc()
+	}()
 	return data, nil
 }