Method running

modules/generator/generator.go:148–155

(ctx context.Context)

}

func (g *Generator) running(ctx context.Context) error {
	if g.cfg.ConsumeFromKafka {
		g.startKafka()
	}

	<-ctx.Done()
	return nil
}

func (g *Generator) stopping(_ error) error {
	g.stopIncomingRequests()