querier

Documentation

Index

• Constants
• type Config
  • func (cfg *Config) RegisterFlagsAndApplyDefaults(prefix string, f *flag.FlagSet)
• type Querier
  • func New(cfg Config, clientCfg ingester_client.Config, ring ring.ReadRing, ...) (*Querier, error)
  • func (q *Querier) CreateAndRegisterWorker(tracesHandler http.Handler) error
  • func (q *Querier) FindTraceByID(ctx context.Context, req *tempopb.TraceByIDRequest) (*tempopb.TraceByIDResponse, error)
  • func (q *Querier) RegisterSubservices(s ...services.Service) error
  • func (q *Querier) TraceByIDHandler(w http.ResponseWriter, r *http.Request)

Constants

const (
	BlockStartKey = "blockStart"
	BlockEndKey   = "blockEnd"
	QueryModeKey  = "mode"

	QueryModeIngesters = "ingesters"
	QueryModeBlocks    = "blocks"
	QueryModeAll       = "all"
)

Types

type Config

type Config struct {
	QueryTimeout         time.Duration        `yaml:"query_timeout"`
	ExtraQueryDelay      time.Duration        `yaml:"extra_query_delay,omitempty"`
	MaxConcurrentQueries int                  `yaml:"max_concurrent_queries"`
	Worker               cortex_worker.Config `yaml:"frontend_worker"`
}

Config for a querier.

func (*Config) RegisterFlagsAndApplyDefaults

func (cfg *Config) RegisterFlagsAndApplyDefaults(prefix string, f *flag.FlagSet)

RegisterFlagsAndApplyDefaults register flags.

type Querier

type Querier struct {
	services.Service
	// contains filtered or unexported fields
}

Querier handlers queries.

func New

func New(cfg Config, clientCfg ingester_client.Config, ring ring.ReadRing, store storage.Store, limits *overrides.Overrides) (*Querier, error)

New makes a new Querier.

func (*Querier) CreateAndRegisterWorker

func (q *Querier) CreateAndRegisterWorker(tracesHandler http.Handler) error

func (*Querier) FindTraceByID

func (q *Querier) FindTraceByID(ctx context.Context, req *tempopb.TraceByIDRequest) (*tempopb.TraceByIDResponse, error)

FindTraceByID implements tempopb.Querier.

func (*Querier) RegisterSubservices

func (q *Querier) RegisterSubservices(s ...services.Service) error

func (*Querier) TraceByIDHandler

func (q *Querier) TraceByIDHandler(w http.ResponseWriter, r *http.Request)

TraceByIDHandler is a http.HandlerFunc to retrieve traces