Versions in this module Expand all Collapse all v2 v2.0.0 Jun 14, 2023 Changes in this version + func DefaultLimitsConfig() validation.Limits + func InitWorkerService(cfg WorkerServiceConfig, reg prometheus.Registerer, ...) (serve services.Service, err error) + func WrapQuerySpanAndTimeout(call string, q *QuerierAPI) 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 + QueryTimeout time.Duration + TailMaxDuration time.Duration + func (cfg *Config) RegisterFlags(f *flag.FlagSet) + func (cfg *Config) Validate() error + type IngesterQuerier struct + func NewIngesterQuerier(clientCfg client.Config, ring ring.ReadRing, extraQueryDelay time.Duration) (*IngesterQuerier, 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) LabelVolume(ctx context.Context, _ string, from, through model.Time, limit int32, ...) (*logproto.LabelVolumeResponse, 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) + type Limits interface + MaxConcurrentTailRequests func(context.Context, string) int + MaxEntriesLimitPerQuery func(context.Context, string) int + MaxStreamsMatchersPerQuery func(context.Context, string) int + QueryTimeout func(context.Context, string) time.Duration + type Metrics struct + func NewMetrics(r prometheus.Registerer) *Metrics + type MultiTenantQuerier struct + func NewMultiTenantQuerier(querier Querier, _ log.Logger) *MultiTenantQuerier + 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) LabelVolume(ctx context.Context, req *logproto.LabelVolumeRequest) (*logproto.LabelVolumeResponse, 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) + type Querier interface + IndexStats func(ctx context.Context, req *loghttp.RangeQuery) (*stats.Stats, error) + Label func(ctx context.Context, req *logproto.LabelRequest) (*logproto.LabelResponse, error) + LabelVolume func(ctx context.Context, req *logproto.LabelVolumeRequest) (*logproto.LabelVolumeResponse, error) + Series func(ctx context.Context, req *logproto.SeriesRequest) (*logproto.SeriesResponse, error) + Tail func(ctx context.Context, req *logproto.TailRequest) (*Tailer, error) + type QuerierAPI struct + func NewQuerierAPI(cfg Config, querier Querier, limits Limits, logger log.Logger) *QuerierAPI + func (q *QuerierAPI) IndexStatsHandler(w http.ResponseWriter, r *http.Request) + func (q *QuerierAPI) InstantQueryHandler(w http.ResponseWriter, r *http.Request) + func (q *QuerierAPI) LabelHandler(w http.ResponseWriter, r *http.Request) + func (q *QuerierAPI) LabelVolumeHandler(w http.ResponseWriter, r *http.Request) + func (q *QuerierAPI) LogQueryHandler(w http.ResponseWriter, r *http.Request) + func (q *QuerierAPI) RangeQueryHandler(w http.ResponseWriter, r *http.Request) + func (q *QuerierAPI) SeriesHandler(w http.ResponseWriter, r *http.Request) + func (q *QuerierAPI) TailHandler(w http.ResponseWriter, r *http.Request) + type QueryResponse struct + Result parser.Value + ResultType parser.ValueType + type SingleTenantQuerier struct + func New(cfg Config, store storage.Store, ingesterQuerier *IngesterQuerier, ...) (*SingleTenantQuerier, error) + func (*SingleTenantQuerier) Check(_ context.Context, _ *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, 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) LabelVolume(ctx context.Context, req *logproto.LabelVolumeRequest) (*logproto.LabelVolumeResponse, 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) (*Tailer, error) + 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 WorkerServiceConfig struct + AllEnabled bool + GrpcListenAddress string + GrpcListenPort int + QuerierMaxConcurrent int + QuerierWorkerConfig *querier_worker.Config + QueryFrontendEnabled bool + QuerySchedulerEnabled bool + ReadEnabled bool + SchedulerRing ring.ReadRing