query_backend

Documentation

Index

• func CreateConcurrencyInterceptor(logger log.Logger) (grpc.UnaryServerInterceptor, error)
• func QueryReportType(q queryv1.QueryType) queryv1.ReportType
• type BlockReader
  • func NewBlockReader(logger log.Logger, storage objstore.Bucket) *BlockReader
  • func (b *BlockReader) Invoke(ctx context.Context, req *queryv1.InvokeRequest) (*queryv1.InvokeResponse, error)
• type Config
  • func (cfg *Config) RegisterFlags(f *flag.FlagSet)
  • func (cfg *Config) Validate() error
• type ProfileEntry
  • func (e ProfileEntry) RowNumber() int64
• type QueryBackend
  • 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

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) *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

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

func (*Config) Validate

func (cfg *Config) Validate() error

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)
}