in recorders/statistics.go [30:43]
func NewStatisticsRecorder(statistics *Statistics) bender.Recorder {
return func(msg interface{}) {
switch msg := msg.(type) {
case *bender.StartEvent:
statistics.Reset()
case *bender.EndRequestEvent:
atomic.AddInt64(&statistics.Requests, 1)
if msg.Err != nil {
atomic.AddInt64(&statistics.Errors, 1)
}
}
}
}