Versions in this module Expand all Collapse all v1 v1.6.3 Jan 15, 2024 Changes in this version + type Config struct + Engine logql.EngineOpts + ExtraQueryDelay time.Duration + IngesterQueryStoreMaxLookback time.Duration + MaxConcurrent int + QueryIngestersWithin time.Duration + QueryTimeout time.Duration + TailMaxDuration time.Duration + func (cfg *Config) RegisterFlags(f *flag.FlagSet) + 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) 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) 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 Querier struct + func New(cfg Config, store storage.Store, ingesterQuerier *IngesterQuerier, ...) (*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) 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) SetQueryable(queryable logql.Querier) + func (q *Querier) Tail(ctx context.Context, req *logproto.TailRequest) (*Tailer, error) + func (q *Querier) TailHandler(w http.ResponseWriter, r *http.Request) + type QueryResponse struct + Result parser.Value + ResultType parser.ValueType + type Tailer struct
Go to main page