func Start()

in app/eventgen/generator/generator.go [98:112]

• 14 lines of code
• 3 McCabe index (conditional complexity)

func Start(event publishers.NewMessage, numPublishers int, timeout time.Duration) error {
	mux.Lock()
	defer mux.Unlock()

	if running != nil {
		return errors.New("there is already an running generator")
	}
	g, err := newGenerator(config.Config.EventTopic, config.Config.EventCodec, config.Config.PublisherBatchSize, config.Config.PublisherNumGoroutines, config.Config.PublisherMaxOutstanding)
	if err != nil {
		return err
	}
	g.Run(event, numPublishers, timeout)
	running = g
	return nil
}