diff --git a/pkg/metrics/envoy.go b/pkg/metrics/envoy.go index b4487df3..5373f532 100644 --- a/pkg/metrics/envoy.go +++ b/pkg/metrics/envoy.go @@ -114,6 +114,6 @@ func (c *Observer) GetEnvoyRequestDuration(name string, namespace string, metric if rate == nil { return 0, fmt.Errorf("no values found for metric %s", metric) } - ms := time.Duration(int64(*rate*1000)) * time.Millisecond + ms := time.Duration(int64(*rate)) * time.Millisecond return ms, nil } diff --git a/pkg/metrics/observer_test.go b/pkg/metrics/observer_test.go index dab4cd52..fcd12eb4 100644 --- a/pkg/metrics/observer_test.go +++ b/pkg/metrics/observer_test.go @@ -29,7 +29,7 @@ func TestCanaryObserver_GetEnvoySuccessRate(t *testing.T) { func TestCanaryObserver_GetEnvoyRequestDuration(t *testing.T) { ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { - json := `{"status":"success","data":{"resultType":"vector","result":[{"metric":{},"value":[1545905245.596,"0.2"]}]}}` + json := `{"status":"success","data":{"resultType":"vector","result":[{"metric":{},"value":[1545905245.596,"200"]}]}}` w.Write([]byte(json)) })) defer ts.Close()