GetLokiSeriesResponseView returns a view on the series response of a QueryResponse.

NewInstantMetricTripperware creates a new frontend tripperware responsible for handling metric queries.

NewLabelsTripperware creates a new frontend tripperware responsible for handling labels requests.

NewLimitedRoundTripper creates a new roundtripper that enforces MaxQueryParallelism to the `next` roundtripper across `middlewares`.

NewLimitedTripperware creates a new frontend tripperware responsible for handling log requests which are label matcher only, no filter expression.

NewLimitsMiddleware creates a new Middleware that enforces query limits.

NewLogFilterTripperware creates a new frontend tripperware responsible for handling log requests.

NewLogResultCache creates a new log result cache middleware.

NewLogResultCacheMetrics creates metrics to be used in log result cache.

NewMetricTripperware creates a new frontend tripperware responsible for handling metric queries.

NewQuerierSizeLimiterMiddleware creates a new Middleware that enforces query size limits after sharding and splitting.

NewQueryShardMiddleware creates a middleware which downstreams queries after AST mapping and query encoding.

NewQuerySizeLimiterMiddleware creates a new Middleware that enforces query size limits.

NewSeriesQueryShardMiddleware creates a middleware which shards series queries.

NewSeriesTripperware creates a new frontend tripperware responsible for handling series requests.

NewSplitByRangeMiddleware creates a new Middleware that splits log requests by the range interval.

NewTripperware returns a Tripperware configured with middlewares to align, split and cache requests.

ResultToResponse is the reverse of ResponseToResult in downstreamer.

SplitByIntervalMiddleware creates a new Middleware that splits log requests by a given interval.

StatsCollectorMiddleware compute the stats summary based on the actual duration of the request and inject it in the request context.

WeightedParallelism will calculate the request parallelism to use based on the two fields: 1) `max_query_parallelism`: 2) `tsdb_max_query_parallelism`: For instance, if the max_query_parallelism=10, tsdb_max_query_parallelism=100, and the request is equally split between tsdb and non-tsdb period configs, the resulting parallelism will be 0.5 * 10 + 0.5 * 100 = 60.

WithSplitByLimits will construct a Limits with a static split by duration.

WriteIndexStatsResponseProtobuf marshals a gatewaypb.Stats to queryrange IndexStatsResponse and then writes it to the provided io.Writer.

WriteLabelResponseProtobuf marshals a logproto.LabelResponse to queryrange LokiLabelNamesResponse and then writes it to the provided io.Writer.

WriteQueryResponseProtobuf marshals the promql.Value to queryrange QueryResonse and then writes it to the provided io.Writer.

WriteSeriesResponseProtobuf marshals a logproto.SeriesResponse to queryrange LokiSeriesResponse and then writes it to the provided io.Writer.

WriteSeriesResponseViewJSON writes a JSON response to the supplied write that is equivalent to marshal.WriteSeriesResponseJSON.

WriteIndexStatsResponseProtobuf marshals a logproto.VolumeResponse to queryrange.QueryResponse and then writes it to the provided io.Writer.

Config is the configuration for the queryrange tripperware.

LogResultCacheMetrics is the metrics wrapper used in log result cache.

LokiPromResponse wraps a Prometheus response with statistics.

LokiSeriesResponseView holds the raw bytes of a LokiSeriesResponse protobuf message.

MergedSeriesResponseView holds references to all series responses that should be merged before serialization to JSON.

PrometheusExtractor implements Extractor interface.

SeriesIdentifierView holds the raw bytes of a logproto.SeriesIdentifier protobuf message.

Limits extends the cortex limits interface with support for per tenant splitby parameters.

Stopper gracefully shutdown resources created.

ShardingConfigs is a slice of chunk shard configs.