Function isDrained

tests/loadtest/tools/queue_benchmark.go:339–341

(s snapshot)

}

func isDrained(s snapshot) bool {
	return !hasWork(s)
}

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