queryrange

Nov 10, 2025

Changes in this version

type Config

+ DynamicQuerySplitsConfig DynamicQuerySplitsConfig

+ type DynamicQuerySplitsConfig struct

+ EnableDynamicVerticalSharding bool

+ MaxFetchedDataDurationPerQuery time.Duration

+ MaxShardsPerQuery int

+ func (cfg *DynamicQuerySplitsConfig) RegisterFlags(f *flag.FlagSet)

Feb 27, 2025

Changes in this version

type PrometheusResponse

+ Infos []string

+ func (m *PrometheusResponse) GetInfos() []string

Sep 3, 2024

Changes in this version

type PrometheusResponse

+ Warnings []string

+ func (m *PrometheusResponse) GetWarnings() []string

Nov 19, 2023

Changes in this version

+ func NewPrometheusCodec(sharded bool) *prometheusCodec

Dec 2, 2022 GO-2022-1175

  GO-2022-1175: Exposure of local files in github.com/cortexproject/cortex

Changes in this version

+ const StatusSuccess

+ var ErrIntOverflowQueryrange = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthQueryrange = fmt.Errorf("proto: negative length found during unmarshaling")

+ var PrometheusCodec tripperware.Codec = &prometheusCodec

+ var ResultsCacheGenNumberHeaderName = "Results-Cache-Gen-Number"

+ var ShardedPrometheusCodec tripperware.Codec = &prometheusCodec

+ var StepAlignMiddleware = tripperware.MiddlewareFunc(func(next tripperware.Handler) tripperware.Handler { ... })

+ func FromResult(res *promql.Result) ([]tripperware.SampleStream, error)

+ func Middlewares(cfg Config, log log.Logger, limits tripperware.Limits, ...) ([]tripperware.Middleware, cache.Cache, error)

+ func NewLimitsMiddleware(l tripperware.Limits) tripperware.Middleware

+ func NewResultsCacheMiddleware(logger log.Logger, cfg ResultsCacheConfig, splitter CacheSplitter, ...) (tripperware.Middleware, cache.Cache, error)

+ func NewRetryMiddleware(log log.Logger, maxRetries int, metrics *RetryMiddlewareMetrics) tripperware.Middleware

+ func NewSeriesSet(sortSeries bool, results []tripperware.SampleStream) storage.SeriesSet

+ func ResponseToSamples(resp tripperware.Response) ([]tripperware.SampleStream, error)

+ func SplitByIntervalMiddleware(interval IntervalFn, limits tripperware.Limits, merger tripperware.Merger, ...) tripperware.Middleware

+ type CacheGenNumberLoader interface

+ GetResultsCacheGenNumber func(tenantIDs []string) string

+ type CacheSplitter interface

+ GenerateCacheKey func(userID string, r tripperware.Request) string

+ type CachedResponse struct

+ Extents []Extent

+ Key string

+ func (*CachedResponse) Descriptor() ([]byte, []int)

+ func (*CachedResponse) ProtoMessage()

+ func (m *CachedResponse) GetExtents() []Extent

+ func (m *CachedResponse) GetKey() string

+ func (m *CachedResponse) Marshal() (dAtA []byte, err error)

+ func (m *CachedResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *CachedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CachedResponse) Reset()

+ func (m *CachedResponse) Size() (n int)

+ func (m *CachedResponse) Unmarshal(dAtA []byte) error

+ func (m *CachedResponse) XXX_DiscardUnknown()

+ func (m *CachedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CachedResponse) XXX_Merge(src proto.Message)

+ func (m *CachedResponse) XXX_Size() int

+ func (m *CachedResponse) XXX_Unmarshal(b []byte) error

+ func (this *CachedResponse) Equal(that interface{}) bool

+ func (this *CachedResponse) GoString() string

+ func (this *CachedResponse) String() string

+ type CachingOptions struct

+ Disabled bool

+ func (*CachingOptions) Descriptor() ([]byte, []int)

+ func (*CachingOptions) ProtoMessage()

+ func (m *CachingOptions) GetDisabled() bool

+ func (m *CachingOptions) Marshal() (dAtA []byte, err error)

+ func (m *CachingOptions) MarshalTo(dAtA []byte) (int, error)

