Function buildSummary

tests/loadtest/tools/queue_benchmark.go:343–521

(cfg benchmarkConfig, start, end snapshot, samples []snapshot)

}

func buildSummary(cfg benchmarkConfig, start, end snapshot, samples []snapshot) map[string]interface{} {
	durationMs := end.timestamp.Sub(start.timestamp).Seconds() * 1000
	if durationMs < 0 {
		durationMs = 0
	}

	processed := maxInt(0, end.processedTotal-start.processedTotal)
	failed := maxInt(0, end.failedTotal-start.failedTotal)
	successes := maxInt(0, processed-failed)
	failRate := rate(failed, processed)
	requestRate := counterRate(processed, durationMs)
	latencySeries := collectLatencySeries(samples)
	latencyStats := trendStats(latencySeries)
	queueSizeStats := trendStats(collectIntSeries(samples, func(s snapshot) int { return s.size }))
	queueDepthStats := trendStats(collectIntSeries(samples, func(s snapshot) int {
		return s.pending + s.active + s.scheduled + s.retry + s.aggregating
	}))
	drained := isDrained(end)

	metrics := map[string]interface{}{
		fmt.Sprintf("http_req_failed{scenario:%s}", cfg.label): metric{
			Type:     "rate",
			Contains: "default",
			Values: map[string]interface{}{
				"rate":   failRate,
				"passes": float64(successes),
				"fails":  float64(failed),
			},
			Thresholds: map[string]interface{}{
				"rate<0.001": map[string]interface{}{"ok": failRate < 0.001},
			},
		},
		"http_req_failed": metric{
			Type:     "rate",
			Contains: "default",
			Values: map[string]interface{}{
				"rate":   failRate,
				"passes": float64(successes),
				"fails":  float64(failed),
			},
		},
		"http_req_duration": metric{
			Type:     "trend",
			Contains: "time",
			Values:   latencyStats,
		},
		"http_req_duration{expected_response:true}": metric{
			Type:     "trend",
			Contains: "time",
			Values:   latencyStats,
		},
		fmt.Sprintf("http_req_duration{scenario:%s,expected_response:true}", cfg.label): metric{
			Type:     "trend",
			Contains: "time",
			Values:   latencyStats,
		},
		"http_reqs": metric{
			Type:     "counter",