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(handler http.Handler) error
  • func (q *Querier) FindTraceByID(ctx context.Context, req *tempopb.TraceByIDRequest, timeStart int64, ...) (*tempopb.TraceByIDResponse, error)
  • func (q *Querier) RegisterSubservices(s ...services.Service) error
  • func (q *Querier) SearchBlock(ctx context.Context, req *tempopb.SearchBlockRequest) (*tempopb.SearchResponse, error)
  • func (q *Querier) SearchHandler(w http.ResponseWriter, r *http.Request)
  • func (q *Querier) SearchRecent(ctx context.Context, req *tempopb.SearchRequest) (*tempopb.SearchResponse, error)
  • func (q *Querier) SearchTagValues(ctx context.Context, req *tempopb.SearchTagValuesRequest) (*tempopb.SearchTagValuesResponse, error)
  • func (q *Querier) SearchTagValuesHandler(w http.ResponseWriter, r *http.Request)
  • func (q *Querier) SearchTags(ctx context.Context, req *tempopb.SearchTagsRequest) (*tempopb.SearchTagsResponse, error)
  • func (q *Querier) SearchTagsHandler(w http.ResponseWriter, r *http.Request)
  • func (q *Querier) TraceByIDHandler(w http.ResponseWriter, r *http.Request)
• type SearchConfig

Constants

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

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

Types

type Config

type Config struct {
	Search SearchConfig `yaml:"search"`

	TraceLookupQueryTimeout time.Duration `yaml:"query_timeout"`
	ExtraQueryDelay         time.Duration `yaml:"extra_query_delay,omitempty"`
	MaxConcurrentQueries    int           `yaml:"max_concurrent_queries"`
	Worker                  worker.Config `yaml:"frontend_worker"`
	QueryRelevantIngesters  bool          `yaml:"query_relevant_ingesters"`
}

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(handler http.Handler) error

func (*Querier) FindTraceByID

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

FindTraceByID implements tempopb.Querier.

func (*Querier) RegisterSubservices

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

func (*Querier) SearchBlock

func (q *Querier) SearchBlock(ctx context.Context, req *tempopb.SearchBlockRequest) (*tempopb.SearchResponse, error)

SearchBlock searches the specified subset of the block for the passed tags.

func (*Querier) SearchHandler

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

func (*Querier) SearchRecent

func (q *Querier) SearchRecent(ctx context.Context, req *tempopb.SearchRequest) (*tempopb.SearchResponse, error)

func (*Querier) SearchTagValues

func (q *Querier) SearchTagValues(ctx context.Context, req *tempopb.SearchTagValuesRequest) (*tempopb.SearchTagValuesResponse, error)

func (*Querier) SearchTagValuesHandler

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

func (*Querier) SearchTags

func (q *Querier) SearchTags(ctx context.Context, req *tempopb.SearchTagsRequest) (*tempopb.SearchTagsResponse, error)

func (*Querier) SearchTagsHandler

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

func (*Querier) TraceByIDHandler

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

TraceByIDHandler is a http.HandlerFunc to retrieve traces

type SearchConfig

type SearchConfig struct {
	QueryTimeout      time.Duration `yaml:"query_timeout"`
	PreferSelf        int           `yaml:"prefer_self"`
	ExternalEndpoints []string      `yaml:"external_endpoints"`
	HedgeRequestsAt   time.Duration `yaml:"external_hedge_requests_at"`
	HedgeRequestsUpTo int           `yaml:"external_hedge_requests_up_to"`
}