in worker.go [137:157]
func (w *worker) reportAll(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)
tr := tabwriter.NewWriter(os.Stdout, 3, 2, 2, ' ', 0)
for i, a := range sorted {
fmt.Fprintf(tr, "%2d.\t[%v]\t%v", i+1, a.region, a.median())
if a.errors > 0 {
fmt.Fprintf(tr, "\t(%d errors)", a.errors)
}
fmt.Fprintln(tr)
}
tr.Flush()
}