Documentation
¶
Index ¶
- type Config
- type Querier
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶
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 ¶ added in v1.0.1
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 ¶ added in v1.0.1
func (q *Querier) LogQueryHandler(w http.ResponseWriter, r *http.Request)
LogQueryHandler is a http.HandlerFunc for log only queries.
func (*Querier) RangeQueryHandler ¶ added in v1.0.1
func (q *Querier) RangeQueryHandler(w http.ResponseWriter, r *http.Request)
RangeQueryHandler is a http.HandlerFunc for range queries.
func (*Querier) ReadinessHandler ¶ added in v1.0.1
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 ¶ added in v1.0.1
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 ¶ added in v1.0.1
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.
Source Files