+ func (m *CachingOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CachingOptions) Reset()

+ func (m *CachingOptions) Size() (n int)

+ func (m *CachingOptions) Unmarshal(dAtA []byte) error

+ func (m *CachingOptions) XXX_DiscardUnknown()

+ func (m *CachingOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CachingOptions) XXX_Merge(src proto.Message)

+ func (m *CachingOptions) XXX_Size() int

+ func (m *CachingOptions) XXX_Unmarshal(b []byte) error

+ func (this *CachingOptions) Equal(that interface{}) bool

+ func (this *CachingOptions) GoString() string

+ func (this *CachingOptions) String() string

+ type Config struct

+ AlignQueriesWithStep bool

+ CacheResults bool

+ ForwardHeaders flagext.StringSlice

+ MaxRetries int

+ SplitQueriesByInterval time.Duration

+ VerticalShardSize int

+ func (cfg *Config) RegisterFlags(f *flag.FlagSet)

+ func (cfg *Config) Validate(qCfg querier.Config) error

+ type Extent struct

+ End int64

+ Response *types.Any

+ Start int64

+ TraceId string

+ func (*Extent) Descriptor() ([]byte, []int)

+ func (*Extent) ProtoMessage()

+ func (m *Extent) GetEnd() int64

+ func (m *Extent) GetResponse() *types.Any

+ func (m *Extent) GetStart() int64

+ func (m *Extent) GetTraceId() string

+ func (m *Extent) Marshal() (dAtA []byte, err error)

+ func (m *Extent) MarshalTo(dAtA []byte) (int, error)

+ func (m *Extent) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Extent) Reset()

+ func (m *Extent) Size() (n int)

+ func (m *Extent) Unmarshal(dAtA []byte) error

+ func (m *Extent) XXX_DiscardUnknown()

+ func (m *Extent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Extent) XXX_Merge(src proto.Message)

+ func (m *Extent) XXX_Size() int

+ func (m *Extent) XXX_Unmarshal(b []byte) error

+ func (this *Extent) Equal(that interface{}) bool

+ func (this *Extent) GoString() string

+ func (this *Extent) String() string

+ type Extractor interface

+ Extract func(start, end int64, from tripperware.Response) tripperware.Response

+ ResponseWithoutHeaders func(resp tripperware.Response) tripperware.Response

+ ResponseWithoutStats func(resp tripperware.Response) tripperware.Response

+ type IntervalFn func(r tripperware.Request) time.Duration

+ type PrometheusData struct

+ Result []tripperware.SampleStream

+ ResultType string

+ Stats *tripperware.PrometheusResponseStats

+ func (*PrometheusData) Descriptor() ([]byte, []int)

+ func (*PrometheusData) ProtoMessage()

+ func (m *PrometheusData) GetResult() []tripperware.SampleStream

+ func (m *PrometheusData) GetResultType() string

+ func (m *PrometheusData) GetStats() *tripperware.PrometheusResponseStats

+ func (m *PrometheusData) Marshal() (dAtA []byte, err error)

+ func (m *PrometheusData) MarshalTo(dAtA []byte) (int, error)

+ func (m *PrometheusData) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PrometheusData) Reset()

+ func (m *PrometheusData) Size() (n int)

+ func (m *PrometheusData) Unmarshal(dAtA []byte) error

+ func (m *PrometheusData) XXX_DiscardUnknown()

+ func (m *PrometheusData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PrometheusData) XXX_Merge(src proto.Message)

+ func (m *PrometheusData) XXX_Size() int

+ func (m *PrometheusData) XXX_Unmarshal(b []byte) error

+ func (this *PrometheusData) Equal(that interface{}) bool

+ func (this *PrometheusData) GoString() string

+ func (this *PrometheusData) String() string

+ type PrometheusRequest struct

+ CachingOptions CachingOptions

+ End int64

+ Headers []*tripperware.PrometheusRequestHeader

+ Path string

+ Query string

+ Start int64

+ Stats string

+ Step int64

+ Timeout time.Duration

+ func (*PrometheusRequest) Descriptor() ([]byte, []int)

+ func (*PrometheusRequest) ProtoMessage()

+ func (m *PrometheusRequest) GetCachingOptions() CachingOptions

