Versions in this module Expand all Collapse all v3 v3.0.0 Apr 8, 2024 Changes in this version + func DefaultLimitsConfig() validation.Limits + func InitWorkerService(logger log.Logger, cfg WorkerServiceConfig, reg prometheus.Registerer, ...) (serve services.Service, err error) + func NewQuerierHTTPHandler(h *Handler) http.Handler + func WrapQuerySpanAndTimeout(call string, limits Limits) middleware.Interface + type Config struct + Engine logql.EngineOpts + ExtraQueryDelay time.Duration + IngesterQueryStoreMaxLookback time.Duration + MaxConcurrent int + MultiTenantQueriesEnabled bool + PerRequestLimitsEnabled bool + QueryIngesterOnly bool + QueryIngestersWithin time.Duration + QueryStoreOnly bool + TailMaxDuration time.Duration + func (cfg *Config) RegisterFlags(f *flag.FlagSet) + func (cfg *Config) Validate() error + type Engine interface + Query func(logql.Params) logql.Query + type Handler struct + func NewQuerierHandler(api *QuerierAPI) *Handler + func (h *Handler) Do(ctx context.Context, req queryrangebase.Request) (queryrangebase.Response, error) + type IngesterQuerier struct + func NewIngesterQuerier(clientCfg client.Config, ring ring.ReadRing, extraQueryDelay time.Duration, ...) (*IngesterQuerier, error) + func (q *IngesterQuerier) DetectedLabel(ctx context.Context, req *logproto.DetectedLabelsRequest) (*logproto.LabelToValuesResponse, error) + func (q *IngesterQuerier) GetChunkIDs(ctx context.Context, from, through model.Time, matchers ...*labels.Matcher) ([]string, error) + func (q *IngesterQuerier) Label(ctx context.Context, req *logproto.LabelRequest) ([][]string, error) + func (q *IngesterQuerier) SelectLogs(ctx context.Context, params logql.SelectLogParams) ([]iter.EntryIterator, error) + func (q *IngesterQuerier) SelectSample(ctx context.Context, params logql.SelectSampleParams) ([]iter.SampleIterator, error) + func (q *IngesterQuerier) Series(ctx context.Context, req *logproto.SeriesRequest) ([][]logproto.SeriesIdentifier, error) + func (q *IngesterQuerier) Stats(ctx context.Context, _ string, from, through model.Time, ...) (*index_stats.Stats, error) + func (q *IngesterQuerier) Tail(ctx context.Context, req *logproto.TailRequest) (map[string]logproto.Querier_TailClient, error) + func (q *IngesterQuerier) TailDisconnectedIngesters(ctx context.Context, req *logproto.TailRequest, ...) (map[string]logproto.Querier_TailClient, error) + func (q *IngesterQuerier) TailersCount(ctx context.Context) ([]uint32, error) + func (q *IngesterQuerier) Volume(ctx context.Context, _ string, from, through model.Time, limit int32, ...) (*logproto.VolumeResponse, error) + type Limits querier_limits.Limits + type Metrics struct + func NewMetrics(r prometheus.Registerer) *Metrics + type MultiTenantQuerier struct + func NewMultiTenantQuerier(querier Querier, logger log.Logger) *MultiTenantQuerier + func (q *MultiTenantQuerier) DetectedFields(ctx context.Context, req *logproto.DetectedFieldsRequest) (*logproto.DetectedFieldsResponse, error) + func (q *MultiTenantQuerier) DetectedLabels(ctx context.Context, req *logproto.DetectedLabelsRequest) (*logproto.DetectedLabelsResponse, error) + func (q *MultiTenantQuerier) IndexShards(ctx context.Context, req *loghttp.RangeQuery, targetBytesPerShard uint64) (*logproto.ShardsResponse, error) + func (q *MultiTenantQuerier) IndexStats(ctx context.Context, req *loghttp.RangeQuery) (*stats.Stats, error) + func (q *MultiTenantQuerier) Label(ctx context.Context, req *logproto.LabelRequest) (*logproto.LabelResponse, error) + func (q *MultiTenantQuerier) SelectLogs(ctx context.Context, params logql.SelectLogParams) (iter.EntryIterator, error) + func (q *MultiTenantQuerier) SelectSamples(ctx context.Context, params logql.SelectSampleParams) (iter.SampleIterator, error) + func (q *MultiTenantQuerier) Series(ctx context.Context, req *logproto.SeriesRequest) (*logproto.SeriesResponse, error) + func (q *MultiTenantQuerier) Volume(ctx context.Context, req *logproto.VolumeRequest) (*logproto.VolumeResponse, error) + type PatterQuerier interface + Patterns func(ctx context.Context, req *logproto.QueryPatternsRequest) (*logproto.QueryPatternsResponse, error) + type Querier interface + DetectedFields func(ctx context.Context, req *logproto.DetectedFieldsRequest) (*logproto.DetectedFieldsResponse, error) + DetectedLabels func(ctx context.Context, req *logproto.DetectedLabelsRequest) (*logproto.DetectedLabelsResponse, error) + IndexShards func(ctx context.Context, req *loghttp.RangeQuery, targetBytesPerShard uint64) (*logproto.ShardsResponse, error) + IndexStats func(ctx context.Context, req *loghttp.RangeQuery) (*stats.Stats, error) + Label func(ctx context.Context, req *logproto.LabelRequest) (*logproto.LabelResponse, error) + Patterns func(ctx context.Context, req *logproto.QueryPatternsRequest) (*logproto.QueryPatternsResponse, error) + Series func(ctx context.Context, req *logproto.SeriesRequest) (*logproto.SeriesResponse, error) + Tail func(ctx context.Context, req *logproto.TailRequest, categorizedLabels bool) (*Tailer, error) + Volume func(ctx context.Context, req *logproto.VolumeRequest) (*logproto.VolumeResponse, error) + type QuerierAPI struct + func NewQuerierAPI(cfg Config, querier Querier, limits Limits, logger log.Logger) *QuerierAPI + func (q *QuerierAPI) DetectedFieldsHandler(ctx context.Context, req *logproto.DetectedFieldsRequest) (*logproto.DetectedFieldsResponse, error) + func (q *QuerierAPI) DetectedLabelsHandler(ctx context.Context, req *logproto.DetectedLabelsRequest) (*logproto.DetectedLabelsResponse, error) + func (q *QuerierAPI) IndexShardsHandler(ctx context.Context, req *loghttp.RangeQuery, targetBytesPerShard uint64) (*logproto.ShardsResponse, error) + func (q *QuerierAPI) IndexStatsHandler(ctx context.Context, req *loghttp.RangeQuery) (*logproto.IndexStatsResponse, error) + func (q *QuerierAPI) InstantQueryHandler(ctx context.Context, req *queryrange.LokiInstantRequest) (logqlmodel.Result, error) + func (q *QuerierAPI) LabelHandler(ctx context.Context, req *logproto.LabelRequest) (*logproto.LabelResponse, error) + func (q *QuerierAPI) PatternsHandler(ctx context.Context, req *logproto.QueryPatternsRequest) (*logproto.QueryPatternsResponse, error) + func (q *QuerierAPI) RangeQueryHandler(ctx context.Context, req *queryrange.LokiRequest) (logqlmodel.Result, error) + func (q *QuerierAPI) SeriesHandler(ctx context.Context, req *logproto.SeriesRequest) (*logproto.SeriesResponse, stats.Result, error) + func (q *QuerierAPI) TailHandler(w http.ResponseWriter, r *http.Request) + func (q *QuerierAPI) VolumeHandler(ctx context.Context, req *logproto.VolumeRequest) (*logproto.VolumeResponse, error) + type QueryResponse struct + Result parser.Value + ResultType parser.ValueType + type SingleTenantQuerier struct + func New(cfg Config, store Store, ingesterQuerier *IngesterQuerier, limits Limits, ...) (*SingleTenantQuerier, error) + func (*SingleTenantQuerier) Check(_ context.Context, _ *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error) + func (q *SingleTenantQuerier) DetectedFields(ctx context.Context, req *logproto.DetectedFieldsRequest) (*logproto.DetectedFieldsResponse, error) + func (q *SingleTenantQuerier) DetectedLabels(ctx context.Context, req *logproto.DetectedLabelsRequest) (*logproto.DetectedLabelsResponse, error) + func (q *SingleTenantQuerier) IndexShards(ctx context.Context, req *loghttp.RangeQuery, targetBytesPerShard uint64) (*logproto.ShardsResponse, error) + func (q *SingleTenantQuerier) IndexStats(ctx context.Context, req *loghttp.RangeQuery) (*stats.Stats, error) + func (q *SingleTenantQuerier) Label(ctx context.Context, req *logproto.LabelRequest) (*logproto.LabelResponse, error) + func (q *SingleTenantQuerier) Patterns(ctx context.Context, req *logproto.QueryPatternsRequest) (*logproto.QueryPatternsResponse, error) + func (q *SingleTenantQuerier) SelectLogs(ctx context.Context, params logql.SelectLogParams) (iter.EntryIterator, error) + func (q *SingleTenantQuerier) SelectSamples(ctx context.Context, params logql.SelectSampleParams) (iter.SampleIterator, error) + func (q *SingleTenantQuerier) Series(ctx context.Context, req *logproto.SeriesRequest) (*logproto.SeriesResponse, error) + func (q *SingleTenantQuerier) Tail(ctx context.Context, req *logproto.TailRequest, categorizedLabels bool) (*Tailer, error) + func (q *SingleTenantQuerier) Volume(ctx context.Context, req *logproto.VolumeRequest) (*logproto.VolumeResponse, error) + func (q *SingleTenantQuerier) WithPatternQuerier(pq PatterQuerier) + type Store interface + type Tailer struct + type TenantEntryIterator struct + func NewTenantEntryIterator(iter iter.EntryIterator, id string) *TenantEntryIterator + func (i *TenantEntryIterator) Labels() string + type TenantSampleIterator struct + func NewTenantSampleIterator(iter iter.SampleIterator, id string) *TenantSampleIterator + func (i *TenantSampleIterator) Labels() string + type TimeRangeLimits querier_limits.TimeRangeLimits + type WorkerServiceConfig struct + AllEnabled bool + GrpcListenAddress string + GrpcListenPort int + QuerierMaxConcurrent int + QuerierWorkerConfig *querier_worker.Config + QueryFrontendEnabled bool + QuerySchedulerEnabled bool + ReadEnabled bool + SchedulerRing ring.ReadRing + func (cfg WorkerServiceConfig) QuerierRunningStandalone() bool Other modules containing this package github.com/grafana/loki