querybackend

Apr 20, 2026

Changes in this version

+ func CreateConcurrencyInterceptor(logger log.Logger) (grpc.UnaryServerInterceptor, error)

+ func QueryReportType(q queryv1.QueryType) queryv1.ReportType

+ type BlockReader struct

+ func NewBlockReader(logger log.Logger, storage objstore.Bucket, reg prometheus.Registerer) *BlockReader

+ func (b *BlockReader) Invoke(ctx context.Context, req *queryv1.InvokeRequest) (*queryv1.InvokeResponse, error)

+ type Config struct

+ Address string

+ ClientTimeout time.Duration

+ GRPCClientConfig grpcclient.Config

+ func (cfg *Config) RegisterFlags(f *flag.FlagSet)

+ func (cfg *Config) Validate() error

+ type ProfileEntry struct

+ Fingerprint model.Fingerprint

+ ID string

+ Labels phlaremodel.Labels

+ Partition uint64

+ RowNum int64

+ Timestamp model.Time

+ func (e ProfileEntry) RowNumber() int64

+ type QueryBackend struct

+ func New(config Config, logger log.Logger, reg prometheus.Registerer, ...) (*QueryBackend, error)

+ func (q *QueryBackend) Invoke(ctx context.Context, req *queryv1.InvokeRequest) (*queryv1.InvokeResponse, error)

+ func (q *QueryBackend) Service() services.Service

+ type QueryHandler interface

+ Invoke func(context.Context, *queryv1.InvokeRequest) (*queryv1.InvokeResponse, error)