Method LabelValuesStream

pkg/ingester/ingester.go:1893–1926

LabelValuesStream returns all label values that are associated with a given label name.

(req *client.LabelValuesRequest, stream client.Ingester_LabelValuesStreamServer)

// LabelValuesStream returns all label values that are associated with a given label name.
func (i *Ingester) LabelValuesStream(req *client.LabelValuesRequest, stream client.Ingester_LabelValuesStreamServer) (err error) {
	defer recoverIngester(i.logger, &err)

	ctx := stream.Context()
	userID, userErr := users.TenantID(ctx)
	if userErr != nil {
		return userErr
	}

	// Set pprof labels for profiling
	pprof.Do(ctx, pprof.Labels("user", userID), func(ctx context.Context) {
		var resp *client.LabelValuesResponse
		var cleanup func()
		resp, cleanup, err = i.labelsValuesCommon(ctx, req)
		defer cleanup()

		if err != nil {
			return
		}

		for i := 0; i < len(resp.LabelValues); i += metadataStreamBatchSize {
			j := min(i+metadataStreamBatchSize, len(resp.LabelValues))
			resp := &client.LabelValuesStreamResponse{
				LabelValues: resp.LabelValues[i:j],
			}
			err = client.SendLabelValuesStream(stream, resp)
			if err != nil {
				return
			}
		}
	})

	return err
}

// labelsValuesCommon returns all label values that are associated with a given label name.
// this should be used by LabelValues and LabelValuesStream