senaduka/old-vegeta
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Duration on Metrics and depenendent Reporters

Browse Source 
This is real duration, calculated by subtracting the last Result's
timestamp with the first Result's timestamp. Garbage
collection and go routine scheduling delays can affect this number.
Fixes #29
This commit is contained in:
Tomás Senart
2013-10-29 13:48:37 +01:00
parent ae8650d641
commit a9657e2660
4 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
README.md
View File

@@ -118,6 +118,7 @@ Specifies the kind of report to be generated. It defaults to text.
##### text ##### text
``` ```
Requests [total] 1200 Requests [total] 1200
Duration [total] 1.998307684s
Latencies [mean, 95, 99, max] 223.340085ms, 326.913687ms, 416.537743ms, 7.788103259s Latencies [mean, 95, 99, max] 223.340085ms, 326.913687ms, 416.537743ms, 7.788103259s
Bytes In [total, mean] 3714690, 3095.57 Bytes In [total, mean] 3714690, 3095.57
Bytes Out [total, mean] 0, 0.00 Bytes Out [total, mean] 0, 0.00
@@ -149,6 +150,7 @@ Get http://localhost:6060: http: can't write HTTP request on broken connection
"total": 0, "total": 0,
"mean": 0 "mean": 0
}, },
"duration": 1998307684,
"requests": 1200, "requests": 1200,
"success": 0.11666666666666667, "success": 0.11666666666666667,
"status_codes": { "status_codes": {

2
lib/metrics.go
View File

@@ -27,6 +27,7 @@ type Metrics struct {
Mean float64 `json:"mean"` Mean float64 `json:"mean"`
} `json:"bytes_out"` } `json:"bytes_out"`
Duration time.Duration `json:"duration"`
Requests uint64 `json:"requests"` Requests uint64 `json:"requests"`
Success float64 `json:"success"` Success float64 `json:"success"`
StatusCodes map[string]int `json:"status_codes"` StatusCodes map[string]int `json:"status_codes"`
@@ -60,6 +61,7 @@ func NewMetrics(results []Result) *Metrics {
} }
} }
m.Duration = results[len(results)-1].Timestamp.Sub(results[0].Timestamp)
m.Latencies.Mean = time.Duration(float64(totalLatencies) / float64(m.Requests)) m.Latencies.Mean = time.Duration(float64(totalLatencies) / float64(m.Requests))
m.Latencies.P95 = time.Duration(quants.Query(0.95)) m.Latencies.P95 = time.Duration(quants.Query(0.95))
m.Latencies.P99 = time.Duration(quants.Query(0.99)) m.Latencies.P99 = time.Duration(quants.Query(0.99))

7
lib/metrics_test.go
View File

@@ -7,9 +7,9 @@ import (
func TestNewMetrics(t *testing.T) { func TestNewMetrics(t *testing.T) {
m := NewMetrics([]Result{ m := NewMetrics([]Result{
Result{500, time.Now(), 100 * time.Millisecond, 10, 30, "Internal server error"}, Result{500, time.Unix(0, 0), 100 * time.Millisecond, 10, 30, "Internal server error"},
Result{200, time.Now(), 20 * time.Millisecond, 20, 20, ""}, Result{200, time.Unix(1, 0), 20 * time.Millisecond, 20, 20, ""},
Result{200, time.Now(), 30 * time.Millisecond, 30, 10, ""}, Result{200, time.Unix(2, 0), 30 * time.Millisecond, 30, 10, ""},
}) })
for field, values := range map[string][]float64{ for field, values := range map[string][]float64{
@@ -27,6 +27,7 @@ func TestNewMetrics(t *testing.T) {
"Latencies.Mean": []time.Duration{m.Latencies.Mean, 50 * time.Millisecond}, "Latencies.Mean": []time.Duration{m.Latencies.Mean, 50 * time.Millisecond},
"Latencies.P95": []time.Duration{m.Latencies.P95, 30 * time.Millisecond}, "Latencies.P95": []time.Duration{m.Latencies.P95, 30 * time.Millisecond},
"Latencies.P99": []time.Duration{m.Latencies.P99, 30 * time.Millisecond}, "Latencies.P99": []time.Duration{m.Latencies.P99, 30 * time.Millisecond},
"Duration": []time.Duration{m.Duration, 2 * time.Second},
} { } {
if values[0] != values[1] { if values[0] != values[1] {
t.Errorf("%s: want: %s, got: %s", field, values[1], values[0]) t.Errorf("%s: want: %s, got: %s", field, values[1], values[0])

1
lib/reporters.go
View File

@@ -19,6 +19,7 @@ func ReportText(results []Result) ([]byte, error) {
w := tabwriter.NewWriter(out, 0, 8, 2, '\t', tabwriter.StripEscape) w := tabwriter.NewWriter(out, 0, 8, 2, '\t', tabwriter.StripEscape)
fmt.Fprintf(w, "Requests\t[total]\t%d\n", m.Requests) fmt.Fprintf(w, "Requests\t[total]\t%d\n", m.Requests)
fmt.Fprintf(w, "Duration\t[total]\t%s\n", m.Duration)
fmt.Fprintf(w, "Latencies\t[mean, 95, 99, max]\t%s, %s, %s, %s\n", fmt.Fprintf(w, "Latencies\t[mean, 95, 99, max]\t%s, %s, %s, %s\n",
m.Latencies.Mean, m.Latencies.P95, m.Latencies.P99, m.Latencies.Max) m.Latencies.Mean, m.Latencies.P95, m.Latencies.P99, m.Latencies.Max)
fmt.Fprintf(w, "Bytes In\t[total, mean]\t%d, %.2f\n", m.BytesIn.Total, m.BytesIn.Mean) fmt.Fprintf(w, "Bytes In\t[total, mean]\t%d, %.2f\n", m.BytesIn.Total, m.BytesIn.Mean)