The highest tagged major version is
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) SelectLogs(ctx context.Context, params logql.SelectLogParams) (iter.EntryIterator, error)
- func (q *Querier) SelectSamples(ctx context.Context, params logql.SelectSampleParams) (iter.SampleIterator, error)
- func (q *Querier) Series(ctx context.Context, req *logproto.SeriesRequest) (*logproto.SeriesResponse, error)
- func (q *Querier) SeriesHandler(w http.ResponseWriter, r *http.Request)
- 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"`
ExtraQueryDelay time.Duration `yaml:"extra_query_delay,omitempty"`
QueryIngestersWithin time.Duration `yaml:"query_ingesters_within,omitempty"`
IngesterQueryStoreMaxLookback time.Duration `yaml:"-"`
Engine logql.EngineOpts `yaml:"engine,omitempty"`
MaxConcurrent int `yaml:"max_concurrent"`
}
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 v0.4.0
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 v0.4.0
func (q *Querier) LogQueryHandler(w http.ResponseWriter, r *http.Request)
LogQueryHandler is a http.HandlerFunc for log only queries.
func (*Querier) RangeQueryHandler ¶ added in v0.4.0
func (q *Querier) RangeQueryHandler(w http.ResponseWriter, r *http.Request)
RangeQueryHandler is a http.HandlerFunc for range queries.
func (*Querier) SelectLogs ¶ added in v1.6.0
func (q *Querier) SelectLogs(ctx context.Context, params logql.SelectLogParams) (iter.EntryIterator, error)
Select Implements logql.Querier which select logs via matchers and regex filters.
func (*Querier) SelectSamples ¶ added in v1.6.0
func (q *Querier) SelectSamples(ctx context.Context, params logql.SelectSampleParams) (iter.SampleIterator, error)
func (*Querier) Series ¶ added in v1.3.0
func (q *Querier) Series(ctx context.Context, req *logproto.SeriesRequest) (*logproto.SeriesResponse, error)
Series fetches any matching series for a list of matcher sets
func (*Querier) SeriesHandler ¶ added in v1.3.0
func (q *Querier) SeriesHandler(w http.ResponseWriter, r *http.Request)
SeriesHandler returns the list of time series that match a certain label set. See https://prometheus.io/docs/prometheus/latest/querying/api/#finding-series-by-label-matchers
func (*Querier) Tail ¶ added in v0.2.0
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
Directories