github/flagger
1
0
Fork 0
mirror of https://github.com/fluxcd/flagger.git synced 2026-08-29 02:37:31 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add Envoy success rate test

Browse Source
This commit is contained in:
stefanprodan
2019-03-31 14:17:39 +03:00
parent f211e0fe31
commit ec759ce467
1 changed files with 23 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/metrics/observer_test.go
+23 -7
View File
@@ -7,17 +7,35 @@ import (
"time"
)
func TestCanaryObserver_GetDeploymentCounter(t *testing.T) {
func TestCanaryObserver_GetEnvoySuccessRate(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.458,"100"]}]}}`
w.Write([]byte(json))
}))
defer ts.Close()
observer := Observer{
metricsServer: ts.URL,
observer := NewObserver(ts.URL)
val, err := observer.GetEnvoySuccessRate("podinfo", "default", "envoy_cluster_upstream_rq", "1m")
if err != nil {
t.Fatal(err.Error())
}
if val != 100 {
t.Errorf("Got %v wanted %v", val, 100)
}
}
func TestCanaryObserver_GetIstioSuccessRate(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.458,"100"]}]}}`
w.Write([]byte(json))
}))
defer ts.Close()
observer := NewObserver(ts.URL)
val, err := observer.GetIstioSuccessRate("podinfo", "default", "istio_requests_total", "1m")
if err != nil {
t.Fatal(err.Error())
@@ -29,16 +47,14 @@ func TestCanaryObserver_GetDeploymentCounter(t *testing.T) {
}
func TestCanaryObserver_GetDeploymentHistogram(t *testing.T) {
func TestCanaryObserver_GetIstioRequestDuration(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"]}]}}`
w.Write([]byte(json))
}))
defer ts.Close()
observer := Observer{
metricsServer: ts.URL,
}
observer := NewObserver(ts.URL)
val, err := observer.GetIstioRequestDuration("podinfo", "default", "istio_request_duration_seconds_bucket", "1m")
if err != nil {