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