Method LabelNamesStream

pkg/ingester/ingester.go:2009–2042

LabelNamesStream return all the label names.

(req *client.LabelNamesRequest, stream client.Ingester_LabelNamesStreamServer)

// LabelNamesStream return all the label names.
func (i *Ingester) LabelNamesStream(req *client.LabelNamesRequest, stream client.Ingester_LabelNamesStreamServer) (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.LabelNamesResponse
		var cleanup func()
		resp, cleanup, err = i.labelNamesCommon(ctx, req)
		defer cleanup()

		if err != nil {
			return
		}

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

	return err
}

// labelNamesCommon return all the label names.
// this should be used by LabelNames and LabelNamesStream.