Versions in this module Expand all Collapse all v3 v3.0.1 Mar 21, 2022 v3.0.0 Mar 21, 2022 Changes in this version + func DefaultLimitsConfig() validation.Limits + func InitWorkerService(cfg WorkerServiceConfig, reg prometheus.Registerer, ...) (serve services.Service, err error) + type Config struct + Engine logql.EngineOpts + ExtraQueryDelay time.Duration + IngesterQueryStoreMaxLookback time.Duration + MaxConcurrent int + MultiTenantQueriesEnabled 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) 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 MultiTenantQuerier struct + func NewMultiTenantQuerier(querier Querier, logger log.Logger) *MultiTenantQuerier + 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) + type Querier interface + Label func(ctx context.Context, req *logproto.LabelRequest) (*logproto.LabelResponse, 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 *validation.Overrides, logger log.Logger) *QuerierAPI + func (q *QuerierAPI) InstantQueryHandler(w http.ResponseWriter, r *http.Request) + func (q *QuerierAPI) LabelHandler(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) Label(ctx context.Context, req *logproto.LabelRequest) (*logproto.LabelResponse, 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 + GrpcListenPort int + QuerierMaxConcurrent int + QuerierWorkerConfig *querier_worker.Config + QueryFrontendEnabled bool + QuerySchedulerEnabled bool + ReadEnabled bool + SchedulerRing ring.ReadRing Other modules containing this package github.com/pao214/loki github.com/pao214/loki/v2