querier

README

Querier

The querier is responsible for handling requests to load data. These services are not addressed directly instead each instance will connect to the frontend services and poll for queries. Each query is then executed and the response encoded and returned to the front end.

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) FindSnapshotByID(ctx context.Context, req *deeppb.SnapshotByIDRequest, timeStart int64, ...) (*deeppb.SnapshotByIDResponse, error)
  • func (q *Querier) RegisterSubservices(s ...services.Service) error
  • func (q *Querier) SearchBlock(ctx context.Context, req *deeppb.SearchBlockRequest) (*deeppb.SearchResponse, error)
  • func (q *Querier) SearchHandler(w http.ResponseWriter, r *http.Request)
  • func (q *Querier) SearchRecent(ctx context.Context, req *deeppb.SearchRequest) (*deeppb.SearchResponse, error)
  • func (q *Querier) SearchTagValues(ctx context.Context, req *deeppb.SearchTagValuesRequest) (*deeppb.SearchTagValuesResponse, error)
  • func (q *Querier) SearchTagValuesHandler(w http.ResponseWriter, r *http.Request)
  • func (q *Querier) SearchTagValuesV2(ctx context.Context, req *deeppb.SearchTagValuesRequest) (*deeppb.SearchTagValuesV2Response, error)
  • func (q *Querier) SearchTagValuesV2Handler(w http.ResponseWriter, r *http.Request)
  • func (q *Querier) SearchTags(ctx context.Context, req *deeppb.SearchTagsRequest) (*deeppb.SearchTagsResponse, error)
  • func (q *Querier) SearchTagsHandler(w http.ResponseWriter, r *http.Request)
  • func (q *Querier) SnapshotByIdHandler(w http.ResponseWriter, r *http.Request)
• type SearchConfig
• type SnapshotByIDConfig

Constants

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

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

Types

type Config

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

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

func (q *Querier) FindSnapshotByID(ctx context.Context, req *deeppb.SnapshotByIDRequest, timeStart int64, timeEnd int64) (*deeppb.SnapshotByIDResponse, error)

func (*Querier) RegisterSubservices

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

func (*Querier) SearchBlock

func (q *Querier) SearchBlock(ctx context.Context, req *deeppb.SearchBlockRequest) (*deeppb.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 *deeppb.SearchRequest) (*deeppb.SearchResponse, error)

func (*Querier) SearchTagValues

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

func (*Querier) SearchTagValuesHandler

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

func (*Querier) SearchTagValuesV2

func (q *Querier) SearchTagValuesV2(ctx context.Context, req *deeppb.SearchTagValuesRequest) (*deeppb.SearchTagValuesV2Response, error)

func (*Querier) SearchTagValuesV2Handler

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

func (*Querier) SearchTags

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

func (*Querier) SearchTagsHandler

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

func (*Querier) SnapshotByIdHandler

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

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"`
}

type SnapshotByIDConfig

type SnapshotByIDConfig struct {
	QueryTimeout time.Duration `yaml:"query_timeout"`
}