func()

in pkg/runner/runner.go [89:114]

• 25 lines of code
• 8 McCabe index (conditional complexity)

func (r *Runner) Execute() error {
	var ticker *time.Ticker = nil
	if r.config.Interval > 0 {
		ticker = time.NewTicker(r.config.Interval)
	}

	for ; true; <-ticker.C {
		for i := 0; i < r.config.Records; i++ {
			b, err := r.generator.Next()
			if err != nil {
				return err
			}
			_, err = r.output.Write(b)
			if err != nil {
				return err
			}
		}
		if r.config.Interval == 0 {
			break
		}
		if err := r.output.NewInterval(); err != nil {
			return err
		}
	}
	return r.output.Close()
}