+ func (m *PrometheusRequest) GetEnd() int64

+ func (m *PrometheusRequest) GetHeaders() []*tripperware.PrometheusRequestHeader

+ func (m *PrometheusRequest) GetPath() string

+ func (m *PrometheusRequest) GetQuery() string

+ func (m *PrometheusRequest) GetStart() int64

+ func (m *PrometheusRequest) GetStats() string

+ func (m *PrometheusRequest) GetStep() int64

+ func (m *PrometheusRequest) GetTimeout() time.Duration

+ func (m *PrometheusRequest) Marshal() (dAtA []byte, err error)

+ func (m *PrometheusRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *PrometheusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PrometheusRequest) Reset()

+ func (m *PrometheusRequest) Size() (n int)

+ func (m *PrometheusRequest) Unmarshal(dAtA []byte) error

+ func (m *PrometheusRequest) XXX_DiscardUnknown()

+ func (m *PrometheusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PrometheusRequest) XXX_Merge(src proto.Message)

+ func (m *PrometheusRequest) XXX_Size() int

+ func (m *PrometheusRequest) XXX_Unmarshal(b []byte) error

+ func (q *PrometheusRequest) LogToSpan(sp opentracing.Span)

+ func (q *PrometheusRequest) WithQuery(query string) tripperware.Request

+ func (q *PrometheusRequest) WithStartEnd(start int64, end int64) tripperware.Request

+ func (q *PrometheusRequest) WithStats(stats string) tripperware.Request

+ func (this *PrometheusRequest) Equal(that interface{}) bool

+ func (this *PrometheusRequest) GoString() string

+ func (this *PrometheusRequest) String() string

+ type PrometheusResponse struct

+ Data PrometheusData

+ Error string

+ ErrorType string

+ Headers []*tripperware.PrometheusResponseHeader

+ Status string

+ func NewEmptyPrometheusResponse() *PrometheusResponse

+ func (*PrometheusResponse) Descriptor() ([]byte, []int)

+ func (*PrometheusResponse) ProtoMessage()

+ func (m *PrometheusResponse) GetData() PrometheusData

+ func (m *PrometheusResponse) GetError() string

+ func (m *PrometheusResponse) GetErrorType() string

+ func (m *PrometheusResponse) GetHeaders() []*tripperware.PrometheusResponseHeader

+ func (m *PrometheusResponse) GetStatus() string

+ func (m *PrometheusResponse) Marshal() (dAtA []byte, err error)

+ func (m *PrometheusResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *PrometheusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PrometheusResponse) Reset()

+ func (m *PrometheusResponse) Size() (n int)

+ func (m *PrometheusResponse) Unmarshal(dAtA []byte) error

+ func (m *PrometheusResponse) XXX_DiscardUnknown()

+ func (m *PrometheusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PrometheusResponse) XXX_Merge(src proto.Message)

+ func (m *PrometheusResponse) XXX_Size() int

+ func (m *PrometheusResponse) XXX_Unmarshal(b []byte) error

+ func (resp *PrometheusResponse) HTTPHeaders() map[string][]string

+ func (this *PrometheusResponse) Equal(that interface{}) bool

+ func (this *PrometheusResponse) GoString() string

+ func (this *PrometheusResponse) String() string

+ type PrometheusResponseExtractor struct

+ func (PrometheusResponseExtractor) Extract(start, end int64, from tripperware.Response) tripperware.Response

+ func (PrometheusResponseExtractor) ResponseWithoutHeaders(resp tripperware.Response) tripperware.Response

+ func (PrometheusResponseExtractor) ResponseWithoutStats(resp tripperware.Response) tripperware.Response

+ type ResultsCacheConfig struct

+ CacheConfig cache.Config

+ CacheQueryableSamplesStats bool

+ Compression string

+ func (cfg *ResultsCacheConfig) RegisterFlags(f *flag.FlagSet)

+ func (cfg *ResultsCacheConfig) Validate(qCfg querier.Config) error

+ type RetryMiddlewareMetrics struct

+ func NewRetryMiddlewareMetrics(registerer prometheus.Registerer) *RetryMiddlewareMetrics

+ type ShouldCacheFn func(r tripperware.Request) bool