querier

Documentation

Index

• type Config
  • func (cfg *Config) RegisterFlags(f *flag.FlagSet)
• type Querier
  • func New(cfg Config, clientCfg client.Config, ring ring.ReadRing, store storage.Store, ...) (*Querier, error)
  • func (*Querier) Check(_ context.Context, _ *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)
  • func (q *Querier) InstantQueryHandler(w http.ResponseWriter, r *http.Request)
  • func (q *Querier) Label(ctx context.Context, req *logproto.LabelRequest) (*logproto.LabelResponse, error)
  • func (q *Querier) LabelHandler(w http.ResponseWriter, r *http.Request)
  • func (q *Querier) LogQueryHandler(w http.ResponseWriter, r *http.Request)
  • func (q *Querier) RangeQueryHandler(w http.ResponseWriter, r *http.Request)
  • func (q *Querier) ReadinessHandler(w http.ResponseWriter, r *http.Request)
  • func (q *Querier) Select(ctx context.Context, params logql.SelectParams) (iter.EntryIterator, error)
  • func (q *Querier) Tail(ctx context.Context, req *logproto.TailRequest) (*Tailer, error)
  • func (q *Querier) TailHandler(w http.ResponseWriter, r *http.Request)
• type QueryResponse
• type Tailer

Types

type Config

type Config struct {
	QueryTimeout    time.Duration    `yaml:"query_timeout"`
	TailMaxDuration time.Duration    `yaml:"tail_max_duration"`
	Engine          logql.EngineOpts `yaml:"engine,omitempty"`
}

Config for a querier.

func (*Config) RegisterFlags

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

RegisterFlags register flags.

type Querier

type Querier struct {
	// contains filtered or unexported fields
}

Querier handlers queries.

func New

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

New makes a new Querier.

func (*Querier) Check

func (*Querier) Check(_ context.Context, _ *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)

Check implements the grpc healthcheck

func (*Querier) InstantQueryHandler

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

InstantQueryHandler is a http.HandlerFunc for instant queries.

func (*Querier) Label

func (q *Querier) Label(ctx context.Context, req *logproto.LabelRequest) (*logproto.LabelResponse, error)

Label does the heavy lifting for a Label query.

func (*Querier) LabelHandler

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

LabelHandler is a http.HandlerFunc for handling label queries.

func (*Querier) LogQueryHandler

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

LogQueryHandler is a http.HandlerFunc for log only queries.

func (*Querier) RangeQueryHandler

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

RangeQueryHandler is a http.HandlerFunc for range queries.

func (*Querier) ReadinessHandler

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

ReadinessHandler is used to indicate to k8s when the querier is ready. Returns 200 when the querier is ready, 500 otherwise.

func (*Querier) Select

func (q *Querier) Select(ctx context.Context, params logql.SelectParams) (iter.EntryIterator, error)

Select Implements logql.Querier which select logs via matchers and regex filters.

func (*Querier) Tail

func (q *Querier) Tail(ctx context.Context, req *logproto.TailRequest) (*Tailer, error)

Tail keeps getting matching logs from all ingesters for given query

func (*Querier) TailHandler

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

TailHandler is a http.HandlerFunc for handling tail queries.

type QueryResponse

type QueryResponse struct {
	ResultType promql.ValueType `json:"resultType"`
	Result     promql.Value     `json:"result"`
}

type Tailer

type Tailer struct {
	// contains filtered or unexported fields
}

Tailer manages complete lifecycle of a tail request