Do not allow invalid latency values in metrics

This commit is contained in:
Manuel de Brito Fontes 2018-07-24 10:53:46 -04:00
parent 43aabfc813
commit 010342aa58

View file

@ -236,11 +236,13 @@ func (sc *SocketCollector) handleMessage(msg []byte) {
requestsMetric.Inc()
}
latencyMetric, err := sc.upstreamLatency.GetMetricWith(latencyLabels)
if err != nil {
glog.Errorf("Error fetching latency metric: %v", err)
} else {
latencyMetric.Observe(stats.Latency)
if stats.Latency != -1 {
latencyMetric, err := sc.upstreamLatency.GetMetricWith(latencyLabels)
if err != nil {
glog.Errorf("Error fetching latency metric: %v", err)
} else {
latencyMetric.Observe(stats.Latency)
}
}
if stats.RequestTime != -1 {