Versions in this module Expand all Collapse all v3 v3.0.0 Apr 8, 2024 Changes in this version + const DefaultDownstreamConcurrency + const DetectedFieldsOp + const DetectedLabelsOp + const IndexShardsOp + const IndexStatsOp + const InstantQueryOp + const JSONType + const LabelNamesOp + const PatternsQueryOp + const ProtobufType + const QueryRangeOp + const SeriesOp + const VolumeOp + const VolumeRangeOp + var DefaultCodec = &Codec + var ErrIntOverflowQueryrange = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthQueryrange = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrMaxQueryParalellism = fmt.Errorf("querying is disabled, please contact your Loki operator") + var StatsHTTPMiddleware middleware.Interface = statsHTTPMiddleware(defaultMetricRecorder) + func MinWeightedParallelism(ctx context.Context, tenantIDs []string, configs []config.PeriodConfig, ...) int + func NewEmptyResponse(r queryrangebase.Request) (queryrangebase.Response, error) + func NewIndexStatsCacheMiddleware(log log.Logger, limits Limits, merger queryrangebase.Merger, c cache.Cache, ...) (queryrangebase.Middleware, error) + func NewIndexStatsTripperware(cfg Config, log log.Logger, limits Limits, schema config.SchemaConfig, ...) (base.Middleware, error) + func NewInstantMetricCacheMiddleware(log log.Logger, limits Limits, merger queryrangebase.Merger, c cache.Cache, ...) (queryrangebase.Middleware, error) + func NewInstantMetricTripperware(cfg Config, engineOpts logql.EngineOpts, log log.Logger, limits Limits, ...) (base.Middleware, error) + func NewLabelsCacheMiddleware(logger log.Logger, limits Limits, merger queryrangebase.Merger, c cache.Cache, ...) (queryrangebase.Middleware, error) + func NewLabelsTripperware(cfg Config, log log.Logger, limits Limits, merger base.Merger, ...) (base.Middleware, error) + func NewLimitedRoundTripper(next queryrangebase.Handler, limits Limits, configs []config.PeriodConfig, ...) queryrangebase.Handler + func NewLimitedTripperware(_ Config, engineOpts logql.EngineOpts, log log.Logger, limits Limits, ...) (base.Middleware, error) + func NewLimitsMiddleware(l Limits) queryrangebase.Middleware + func NewLogFilterTripperware(cfg Config, engineOpts logql.EngineOpts, log log.Logger, limits Limits, ...) (base.Middleware, error) + func NewLogResultCache(logger log.Logger, limits Limits, cache cache.Cache, ...) queryrangebase.Middleware + func NewMetricTripperware(cfg Config, engineOpts logql.EngineOpts, log log.Logger, limits Limits, ...) (base.Middleware, error) + func NewQuerierSizeLimiterMiddleware(cfg []config.PeriodConfig, engineOpts logql.EngineOpts, logger log.Logger, ...) queryrangebase.Middleware + func NewQueryShardMiddleware(logger log.Logger, confs ShardingConfigs, engineOpts logql.EngineOpts, ...) queryrangebase.Middleware + func NewQuerySizeLimiterMiddleware(cfg []config.PeriodConfig, engineOpts logql.EngineOpts, logger log.Logger, ...) queryrangebase.Middleware + func NewSerializeHTTPHandler(next queryrangebase.Handler, codec queryrangebase.Codec) http.Handler + func NewSerializeRoundTripper(next queryrangebase.Handler, codec queryrangebase.Codec) http.RoundTripper + func NewSeriesCacheMiddleware(logger log.Logger, limits Limits, merger queryrangebase.Merger, c cache.Cache, ...) (queryrangebase.Middleware, error) + func NewSeriesQueryShardMiddleware(logger log.Logger, confs ShardingConfigs, ...) queryrangebase.Middleware + func NewSeriesTripperware(cfg Config, log log.Logger, limits Limits, metrics *Metrics, ...) (base.Middleware, error) + func NewSplitByRangeMiddleware(logger log.Logger, engineOpts logql.EngineOpts, limits Limits, splitAlign bool, ...) queryrangebase.Middleware + func NewVolumeCacheMiddleware(log log.Logger, limits Limits, merger queryrangebase.Merger, c cache.Cache, ...) (queryrangebase.Middleware, error) + func NewVolumeMiddleware() queryrangebase.Middleware + func NewVolumeTripperware(cfg Config, log log.Logger, limits Limits, schema config.SchemaConfig, ...) (base.Middleware, error) + func ParamsFromRequest(req queryrangebase.Request) (logql.Params, error) + func ParamsToLokiRequest(params logql.Params) queryrangebase.Request + func QueryMetricsMiddleware(metrics *QueryMetrics) queryrangebase.Middleware + func QueryResponseUnwrap(res *QueryResponse) (queryrangebase.Response, error) + func ResponseToResult(resp queryrangebase.Response) (logqlmodel.Result, error) + func ResultToResponse(result logqlmodel.Result, params logql.Params) (queryrangebase.Response, error) + func SplitByIntervalMiddleware(configs []config.PeriodConfig, limits Limits, merger queryrangebase.Merger, ...) queryrangebase.Middleware + func SplitIntervalForTimeRange(iqo util.IngesterQueryOptions, limits Limits, ...) time.Duration + func StatsCollectorMiddleware() queryrangebase.Middleware + func WeightedParallelism(ctx context.Context, configs []config.PeriodConfig, user string, l Limits, ...) int + func WriteQueryResponseProtobuf(params logql.Params, v logqlmodel.Result, w io.Writer) error + func WriteSeriesResponseViewJSON(v *MergedSeriesResponseView, w io.Writer) error + type Buffer interface + Bytes func() []byte + type Codec struct + func (Codec) DecodeHTTPGrpcRequest(ctx context.Context, r *httpgrpc.HTTPRequest) (queryrangebase.Request, context.Context, error) + func (Codec) DecodeHTTPGrpcResponse(r *httpgrpc.HTTPResponse, req queryrangebase.Request) (queryrangebase.Response, error) + func (Codec) DecodeRequest(_ context.Context, r *http.Request, _ []string) (queryrangebase.Request, error) + func (Codec) DecodeResponse(_ context.Context, r *http.Response, req queryrangebase.Request) (queryrangebase.Response, error) + func (Codec) EncodeHTTPGrpcResponse(_ context.Context, req *httpgrpc.HTTPRequest, res queryrangebase.Response) (*httpgrpc.HTTPResponse, error) + func (Codec) EncodeResponse(ctx context.Context, req *http.Request, res queryrangebase.Response) (*http.Response, error) + func (Codec) MergeResponse(responses ...queryrangebase.Response) (queryrangebase.Response, error) + func (Codec) QueryRequestUnwrap(ctx context.Context, req *QueryRequest) (queryrangebase.Request, context.Context, error) + func (Codec) QueryRequestWrap(ctx context.Context, r queryrangebase.Request) (*QueryRequest, error) + func (c Codec) EncodeRequest(ctx context.Context, r queryrangebase.Request) (*http.Request, error) + func (c Codec) Path(r queryrangebase.Request) string + type Config struct + CacheIndexStatsResults bool + CacheInstantMetricResults bool + CacheLabelResults bool + CacheSeriesResults bool + CacheVolumeResults bool + InstantMetricCacheConfig InstantMetricCacheConfig + InstantMetricQuerySplitAlign bool + LabelsCacheConfig LabelsCacheConfig + SeriesCacheConfig SeriesCacheConfig + StatsCacheConfig IndexStatsCacheConfig + Transformer UserIDTransformer + VolumeCacheConfig VolumeCacheConfig + func (cfg *Config) RegisterFlags(f *flag.FlagSet) + func (cfg *Config) Validate() error + type DetectedFieldsRequest struct + func NewDetectedFieldsRequest(start, end time.Time, query, path string) *DetectedFieldsRequest + func (*DetectedFieldsRequest) GetCachingOptions() (res queryrangebase.CachingOptions) + func (r *DetectedFieldsRequest) AsProto() *logproto.DetectedFieldsRequest + func (r *DetectedFieldsRequest) GetEnd() time.Time + func (r *DetectedFieldsRequest) GetEndTs() time.Time + func (r *DetectedFieldsRequest) GetStart() time.Time + func (r *DetectedFieldsRequest) GetStartTs() time.Time + func (r *DetectedFieldsRequest) GetStep() int64 + func (r *DetectedFieldsRequest) LogToSpan(sp opentracing.Span) + func (r *DetectedFieldsRequest) Path() string + func (r *DetectedFieldsRequest) WithQuery(query string) queryrangebase.Request + func (r *DetectedFieldsRequest) WithStartEnd(s, e time.Time) queryrangebase.Request + func (r *DetectedFieldsRequest) WithStartEndForCache(s time.Time, e time.Time) resultscache.Request + type DetectedFieldsResponse struct + Headers []github_com_grafana_loki_v3_pkg_querier_queryrange_queryrangebase_definitions.PrometheusResponseHeader + Response *github_com_grafana_loki_v3_pkg_logproto.DetectedFieldsResponse + func (*DetectedFieldsResponse) Descriptor() ([]byte, []int) + func (*DetectedFieldsResponse) ProtoMessage() + func (m *DetectedFieldsResponse) GetHeaders() []*queryrangebase.PrometheusResponseHeader + func (m *DetectedFieldsResponse) Marshal() (dAtA []byte, err error) + func (m *DetectedFieldsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *DetectedFieldsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DetectedFieldsResponse) Reset() + func (m *DetectedFieldsResponse) SetHeader(name, value string) + func (m *DetectedFieldsResponse) Size() (n int) + func (m *DetectedFieldsResponse) Unmarshal(dAtA []byte) error + func (m *DetectedFieldsResponse) WithHeaders(h []queryrangebase.PrometheusResponseHeader) queryrangebase.Response + func (m *DetectedFieldsResponse) XXX_DiscardUnknown() + func (m *DetectedFieldsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DetectedFieldsResponse) XXX_Merge(src proto.Message) + func (m *DetectedFieldsResponse) XXX_Size() int + func (m *DetectedFieldsResponse) XXX_Unmarshal(b []byte) error + func (this *DetectedFieldsResponse) Equal(that interface{}) bool + func (this *DetectedFieldsResponse) GoString() string + func (this *DetectedFieldsResponse) String() string + type DetectedLabelsRequest struct + func NewDetectedLabelsRequest(start, end time.Time, query, path string) *DetectedLabelsRequest + func (*DetectedLabelsRequest) GetCachingOptions() (res queryrangebase.CachingOptions) + func (r *DetectedLabelsRequest) AsProto() *logproto.DetectedLabelsRequest + func (r *DetectedLabelsRequest) GetEnd() time.Time + func (r *DetectedLabelsRequest) GetEndTs() time.Time + func (r *DetectedLabelsRequest) GetStart() time.Time + func (r *DetectedLabelsRequest) GetStartTs() time.Time + func (r *DetectedLabelsRequest) GetStep() int64 + func (r *DetectedLabelsRequest) LogToSpan(sp opentracing.Span) + func (r *DetectedLabelsRequest) Path() string + func (r *DetectedLabelsRequest) WithQuery(query string) queryrangebase.Request + func (r *DetectedLabelsRequest) WithStartEnd(s, e time.Time) queryrangebase.Request + func (r *DetectedLabelsRequest) WithStartEndForCache(s time.Time, e time.Time) resultscache.Request + type DetectedLabelsResponse struct + Headers []github_com_grafana_loki_v3_pkg_querier_queryrange_queryrangebase_definitions.PrometheusResponseHeader + Response *github_com_grafana_loki_v3_pkg_logproto.DetectedLabelsResponse + func (*DetectedLabelsResponse) Descriptor() ([]byte, []int) + func (*DetectedLabelsResponse) ProtoMessage() + func (m *DetectedLabelsResponse) GetHeaders() []*queryrangebase.PrometheusResponseHeader + func (m *DetectedLabelsResponse) Marshal() (dAtA []byte, err error) + func (m *DetectedLabelsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *DetectedLabelsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DetectedLabelsResponse) Reset() + func (m *DetectedLabelsResponse) SetHeader(name, value string) + func (m *DetectedLabelsResponse) Size() (n int) + func (m *DetectedLabelsResponse) Unmarshal(dAtA []byte) error + func (m *DetectedLabelsResponse) WithHeaders(h []queryrangebase.PrometheusResponseHeader) queryrangebase.Response + func (m *DetectedLabelsResponse) XXX_DiscardUnknown() + func (m *DetectedLabelsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DetectedLabelsResponse) XXX_Merge(src proto.Message) + func (m *DetectedLabelsResponse) XXX_Size() int + func (m *DetectedLabelsResponse) XXX_Unmarshal(b []byte) error + func (this *DetectedLabelsResponse) Equal(that interface{}) bool + func (this *DetectedLabelsResponse) GoString() string + func (this *DetectedLabelsResponse) String() string + type DownstreamHandler struct + func (h DownstreamHandler) Downstreamer(ctx context.Context) logql.Downstreamer + type IndexStatsCacheConfig struct + func (cfg *IndexStatsCacheConfig) RegisterFlags(f *flag.FlagSet) + func (cfg *IndexStatsCacheConfig) Validate() error + type IndexStatsExtractor struct + func (p IndexStatsExtractor) Extract(start, end int64, res resultscache.Response, resStart, resEnd int64) resultscache.Response + func (p IndexStatsExtractor) ResponseWithoutHeaders(resp queryrangebase.Response) queryrangebase.Response + type IndexStatsResponse struct + Headers []github_com_grafana_loki_v3_pkg_querier_queryrange_queryrangebase_definitions.PrometheusResponseHeader + Response *github_com_grafana_loki_v3_pkg_logproto.IndexStatsResponse + func (*IndexStatsResponse) Descriptor() ([]byte, []int) + func (*IndexStatsResponse) ProtoMessage() + func (m *IndexStatsResponse) GetHeaders() []*queryrangebase.PrometheusResponseHeader + func (m *IndexStatsResponse) Marshal() (dAtA []byte, err error) + func (m *IndexStatsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *IndexStatsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *IndexStatsResponse) Reset() + func (m *IndexStatsResponse) SetHeader(name, value string) + func (m *IndexStatsResponse) Size() (n int) + func (m *IndexStatsResponse) Unmarshal(dAtA []byte) error + func (m *IndexStatsResponse) WithHeaders(h []queryrangebase.PrometheusResponseHeader) queryrangebase.Response + func (m *IndexStatsResponse) XXX_DiscardUnknown() + func (m *IndexStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IndexStatsResponse) XXX_Merge(src proto.Message) + func (m *IndexStatsResponse) XXX_Size() int + func (m *IndexStatsResponse) XXX_Unmarshal(b []byte) error + func (this *IndexStatsResponse) Equal(that interface{}) bool + func (this *IndexStatsResponse) GoString() string + func (this *IndexStatsResponse) String() string + type IndexStatsSplitter struct + func (i IndexStatsSplitter) GenerateCacheKey(ctx context.Context, userID string, r resultscache.Request) string + type InstantMetricCacheConfig struct + func (cfg *InstantMetricCacheConfig) RegisterFlags(f *flag.FlagSet) + func (cfg *InstantMetricCacheConfig) Validate() error + type InstantMetricSplitter struct + func (i InstantMetricSplitter) GenerateCacheKey(ctx context.Context, userID string, r resultscache.Request) string + type Instrument struct + func (i Instrument) Wrap(next queryrangebase.Handler) queryrangebase.Handler + type LabelRequest struct + func NewLabelRequest(start, end time.Time, query, name, path string) *LabelRequest + func (*LabelRequest) GetCachingOptions() (res queryrangebase.CachingOptions) + func (r *LabelRequest) AsProto() *logproto.LabelRequest + func (r *LabelRequest) GetEnd() time.Time + func (r *LabelRequest) GetEndTs() time.Time + func (r *LabelRequest) GetStart() time.Time + func (r *LabelRequest) GetStartTs() time.Time + func (r *LabelRequest) GetStep() int64 + func (r *LabelRequest) LogToSpan(sp opentracing.Span) + func (r *LabelRequest) Path() string + func (r *LabelRequest) WithQuery(query string) queryrangebase.Request + func (r *LabelRequest) WithStartEnd(s, e time.Time) queryrangebase.Request + func (r *LabelRequest) WithStartEndForCache(s time.Time, e time.Time) resultscache.Request + type LabelsCacheConfig struct + func (cfg *LabelsCacheConfig) RegisterFlags(f *flag.FlagSet) + func (cfg *LabelsCacheConfig) Validate() error + type Limits queryrange_limits.Limits + func WithMaxParallelism(l Limits, maxParallelism int) Limits + func WithSplitByLimits(l Limits, splitBy time.Duration) Limits + type LogResultCacheMetrics struct + CacheHit prometheus.Counter + CacheMiss prometheus.Counter + func NewLogResultCacheMetrics(registerer prometheus.Registerer) *LogResultCacheMetrics + type LokiData struct + Result []github_com_grafana_loki_pkg_push.Stream + ResultType string + func (*LokiData) Descriptor() ([]byte, []int) + func (*LokiData) ProtoMessage() + func (m *LokiData) GetResultType() string + func (m *LokiData) Marshal() (dAtA []byte, err error) + func (m *LokiData) MarshalTo(dAtA []byte) (int, error) + func (m *LokiData) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LokiData) Reset() + func (m *LokiData) Size() (n int) + func (m *LokiData) Unmarshal(dAtA []byte) error + func (m *LokiData) XXX_DiscardUnknown() + func (m *LokiData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LokiData) XXX_Merge(src proto.Message) + func (m *LokiData) XXX_Size() int + func (m *LokiData) XXX_Unmarshal(b []byte) error + func (this *LokiData) Equal(that interface{}) bool + func (this *LokiData) GoString() string + func (this *LokiData) String() string + type LokiInstantRequest struct + Direction logproto.Direction + Limit uint32 + Path string + Plan *github_com_grafana_loki_v3_pkg_querier_plan.QueryPlan + Query string + Shards []string + TimeTs time.Time + func (*LokiInstantRequest) Descriptor() ([]byte, []int) + func (*LokiInstantRequest) GetCachingOptions() (res queryrangebase.CachingOptions) + func (*LokiInstantRequest) ProtoMessage() + func (m *LokiInstantRequest) GetDirection() logproto.Direction + func (m *LokiInstantRequest) GetLimit() uint32 + func (m *LokiInstantRequest) GetPath() string + func (m *LokiInstantRequest) GetQuery() string + func (m *LokiInstantRequest) GetShards() []string + func (m *LokiInstantRequest) GetTimeTs() time.Time + func (m *LokiInstantRequest) Marshal() (dAtA []byte, err error) + func (m *LokiInstantRequest) MarshalTo(dAtA []byte) (int, error) + func (m *LokiInstantRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LokiInstantRequest) Reset() + func (m *LokiInstantRequest) Size() (n int) + func (m *LokiInstantRequest) Unmarshal(dAtA []byte) error + func (m *LokiInstantRequest) XXX_DiscardUnknown() + func (m *LokiInstantRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LokiInstantRequest) XXX_Merge(src proto.Message) + func (m *LokiInstantRequest) XXX_Size() int + func (m *LokiInstantRequest) XXX_Unmarshal(b []byte) error + func (r *LokiInstantRequest) GetEnd() time.Time + func (r *LokiInstantRequest) GetStart() time.Time + func (r *LokiInstantRequest) GetStep() int64 + func (r *LokiInstantRequest) LogToSpan(sp opentracing.Span) + func (r *LokiInstantRequest) WithQuery(query string) queryrangebase.Request + func (r *LokiInstantRequest) WithShards(shards logql.Shards) *LokiInstantRequest + func (r *LokiInstantRequest) WithStartEnd(s time.Time, _ time.Time) queryrangebase.Request + func (r *LokiInstantRequest) WithStartEndForCache(s time.Time, e time.Time) resultscache.Request + func (this *LokiInstantRequest) Equal(that interface{}) bool + func (this *LokiInstantRequest) GoString() string + func (this *LokiInstantRequest) String() string + type LokiLabelNamesResponse struct + Data []string + Headers []github_com_grafana_loki_v3_pkg_querier_queryrange_queryrangebase_definitions.PrometheusResponseHeader + Statistics stats.Result + Status string + Version uint32 + func (*LokiLabelNamesResponse) Descriptor() ([]byte, []int) + func (*LokiLabelNamesResponse) ProtoMessage() + func (m *LokiLabelNamesResponse) GetData() []string + func (m *LokiLabelNamesResponse) GetHeaders() []*queryrangebase.PrometheusResponseHeader + func (m *LokiLabelNamesResponse) GetStatistics() stats.Result + func (m *LokiLabelNamesResponse) GetStatus() string + func (m *LokiLabelNamesResponse) GetVersion() uint32 + func (m *LokiLabelNamesResponse) Marshal() (dAtA []byte, err error) + func (m *LokiLabelNamesResponse) MarshalTo(dAtA []byte) (int, error) + func (m *LokiLabelNamesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LokiLabelNamesResponse) Reset() + func (m *LokiLabelNamesResponse) SetHeader(name, value string) + func (m *LokiLabelNamesResponse) Size() (n int) + func (m *LokiLabelNamesResponse) Unmarshal(dAtA []byte) error + func (m *LokiLabelNamesResponse) WithHeaders(h []queryrangebase.PrometheusResponseHeader) queryrangebase.Response + func (m *LokiLabelNamesResponse) XXX_DiscardUnknown() + func (m *LokiLabelNamesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LokiLabelNamesResponse) XXX_Merge(src proto.Message) + func (m *LokiLabelNamesResponse) XXX_Size() int + func (m *LokiLabelNamesResponse) XXX_Unmarshal(b []byte) error + func (this *LokiLabelNamesResponse) Equal(that interface{}) bool + func (this *LokiLabelNamesResponse) GoString() string + func (this *LokiLabelNamesResponse) String() string + type LokiPromResponse struct + Response *queryrangebase.PrometheusResponse + Statistics stats.Result + func ToPrometheusResponse(respsCh chan *bucketedVolumeResponse, aggregateBySeries bool) *LokiPromResponse + func (*LokiPromResponse) Descriptor() ([]byte, []int) + func (*LokiPromResponse) ProtoMessage() + func (m *LokiPromResponse) GetHeaders() []*queryrangebase.PrometheusResponseHeader + func (m *LokiPromResponse) GetResponse() *queryrangebase.PrometheusResponse + func (m *LokiPromResponse) GetStatistics() stats.Result + func (m *LokiPromResponse) Marshal() (dAtA []byte, err error) + func (m *LokiPromResponse) MarshalTo(dAtA []byte) (int, error) + func (m *LokiPromResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LokiPromResponse) Reset() + func (m *LokiPromResponse) SetHeader(name, value string) + func (m *LokiPromResponse) Size() (n int) + func (m *LokiPromResponse) Unmarshal(dAtA []byte) error + func (m *LokiPromResponse) WithHeaders(h []queryrangebase.PrometheusResponseHeader) queryrangebase.Response + func (m *LokiPromResponse) XXX_DiscardUnknown() + func (m *LokiPromResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LokiPromResponse) XXX_Merge(src proto.Message) + func (m *LokiPromResponse) XXX_Size() int + func (m *LokiPromResponse) XXX_Unmarshal(b []byte) error + func (this *LokiPromResponse) Equal(that interface{}) bool + func (this *LokiPromResponse) GoString() string + func (this *LokiPromResponse) String() string + type LokiRequest struct + Direction logproto.Direction + EndTs time.Time + Interval int64 + Limit uint32 + Path string + Plan *github_com_grafana_loki_v3_pkg_querier_plan.QueryPlan + Query string + Shards []string + StartTs time.Time + Step int64 + func (*LokiRequest) Descriptor() ([]byte, []int) + func (*LokiRequest) GetCachingOptions() (res queryrangebase.CachingOptions) + func (*LokiRequest) ProtoMessage() + func (m *LokiRequest) GetDirection() logproto.Direction + func (m *LokiRequest) GetEndTs() time.Time + func (m *LokiRequest) GetInterval() int64 + func (m *LokiRequest) GetLimit() uint32 + func (m *LokiRequest) GetPath() string + func (m *LokiRequest) GetQuery() string + func (m *LokiRequest) GetShards() []string + func (m *LokiRequest) GetStartTs() time.Time + func (m *LokiRequest) GetStep() int64 + func (m *LokiRequest) Marshal() (dAtA []byte, err error) + func (m *LokiRequest) MarshalTo(dAtA []byte) (int, error) + func (m *LokiRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LokiRequest) Reset() + func (m *LokiRequest) Size() (n int) + func (m *LokiRequest) Unmarshal(dAtA []byte) error + func (m *LokiRequest) XXX_DiscardUnknown() + func (m *LokiRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LokiRequest) XXX_Merge(src proto.Message) + func (m *LokiRequest) XXX_Size() int + func (m *LokiRequest) XXX_Unmarshal(b []byte) error + func (r *LokiRequest) GetEnd() time.Time + func (r *LokiRequest) GetStart() time.Time + func (r *LokiRequest) LogToSpan(sp opentracing.Span) + func (r *LokiRequest) WithQuery(query string) queryrangebase.Request + func (r *LokiRequest) WithShards(shards logql.Shards) *LokiRequest + func (r *LokiRequest) WithStartEnd(s time.Time, e time.Time) queryrangebase.Request + func (r *LokiRequest) WithStartEndForCache(s time.Time, e time.Time) resultscache.Request + func (this *LokiRequest) Equal(that interface{}) bool + func (this *LokiRequest) GoString() string + func (this *LokiRequest) String() string + type LokiResponse struct + Data LokiData + Direction logproto.Direction + Error string + ErrorType string + Headers []github_com_grafana_loki_v3_pkg_querier_queryrange_queryrangebase_definitions.PrometheusResponseHeader + Limit uint32 + Statistics stats.Result + Status string + Version uint32 + Warnings []string + func (*LokiResponse) Descriptor() ([]byte, []int) + func (*LokiResponse) ProtoMessage() + func (m *LokiResponse) GetData() LokiData + func (m *LokiResponse) GetDirection() logproto.Direction + func (m *LokiResponse) GetError() string + func (m *LokiResponse) GetErrorType() string + func (m *LokiResponse) GetHeaders() []*queryrangebase.PrometheusResponseHeader + func (m *LokiResponse) GetLimit() uint32 + func (m *LokiResponse) GetStatistics() stats.Result + func (m *LokiResponse) GetStatus() string + func (m *LokiResponse) GetVersion() uint32 + func (m *LokiResponse) GetWarnings() []string + func (m *LokiResponse) Marshal() (dAtA []byte, err error) + func (m *LokiResponse) MarshalTo(dAtA []byte) (int, error) + func (m *LokiResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LokiResponse) Reset() + func (m *LokiResponse) SetHeader(name, value string) + func (m *LokiResponse) Size() (n int) + func (m *LokiResponse) Unmarshal(dAtA []byte) error + func (m *LokiResponse) WithHeaders(h []queryrangebase.PrometheusResponseHeader) queryrangebase.Response + func (m *LokiResponse) XXX_DiscardUnknown() + func (m *LokiResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LokiResponse) XXX_Merge(src proto.Message) + func (m *LokiResponse) XXX_Size() int + func (m *LokiResponse) XXX_Unmarshal(b []byte) error + func (res LokiResponse) Count() int64 + func (this *LokiResponse) Equal(that interface{}) bool + func (this *LokiResponse) GoString() string + func (this *LokiResponse) String() string + type LokiSeriesRequest struct + EndTs time.Time + Match []string + Path string + Shards []string + StartTs time.Time + func (*LokiSeriesRequest) Descriptor() ([]byte, []int) + func (*LokiSeriesRequest) GetCachingOptions() (res queryrangebase.CachingOptions) + func (*LokiSeriesRequest) ProtoMessage() + func (m *LokiSeriesRequest) GetEndTs() time.Time + func (m *LokiSeriesRequest) GetMatch() []string + func (m *LokiSeriesRequest) GetPath() string + func (m *LokiSeriesRequest) GetShards() []string + func (m *LokiSeriesRequest) GetStartTs() time.Time + func (m *LokiSeriesRequest) Marshal() (dAtA []byte, err error) + func (m *LokiSeriesRequest) MarshalTo(dAtA []byte) (int, error) + func (m *LokiSeriesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LokiSeriesRequest) Reset() + func (m *LokiSeriesRequest) Size() (n int) + func (m *LokiSeriesRequest) Unmarshal(dAtA []byte) error + func (m *LokiSeriesRequest) XXX_DiscardUnknown() + func (m *LokiSeriesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LokiSeriesRequest) XXX_Merge(src proto.Message) + func (m *LokiSeriesRequest) XXX_Size() int + func (m *LokiSeriesRequest) XXX_Unmarshal(b []byte) error + func (r *LokiSeriesRequest) GetEnd() time.Time + func (r *LokiSeriesRequest) GetQuery() string + func (r *LokiSeriesRequest) GetStart() time.Time + func (r *LokiSeriesRequest) GetStep() int64 + func (r *LokiSeriesRequest) LogToSpan(sp opentracing.Span) + func (r *LokiSeriesRequest) WithQuery(_ string) queryrangebase.Request + func (r *LokiSeriesRequest) WithStartEnd(s, e time.Time) queryrangebase.Request + func (r *LokiSeriesRequest) WithStartEndForCache(s time.Time, e time.Time) resultscache.Request + func (this *LokiSeriesRequest) Equal(that interface{}) bool + func (this *LokiSeriesRequest) GoString() string + func (this *LokiSeriesRequest) String() string + type LokiSeriesResponse struct + Data []logproto.SeriesIdentifier + Headers []github_com_grafana_loki_v3_pkg_querier_queryrange_queryrangebase_definitions.PrometheusResponseHeader + Statistics stats.Result + Status string + Version uint32 + func (*LokiSeriesResponse) Descriptor() ([]byte, []int) + func (*LokiSeriesResponse) ProtoMessage() + func (m *LokiSeriesResponse) GetData() []logproto.SeriesIdentifier + func (m *LokiSeriesResponse) GetHeaders() []*queryrangebase.PrometheusResponseHeader + func (m *LokiSeriesResponse) GetStatistics() stats.Result + func (m *LokiSeriesResponse) GetStatus() string + func (m *LokiSeriesResponse) GetVersion() uint32 + func (m *LokiSeriesResponse) Marshal() (dAtA []byte, err error) + func (m *LokiSeriesResponse) MarshalTo(dAtA []byte) (int, error) + func (m *LokiSeriesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LokiSeriesResponse) Reset() + func (m *LokiSeriesResponse) SetHeader(name, value string) + func (m *LokiSeriesResponse) Size() (n int) + func (m *LokiSeriesResponse) Unmarshal(dAtA []byte) error + func (m *LokiSeriesResponse) UnmarshalJSON(data []byte) error + func (m *LokiSeriesResponse) WithHeaders(h []queryrangebase.PrometheusResponseHeader) queryrangebase.Response + func (m *LokiSeriesResponse) XXX_DiscardUnknown() + func (m *LokiSeriesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LokiSeriesResponse) XXX_Merge(src proto.Message) + func (m *LokiSeriesResponse) XXX_Size() int + func (m *LokiSeriesResponse) XXX_Unmarshal(b []byte) error + func (this *LokiSeriesResponse) Equal(that interface{}) bool + func (this *LokiSeriesResponse) GoString() string + func (this *LokiSeriesResponse) String() string + type LokiSeriesResponseView struct + func GetLokiSeriesResponseView(data []byte) (view *LokiSeriesResponseView, err error) + func (v *LokiSeriesResponseView) ForEachSeries(fn func(view *SeriesIdentifierView) error) error + func (v *LokiSeriesResponseView) GetHeaders() []*queryrangebase.PrometheusResponseHeader + func (v *LokiSeriesResponseView) ProtoMessage() + func (v *LokiSeriesResponseView) Reset() + func (v *LokiSeriesResponseView) SetHeader(name, value string) + func (v *LokiSeriesResponseView) String() string + func (v *LokiSeriesResponseView) WithHeaders(h []queryrangebase.PrometheusResponseHeader) queryrangebase.Response + type MergedSeriesResponseView struct + func (v *MergedSeriesResponseView) ForEachUniqueSeries(fn func(*SeriesIdentifierView) error) error + func (v *MergedSeriesResponseView) GetHeaders() []*queryrangebase.PrometheusResponseHeader + func (v *MergedSeriesResponseView) Materialize() (*LokiSeriesResponse, error) + func (v *MergedSeriesResponseView) ProtoMessage() + func (v *MergedSeriesResponseView) Reset() + func (v *MergedSeriesResponseView) SetHeader(name, value string) + func (v *MergedSeriesResponseView) String() string + func (v *MergedSeriesResponseView) WithHeaders(headers []queryrangebase.PrometheusResponseHeader) queryrangebase.Response + type Metrics struct + func NewMetrics(registerer prometheus.Registerer, metricsNamespace string) *Metrics + type MiddlewareMapperMetrics struct + func NewMiddlewareMapperMetrics(registerer prometheus.Registerer) *MiddlewareMapperMetrics + type Plan struct + Raw []byte + func (*Plan) Descriptor() ([]byte, []int) + func (*Plan) ProtoMessage() + func (m *Plan) GetRaw() []byte + func (m *Plan) Marshal() (dAtA []byte, err error) + func (m *Plan) MarshalTo(dAtA []byte) (int, error) + func (m *Plan) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Plan) Reset() + func (m *Plan) Size() (n int) + func (m *Plan) Unmarshal(dAtA []byte) error + func (m *Plan) XXX_DiscardUnknown() + func (m *Plan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Plan) XXX_Merge(src proto.Message) + func (m *Plan) XXX_Size() int + func (m *Plan) XXX_Unmarshal(b []byte) error + func (this *Plan) Equal(that interface{}) bool + func (this *Plan) GoString() string + func (this *Plan) String() string + type PrometheusExtractor struct + func (PrometheusExtractor) Extract(start, end int64, res resultscache.Response, resStart, resEnd int64) resultscache.Response + func (PrometheusExtractor) ResponseWithoutHeaders(resp queryrangebase.Response) queryrangebase.Response + type QuantileSketchResponse struct + Headers []github_com_grafana_loki_v3_pkg_querier_queryrange_queryrangebase_definitions.PrometheusResponseHeader + Response *github_com_grafana_loki_v3_pkg_logproto.QuantileSketchMatrix + Warnings []string + func (*QuantileSketchResponse) Descriptor() ([]byte, []int) + func (*QuantileSketchResponse) ProtoMessage() + func (m *QuantileSketchResponse) GetHeaders() []*queryrangebase.PrometheusResponseHeader + func (m *QuantileSketchResponse) GetWarnings() []string + func (m *QuantileSketchResponse) Marshal() (dAtA []byte, err error) + func (m *QuantileSketchResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QuantileSketchResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QuantileSketchResponse) Reset() + func (m *QuantileSketchResponse) SetHeader(name, value string) + func (m *QuantileSketchResponse) Size() (n int) + func (m *QuantileSketchResponse) Unmarshal(dAtA []byte) error + func (m *QuantileSketchResponse) WithHeaders(h []queryrangebase.PrometheusResponseHeader) queryrangebase.Response + func (m *QuantileSketchResponse) XXX_DiscardUnknown() + func (m *QuantileSketchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QuantileSketchResponse) XXX_Merge(src proto.Message) + func (m *QuantileSketchResponse) XXX_Size() int + func (m *QuantileSketchResponse) XXX_Unmarshal(b []byte) error + func (this *QuantileSketchResponse) Equal(that interface{}) bool + func (this *QuantileSketchResponse) GoString() string + func (this *QuantileSketchResponse) String() string + type QueryMetrics struct + func NewMiddlewareQueryMetrics(registerer prometheus.Registerer, metricsNamespace string) *QueryMetrics + type QueryPatternsResponse struct + Headers []github_com_grafana_loki_v3_pkg_querier_queryrange_queryrangebase_definitions.PrometheusResponseHeader + Response *github_com_grafana_loki_v3_pkg_logproto.QueryPatternsResponse + func (*QueryPatternsResponse) Descriptor() ([]byte, []int) + func (*QueryPatternsResponse) ProtoMessage() + func (m *QueryPatternsResponse) GetHeaders() []*queryrangebase.PrometheusResponseHeader + func (m *QueryPatternsResponse) Marshal() (dAtA []byte, err error) + func (m *QueryPatternsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryPatternsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryPatternsResponse) Reset() + func (m *QueryPatternsResponse) SetHeader(name, value string) + func (m *QueryPatternsResponse) Size() (n int) + func (m *QueryPatternsResponse) Unmarshal(dAtA []byte) error + func (m *QueryPatternsResponse) WithHeaders(h []queryrangebase.PrometheusResponseHeader) queryrangebase.Response + func (m *QueryPatternsResponse) XXX_DiscardUnknown() + func (m *QueryPatternsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryPatternsResponse) XXX_Merge(src proto.Message) + func (m *QueryPatternsResponse) XXX_Size() int + func (m *QueryPatternsResponse) XXX_Unmarshal(b []byte) error + func (this *QueryPatternsResponse) Equal(that interface{}) bool + func (this *QueryPatternsResponse) GoString() string + func (this *QueryPatternsResponse) String() string + type QueryRequest struct + Metadata map[string]string + Request isQueryRequest_Request + func (*QueryRequest) Descriptor() ([]byte, []int) + func (*QueryRequest) ProtoMessage() + func (*QueryRequest) XXX_OneofWrappers() []interface{} + func (m *QueryRequest) GetDetectedFields() *logproto.DetectedFieldsRequest + func (m *QueryRequest) GetDetectedLabels() *logproto.DetectedLabelsRequest + func (m *QueryRequest) GetInstant() *LokiInstantRequest + func (m *QueryRequest) GetLabels() *logproto.LabelRequest + func (m *QueryRequest) GetMetadata() map[string]string + func (m *QueryRequest) GetPatternsRequest() *logproto.QueryPatternsRequest + func (m *QueryRequest) GetRequest() isQueryRequest_Request + func (m *QueryRequest) GetSeries() *LokiSeriesRequest + func (m *QueryRequest) GetShardsRequest() *logproto.ShardsRequest + func (m *QueryRequest) GetStats() *logproto.IndexStatsRequest + func (m *QueryRequest) GetStreams() *LokiRequest + func (m *QueryRequest) GetVolume() *logproto.VolumeRequest + func (m *QueryRequest) Marshal() (dAtA []byte, err error) + func (m *QueryRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryRequest) Reset() + func (m *QueryRequest) Size() (n int) + func (m *QueryRequest) Unmarshal(dAtA []byte) error + func (m *QueryRequest) XXX_DiscardUnknown() + func (m *QueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryRequest) XXX_Merge(src proto.Message) + func (m *QueryRequest) XXX_Size() int + func (m *QueryRequest) XXX_Unmarshal(b []byte) error + func (this *QueryRequest) Equal(that interface{}) bool + func (this *QueryRequest) GoString() string + func (this *QueryRequest) String() string + type QueryRequest_DetectedFields struct + DetectedFields *logproto.DetectedFieldsRequest + func (m *QueryRequest_DetectedFields) MarshalTo(dAtA []byte) (int, error) + func (m *QueryRequest_DetectedFields) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryRequest_DetectedFields) Size() (n int) + func (this *QueryRequest_DetectedFields) Equal(that interface{}) bool + func (this *QueryRequest_DetectedFields) GoString() string + func (this *QueryRequest_DetectedFields) String() string + type QueryRequest_DetectedLabels struct + DetectedLabels *logproto.DetectedLabelsRequest + func (m *QueryRequest_DetectedLabels) MarshalTo(dAtA []byte) (int, error) + func (m *QueryRequest_DetectedLabels) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryRequest_DetectedLabels) Size() (n int) + func (this *QueryRequest_DetectedLabels) Equal(that interface{}) bool + func (this *QueryRequest_DetectedLabels) GoString() string + func (this *QueryRequest_DetectedLabels) String() string + type QueryRequest_Instant struct + Instant *LokiInstantRequest + func (m *QueryRequest_Instant) MarshalTo(dAtA []byte) (int, error) + func (m *QueryRequest_Instant) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryRequest_Instant) Size() (n int) + func (this *QueryRequest_Instant) Equal(that interface{}) bool + func (this *QueryRequest_Instant) GoString() string + func (this *QueryRequest_Instant) String() string + type QueryRequest_Labels struct + Labels *logproto.LabelRequest + func (m *QueryRequest_Labels) MarshalTo(dAtA []byte) (int, error) + func (m *QueryRequest_Labels) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryRequest_Labels) Size() (n int) + func (this *QueryRequest_Labels) Equal(that interface{}) bool + func (this *QueryRequest_Labels) GoString() string + func (this *QueryRequest_Labels) String() string + type QueryRequest_PatternsRequest struct + PatternsRequest *logproto.QueryPatternsRequest + func (m *QueryRequest_PatternsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryRequest_PatternsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryRequest_PatternsRequest) Size() (n int) + func (this *QueryRequest_PatternsRequest) Equal(that interface{}) bool + func (this *QueryRequest_PatternsRequest) GoString() string + func (this *QueryRequest_PatternsRequest) String() string + type QueryRequest_Series struct + Series *LokiSeriesRequest + func (m *QueryRequest_Series) MarshalTo(dAtA []byte) (int, error) + func (m *QueryRequest_Series) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryRequest_Series) Size() (n int) + func (this *QueryRequest_Series) Equal(that interface{}) bool + func (this *QueryRequest_Series) GoString() string + func (this *QueryRequest_Series) String() string + type QueryRequest_ShardsRequest struct + ShardsRequest *logproto.ShardsRequest + func (m *QueryRequest_ShardsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryRequest_ShardsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryRequest_ShardsRequest) Size() (n int) + func (this *QueryRequest_ShardsRequest) Equal(that interface{}) bool + func (this *QueryRequest_ShardsRequest) GoString() string + func (this *QueryRequest_ShardsRequest) String() string + type QueryRequest_Stats struct + Stats *logproto.IndexStatsRequest + func (m *QueryRequest_Stats) MarshalTo(dAtA []byte) (int, error) + func (m *QueryRequest_Stats) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryRequest_Stats) Size() (n int) + func (this *QueryRequest_Stats) Equal(that interface{}) bool + func (this *QueryRequest_Stats) GoString() string + func (this *QueryRequest_Stats) String() string + type QueryRequest_Streams struct + Streams *LokiRequest + func (m *QueryRequest_Streams) MarshalTo(dAtA []byte) (int, error) + func (m *QueryRequest_Streams) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryRequest_Streams) Size() (n int) + func (this *QueryRequest_Streams) Equal(that interface{}) bool + func (this *QueryRequest_Streams) GoString() string + func (this *QueryRequest_Streams) String() string + type QueryRequest_Volume struct + Volume *logproto.VolumeRequest + func (m *QueryRequest_Volume) MarshalTo(dAtA []byte) (int, error) + func (m *QueryRequest_Volume) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryRequest_Volume) Size() (n int) + func (this *QueryRequest_Volume) Equal(that interface{}) bool + func (this *QueryRequest_Volume) GoString() string + func (this *QueryRequest_Volume) String() string + type QueryResponse struct + Response isQueryResponse_Response + Status *rpc.Status + func QueryResponseWrap(res queryrangebase.Response) (*QueryResponse, error) + func QueryResponseWrapError(err error) *QueryResponse + func (*QueryResponse) Descriptor() ([]byte, []int) + func (*QueryResponse) ProtoMessage() + func (*QueryResponse) XXX_OneofWrappers() []interface{} + func (m *QueryResponse) GetDetectedFields() *DetectedFieldsResponse + func (m *QueryResponse) GetDetectedLabels() *DetectedLabelsResponse + func (m *QueryResponse) GetLabels() *LokiLabelNamesResponse + func (m *QueryResponse) GetPatternsResponse() *QueryPatternsResponse + func (m *QueryResponse) GetProm() *LokiPromResponse + func (m *QueryResponse) GetQuantileSketches() *QuantileSketchResponse + func (m *QueryResponse) GetResponse() isQueryResponse_Response + func (m *QueryResponse) GetSeries() *LokiSeriesResponse + func (m *QueryResponse) GetShardsResponse() *ShardsResponse + func (m *QueryResponse) GetStats() *IndexStatsResponse + func (m *QueryResponse) GetStatus() *rpc.Status + func (m *QueryResponse) GetStreams() *LokiResponse + func (m *QueryResponse) GetTopkSketches() *TopKSketchesResponse + func (m *QueryResponse) GetVolume() *VolumeResponse + func (m *QueryResponse) Marshal() (dAtA []byte, err error) + func (m *QueryResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryResponse) Reset() + func (m *QueryResponse) Size() (n int) + func (m *QueryResponse) Unmarshal(dAtA []byte) error + func (m *QueryResponse) XXX_DiscardUnknown() + func (m *QueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryResponse) XXX_Merge(src proto.Message) + func (m *QueryResponse) XXX_Size() int + func (m *QueryResponse) XXX_Unmarshal(b []byte) error + func (this *QueryResponse) Equal(that interface{}) bool + func (this *QueryResponse) GoString() string + func (this *QueryResponse) String() string + type QueryResponse_DetectedFields struct + DetectedFields *DetectedFieldsResponse + func (m *QueryResponse_DetectedFields) MarshalTo(dAtA []byte) (int, error) + func (m *QueryResponse_DetectedFields) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryResponse_DetectedFields) Size() (n int) + func (this *QueryResponse_DetectedFields) Equal(that interface{}) bool + func (this *QueryResponse_DetectedFields) GoString() string + func (this *QueryResponse_DetectedFields) String() string + type QueryResponse_DetectedLabels struct + DetectedLabels *DetectedLabelsResponse + func (m *QueryResponse_DetectedLabels) MarshalTo(dAtA []byte) (int, error) + func (m *QueryResponse_DetectedLabels) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryResponse_DetectedLabels) Size() (n int) + func (this *QueryResponse_DetectedLabels) Equal(that interface{}) bool + func (this *QueryResponse_DetectedLabels) GoString() string + func (this *QueryResponse_DetectedLabels) String() string + type QueryResponse_Labels struct + Labels *LokiLabelNamesResponse + func (m *QueryResponse_Labels) MarshalTo(dAtA []byte) (int, error) + func (m *QueryResponse_Labels) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryResponse_Labels) Size() (n int) + func (this *QueryResponse_Labels) Equal(that interface{}) bool + func (this *QueryResponse_Labels) GoString() string + func (this *QueryResponse_Labels) String() string + type QueryResponse_PatternsResponse struct + PatternsResponse *QueryPatternsResponse + func (m *QueryResponse_PatternsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryResponse_PatternsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryResponse_PatternsResponse) Size() (n int) + func (this *QueryResponse_PatternsResponse) Equal(that interface{}) bool + func (this *QueryResponse_PatternsResponse) GoString() string + func (this *QueryResponse_PatternsResponse) String() string + type QueryResponse_Prom struct + Prom *LokiPromResponse + func (m *QueryResponse_Prom) MarshalTo(dAtA []byte) (int, error) + func (m *QueryResponse_Prom) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryResponse_Prom) Size() (n int) + func (this *QueryResponse_Prom) Equal(that interface{}) bool + func (this *QueryResponse_Prom) GoString() string + func (this *QueryResponse_Prom) String() string + type QueryResponse_QuantileSketches struct + QuantileSketches *QuantileSketchResponse + func (m *QueryResponse_QuantileSketches) MarshalTo(dAtA []byte) (int, error) + func (m *QueryResponse_QuantileSketches) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryResponse_QuantileSketches) Size() (n int) + func (this *QueryResponse_QuantileSketches) Equal(that interface{}) bool + func (this *QueryResponse_QuantileSketches) GoString() string + func (this *QueryResponse_QuantileSketches) String() string + type QueryResponse_Series struct + Series *LokiSeriesResponse + func (m *QueryResponse_Series) MarshalTo(dAtA []byte) (int, error) + func (m *QueryResponse_Series) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryResponse_Series) Size() (n int) + func (this *QueryResponse_Series) Equal(that interface{}) bool + func (this *QueryResponse_Series) GoString() string + func (this *QueryResponse_Series) String() string + type QueryResponse_ShardsResponse struct + ShardsResponse *ShardsResponse + func (m *QueryResponse_ShardsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryResponse_ShardsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryResponse_ShardsResponse) Size() (n int) + func (this *QueryResponse_ShardsResponse) Equal(that interface{}) bool + func (this *QueryResponse_ShardsResponse) GoString() string + func (this *QueryResponse_ShardsResponse) String() string + type QueryResponse_Stats struct + Stats *IndexStatsResponse + func (m *QueryResponse_Stats) MarshalTo(dAtA []byte) (int, error) + func (m *QueryResponse_Stats) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryResponse_Stats) Size() (n int) + func (this *QueryResponse_Stats) Equal(that interface{}) bool + func (this *QueryResponse_Stats) GoString() string + func (this *QueryResponse_Stats) String() string + type QueryResponse_Streams struct + Streams *LokiResponse + func (m *QueryResponse_Streams) MarshalTo(dAtA []byte) (int, error) + func (m *QueryResponse_Streams) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryResponse_Streams) Size() (n int) + func (this *QueryResponse_Streams) Equal(that interface{}) bool + func (this *QueryResponse_Streams) GoString() string + func (this *QueryResponse_Streams) String() string + type QueryResponse_TopkSketches struct + TopkSketches *TopKSketchesResponse + func (m *QueryResponse_TopkSketches) MarshalTo(dAtA []byte) (int, error) + func (m *QueryResponse_TopkSketches) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryResponse_TopkSketches) Size() (n int) + func (this *QueryResponse_TopkSketches) Equal(that interface{}) bool + func (this *QueryResponse_TopkSketches) GoString() string + func (this *QueryResponse_TopkSketches) String() string + type QueryResponse_Volume struct + Volume *VolumeResponse + func (m *QueryResponse_Volume) MarshalTo(dAtA []byte) (int, error) + func (m *QueryResponse_Volume) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryResponse_Volume) Size() (n int) + func (this *QueryResponse_Volume) Equal(that interface{}) bool + func (this *QueryResponse_Volume) GoString() string + func (this *QueryResponse_Volume) String() string + type RequestProtobufCodec struct + func (p RequestProtobufCodec) EncodeRequest(ctx context.Context, r queryrangebase.Request) (*http.Request, error) + type SemaphoreWithTiming struct + func NewSemaphoreWithTiming(max int64) *SemaphoreWithTiming + func (s *SemaphoreWithTiming) Acquire(ctx context.Context, n int64) (time.Duration, error) + type SeriesCacheConfig struct + func (cfg *SeriesCacheConfig) RegisterFlags(f *flag.FlagSet) + func (cfg *SeriesCacheConfig) Validate() error + type SeriesIdentifierView struct + func (v *SeriesIdentifierView) ForEachLabel(fn func(string, string) error) error + func (v *SeriesIdentifierView) Hash(b []byte, keyLabelPairs []string) (uint64, []string, error) + func (v *SeriesIdentifierView) HashFast(b []byte, keyLabelPairs []string) (uint64, []string, error) + type ShardingConfigs []config.PeriodConfig + func (confs ShardingConfigs) GetConf(start, end int64) (config.PeriodConfig, error) + func (confs ShardingConfigs) ValidRange(start, end int64) (config.PeriodConfig, error) + type ShardsResponse struct + Headers []github_com_grafana_loki_v3_pkg_querier_queryrange_queryrangebase_definitions.PrometheusResponseHeader + Response *github_com_grafana_loki_v3_pkg_logproto.ShardsResponse + func (*ShardsResponse) Descriptor() ([]byte, []int) + func (*ShardsResponse) ProtoMessage() + func (m *ShardsResponse) GetHeaders() []*queryrangebase.PrometheusResponseHeader + func (m *ShardsResponse) Marshal() (dAtA []byte, err error) + func (m *ShardsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ShardsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ShardsResponse) Reset() + func (m *ShardsResponse) SetHeader(name, value string) + func (m *ShardsResponse) Size() (n int) + func (m *ShardsResponse) Unmarshal(dAtA []byte) error + func (m *ShardsResponse) WithHeaders(h []queryrangebase.PrometheusResponseHeader) queryrangebase.Response + func (m *ShardsResponse) XXX_DiscardUnknown() + func (m *ShardsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShardsResponse) XXX_Merge(src proto.Message) + func (m *ShardsResponse) XXX_Size() int + func (m *ShardsResponse) XXX_Unmarshal(b []byte) error + func (this *ShardsResponse) Equal(that interface{}) bool + func (this *ShardsResponse) GoString() string + func (this *ShardsResponse) String() string + type SplitByMetrics struct + func NewSplitByMetrics(r prometheus.Registerer) *SplitByMetrics + type Stopper interface + Stop func() + func NewMiddleware(cfg Config, engineOpts logql.EngineOpts, iqo util.IngesterQueryOptions, ...) (base.Middleware, Stopper, error) + type StopperWrapper []Stopper + func (s StopperWrapper) Stop() + type TopKSketchesResponse struct + Headers []github_com_grafana_loki_v3_pkg_querier_queryrange_queryrangebase_definitions.PrometheusResponseHeader + Response *github_com_grafana_loki_v3_pkg_logproto.TopKMatrix + Warnings []string + func (*TopKSketchesResponse) Descriptor() ([]byte, []int) + func (*TopKSketchesResponse) ProtoMessage() + func (m *TopKSketchesResponse) GetHeaders() []*queryrangebase.PrometheusResponseHeader + func (m *TopKSketchesResponse) GetWarnings() []string + func (m *TopKSketchesResponse) Marshal() (dAtA []byte, err error) + func (m *TopKSketchesResponse) MarshalTo(dAtA []byte) (int, error) + func (m *TopKSketchesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TopKSketchesResponse) Reset() + func (m *TopKSketchesResponse) SetHeader(name, value string) + func (m *TopKSketchesResponse) Size() (n int) + func (m *TopKSketchesResponse) Unmarshal(dAtA []byte) error + func (m *TopKSketchesResponse) WithHeaders(h []queryrangebase.PrometheusResponseHeader) queryrangebase.Response + func (m *TopKSketchesResponse) XXX_DiscardUnknown() + func (m *TopKSketchesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TopKSketchesResponse) XXX_Merge(src proto.Message) + func (m *TopKSketchesResponse) XXX_Size() int + func (m *TopKSketchesResponse) XXX_Unmarshal(b []byte) error + func (this *TopKSketchesResponse) Equal(that interface{}) bool + func (this *TopKSketchesResponse) GoString() string + func (this *TopKSketchesResponse) String() string + type Tracer struct + func (t Tracer) Wrap(next queryrangebase.Handler) queryrangebase.Handler + type UserIDTransformer func(context.Context, string) string + type VolumeCacheConfig struct + func (cfg *VolumeCacheConfig) RegisterFlags(f *flag.FlagSet) + func (cfg *VolumeCacheConfig) Validate() error + type VolumeExtractor struct + func (p VolumeExtractor) Extract(start, end int64, res resultscache.Response, resStart, resEnd int64) resultscache.Response + func (p VolumeExtractor) ResponseWithoutHeaders(resp queryrangebase.Response) queryrangebase.Response + type VolumeResponse struct + Headers []github_com_grafana_loki_v3_pkg_querier_queryrange_queryrangebase_definitions.PrometheusResponseHeader + Response *github_com_grafana_loki_v3_pkg_logproto.VolumeResponse + func (*VolumeResponse) Descriptor() ([]byte, []int) + func (*VolumeResponse) ProtoMessage() + func (m *VolumeResponse) GetHeaders() []*queryrangebase.PrometheusResponseHeader + func (m *VolumeResponse) Marshal() (dAtA []byte, err error) + func (m *VolumeResponse) MarshalTo(dAtA []byte) (int, error) + func (m *VolumeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *VolumeResponse) Reset() + func (m *VolumeResponse) SetHeader(name, value string) + func (m *VolumeResponse) Size() (n int) + func (m *VolumeResponse) Unmarshal(dAtA []byte) error + func (m *VolumeResponse) WithHeaders(h []queryrangebase.PrometheusResponseHeader) queryrangebase.Response + func (m *VolumeResponse) XXX_DiscardUnknown() + func (m *VolumeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *VolumeResponse) XXX_Merge(src proto.Message) + func (m *VolumeResponse) XXX_Size() int + func (m *VolumeResponse) XXX_Unmarshal(b []byte) error + func (this *VolumeResponse) Equal(that interface{}) bool + func (this *VolumeResponse) GoString() string + func (this *VolumeResponse) String() string + type VolumeSplitter struct + func (i VolumeSplitter) GenerateCacheKey(ctx context.Context, userID string, r resultscache.Request) string Other modules containing this package github.com/grafana/loki