query_frontend

package

v1.11.0 Latest Latest Go to latest Published: Dec 19, 2024 License: AGPL-3.0 Imports: 28 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/grafana/pyroscope

Links

Open Source Insights

Documentation ¶

Index ¶

type QueryFrontend
- func NewQueryFrontend(logger log.Logger, limits frontend.Limits, ...) *QueryFrontend

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type QueryFrontend ¶

type QueryFrontend struct {
	// contains filtered or unexported fields
}

func NewQueryFrontend ¶

func NewQueryFrontend(
	logger log.Logger,
	limits frontend.Limits,
	metadataQueryClient metastorev1.MetadataQueryServiceClient,
	tenantServiceClient metastorev1.TenantServiceClient,
	querybackendClient *querybackendclient.Client,
) *QueryFrontend

func (*QueryFrontend) AnalyzeQuery ¶

func (q *QueryFrontend) AnalyzeQuery(
	context.Context,
	*connect.Request[querierv1.AnalyzeQueryRequest],
) (*connect.Response[querierv1.AnalyzeQueryResponse], error)

func (*QueryFrontend) Diff ¶

func (q *QueryFrontend) Diff(
	ctx context.Context,
	c *connect.Request[querierv1.DiffRequest],
) (*connect.Response[querierv1.DiffResponse], error)

func (*QueryFrontend) GetProfileStats ¶

func (q *QueryFrontend) GetProfileStats(
	ctx context.Context,
	_ *connect.Request[typesv1.GetProfileStatsRequest],
) (*connect.Response[typesv1.GetProfileStatsResponse], error)

func (*QueryFrontend) LabelNames ¶

func (q *QueryFrontend) LabelNames(
	ctx context.Context,
	c *connect.Request[typesv1.LabelNamesRequest],
) (*connect.Response[typesv1.LabelNamesResponse], error)

func (*QueryFrontend) LabelValues ¶

func (q *QueryFrontend) LabelValues(
	ctx context.Context,
	c *connect.Request[typesv1.LabelValuesRequest],
) (*connect.Response[typesv1.LabelValuesResponse], error)

func (*QueryFrontend) ProfileTypes ¶

func (q *QueryFrontend) ProfileTypes(
	ctx context.Context,
	req *connect.Request[querierv1.ProfileTypesRequest],
) (*connect.Response[querierv1.ProfileTypesResponse], error)

func (*QueryFrontend) Query ¶

func (q *QueryFrontend) Query(
	ctx context.Context,
	req *queryv1.QueryRequest,
) (*queryv1.QueryResponse, error)

func (*QueryFrontend) SelectMergeProfile ¶

func (q *QueryFrontend) SelectMergeProfile(
	ctx context.Context,
	c *connect.Request[querierv1.SelectMergeProfileRequest],
) (*connect.Response[profilev1.Profile], error)

func (*QueryFrontend) SelectMergeSpanProfile ¶

func (q *QueryFrontend) SelectMergeSpanProfile(
	ctx context.Context,
	c *connect.Request[querierv1.SelectMergeSpanProfileRequest],
) (*connect.Response[querierv1.SelectMergeSpanProfileResponse], error)

func (*QueryFrontend) SelectMergeStacktraces ¶

func (q *QueryFrontend) SelectMergeStacktraces(
	ctx context.Context,
	c *connect.Request[querierv1.SelectMergeStacktracesRequest],
) (*connect.Response[querierv1.SelectMergeStacktracesResponse], error)

func (*QueryFrontend) SelectSeries ¶

func (q *QueryFrontend) SelectSeries(
	ctx context.Context,
	c *connect.Request[querierv1.SelectSeriesRequest],
) (*connect.Response[querierv1.SelectSeriesResponse], error)

func (*QueryFrontend) Series ¶

func (q *QueryFrontend) Series(
	ctx context.Context,
	c *connect.Request[querierv1.SeriesRequest],
) (*connect.Response[querierv1.SeriesResponse], error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL