Method pushTracesKafka

modules/distributor/distributor.go:511–514

(ctx context.Context, userID string, keys []uint32, traces []*rebatchedTrace)

}

func (d *Distributor) pushTracesKafka(ctx context.Context, userID string, keys []uint32, traces []*rebatchedTrace) error {
	skipMetricsGeneration := generator.ExtractNoGenerateMetrics(ctx)
	return d.sendToKafka(ctx, userID, keys, traces, skipMetricsGeneration)
}

func (d *Distributor) pushLocal(ctx context.Context, userID string, keys []uint32, traces []*rebatchedTrace) error {
	if err := d.pushTracesToLiveStore(ctx, userID, traces); err != nil {