func NewStatisticsRecorder()

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)
			}
		}
	}
}