in worker.go [159:174]
func (w *worker) reportCSV(em map[string]config.Endpoint) {
w.inputs = make(chan input, concurrency)
w.outputs = make(chan output, w.size(em, region))
for i := 0; i < number; i++ {
for r, e := range em {
w.inputs <- input{region: r, endpoint: e.URL}
}
}
close(w.inputs)
sorted := w.sortOutput(em)
fmt.Println("region,latency_ns,errors")
for _, a := range sorted {
fmt.Printf("%v,%v,%v\n", a.region, a.median().Nanoseconds(), a.errors)
}
}