queryfrontend

package

v2.3.0 Latest Latest Go to latest Published: Aug 24, 2026 License: AGPL-3.0 Imports: 48 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 DiagnosticsStore
type QueryBackend
type QueryFrontend
- func NewQueryFrontend(logger log.Logger, limits frontend.Limits, cfg frontend.Config, ...) *QueryFrontend
type Symbolizer

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type DiagnosticsStore ¶

type DiagnosticsStore interface {
	// Add stores diagnostics in memory for later flushing.
	Add(id string, diag *queryv1.Diagnostics)
}

DiagnosticsStore provides the ability to store query diagnostics.

type QueryBackend ¶

type QueryBackend interface {
	Invoke(ctx context.Context, req *queryv1.InvokeRequest) (*queryv1.InvokeResponse, error)
}

type QueryFrontend ¶

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

func NewQueryFrontend ¶

func NewQueryFrontend(
	logger log.Logger,
	limits frontend.Limits,
	cfg frontend.Config,
	metadataQueryClient metastorev1.MetadataQueryServiceClient,
	tenantServiceClient metastorev1.TenantServiceClient,
	querybackendClient QueryBackend,
	sym Symbolizer,
	diagnosticsStore DiagnosticsStore,
	reg prometheus.Registerer,
) *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) QueryMetadata ¶

func (q *QueryFrontend) QueryMetadata(
	ctx context.Context,
	req *queryv1.QueryRequest,
) (blocks []*metastorev1.BlockMeta, err error)

func (*QueryFrontend) SelectHeatmap ¶

func (q *QueryFrontend) SelectHeatmap(
	ctx context.Context,
	c *connect.Request[querierv1.SelectHeatmapRequest],
) (*connect.Response[querierv1.SelectHeatmapResponse], 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)

type Symbolizer ¶

type Symbolizer interface {
	SymbolizePprof(ctx context.Context, profile *googlev1.Profile) error
	Resolve(ctx context.Context, buildID, binaryName string, addrs []uint64) ([][]lidia.SourceInfoFrame, error)
	// ResolveConcurrency is the maximum number of concurrent Resolve calls
	// the symbolizer allows.
	ResolveConcurrency() int
	// ResolveTimeout bounds resolving a single binary's unresolved
	// addresses.
	ResolveTimeout() time.Duration
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
diagnostics

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