Method UsageTrackerHandler

modules/distributor/distributor.go:584–590

()

}

func (d *Distributor) UsageTrackerHandler() http.Handler {
	if d.usage != nil {
		return d.usage.Handler()
	}

	return nil
}

func (d *Distributor) sendToKafka(ctx context.Context, userID string, keys []uint32, traces []*rebatchedTrace, skipMetricsGeneration bool) error {
	marshalledTraces := make([][]byte, len(traces))