Versions in this module Expand all Collapse all v2 v2.4.3 Feb 9, 2022 Changes in this version + func DefaultLimitsConfig() validation.Limits + func InitWorkerService(cfg WorkerServiceConfig, reg prometheus.Registerer, ...) (serve services.Service, err error) + func NewErrorTranslateQueryable(q storage.Queryable) storage.Queryable + func NewErrorTranslateQueryableWithFn(q storage.Queryable, fn ErrTranslateFn) storage.Queryable + func NewErrorTranslateSampleAndChunkQueryable(q storage.SampleAndChunkQueryable) storage.SampleAndChunkQueryable + func NewErrorTranslateSampleAndChunkQueryableWithFn(q storage.SampleAndChunkQueryable, fn ErrTranslateFn) storage.SampleAndChunkQueryable + func TranslateToPromqlAPIError(err error) error + type Config struct + Engine logql.EngineOpts + ExtraQueryDelay time.Duration + IngesterQueryStoreMaxLookback time.Duration + MaxConcurrent int + QueryIngesterOnly bool + QueryIngestersWithin time.Duration + QueryStoreOnly bool + QueryTimeout time.Duration + TailMaxDuration time.Duration + func DefaultQuerierConfig() Config + func (cfg *Config) RegisterFlags(f *flag.FlagSet) + func (cfg *Config) Validate() error + type DummyAlertmanagerRetriever struct + func (DummyAlertmanagerRetriever) Alertmanagers() []*url.URL + func (DummyAlertmanagerRetriever) DroppedAlertmanagers() []*url.URL + type DummyRulesRetriever struct + func (DummyRulesRetriever) AlertingRules() []*rules.AlertingRule + func (DummyRulesRetriever) RuleGroups() []*rules.Group + type DummyTargetRetriever struct + func (DummyTargetRetriever) TargetsActive() map[string][]*scrape.Target + func (DummyTargetRetriever) TargetsDropped() map[string][]*scrape.Target + type ErrTranslateFn func(err error) 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) 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 MockDistributor struct + func (m *MockDistributor) LabelNames(ctx context.Context, from, to model.Time) ([]string, error) + func (m *MockDistributor) LabelValuesForLabelName(ctx context.Context, from, to model.Time, lbl model.LabelName, ...) ([]string, error) + func (m *MockDistributor) MetricsForLabelMatchers(ctx context.Context, from, to model.Time, matchers ...*labels.Matcher) ([]metric.Metric, error) + func (m *MockDistributor) MetricsMetadata(ctx context.Context) ([]scrape.MetricMetadata, error) + func (m *MockDistributor) Query(ctx context.Context, from, to model.Time, matchers ...*labels.Matcher) (model.Matrix, error) + func (m *MockDistributor) QueryExemplars(ctx context.Context, from, to model.Time, matchers ...[]*labels.Matcher) (*client.ExemplarQueryResponse, error) + func (m *MockDistributor) QueryStream(ctx context.Context, from, to model.Time, matchers ...*labels.Matcher) (*client.QueryStreamResponse, 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 + type TestConfig struct + Cfg Config + Distributor base_querier.Distributor + Stores []base_querier.QueryableWithFilter + type WorkerServiceConfig struct + AllEnabled bool + GrpcListenPort int + QuerierMaxConcurrent int + QuerierWorkerConfig *querier_worker.Config + QueryFrontendEnabled bool + QuerySchedulerEnabled bool + ReadEnabled bool + SchedulerRing ring.ReadRing Other modules containing this package github.com/frelon/loki