Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateConcurrencyInterceptor ¶
func CreateConcurrencyInterceptor(logger log.Logger) (grpc.UnaryServerInterceptor, error)
func QueryReportType ¶
func QueryReportType(q queryv1.QueryType) queryv1.ReportType
Types ¶
type BlockReader ¶
type BlockReader struct {
// contains filtered or unexported fields
}
func NewBlockReader ¶
func NewBlockReader(logger log.Logger, storage objstore.Bucket, reg prometheus.Registerer) *BlockReader
func (*BlockReader) Invoke ¶
func (b *BlockReader) Invoke( ctx context.Context, req *queryv1.InvokeRequest, ) (*queryv1.InvokeResponse, error)
type Config ¶
type Config struct {
Address string `yaml:"address"`
GRPCClientConfig grpcclient.Config `` /* 144-byte string literal not displayed */
}
func (*Config) RegisterFlags ¶
type ProfileEntry ¶
type ProfileEntry struct {
RowNum int64
Timestamp model.Time
Fingerprint model.Fingerprint
Labels phlaremodel.Labels
Partition uint64
}
func (ProfileEntry) RowNumber ¶
func (e ProfileEntry) RowNumber() int64
type QueryBackend ¶
type QueryBackend struct {
queryv1.QueryBackendServiceServer
// contains filtered or unexported fields
}
func New ¶
func New( config Config, logger log.Logger, reg prometheus.Registerer, backendClient QueryHandler, blockReader QueryHandler, ) (*QueryBackend, error)
func (*QueryBackend) Invoke ¶
func (q *QueryBackend) Invoke( ctx context.Context, req *queryv1.InvokeRequest, ) (*queryv1.InvokeResponse, error)
func (*QueryBackend) Service ¶
func (q *QueryBackend) Service() services.Service
type QueryHandler ¶
type QueryHandler interface {
Invoke(context.Context, *queryv1.InvokeRequest) (*queryv1.InvokeResponse, error)
}
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.