func()

in util/common/traces/otlp/generator.go [36:54]


func (g *OtlpTracesGenerator) StartSendingTraces(ctx context.Context) error {
	client, shutdown, err := setupClient(ctx)
	if err != nil {
		return err
	}
	defer shutdown(ctx)
	ticker := time.NewTicker(g.Cfg.Interval)
	for {
		select {
		case <-g.Done:
			ticker.Stop()
			return client.ForceFlush(ctx)
		case <-ticker.C:
			if err = g.Generate(ctx); err != nil {
				return err
			}
		}
	}
}