Versions in this module Expand all Collapse all v0 v0.26.0 Apr 9, 2022 Changes in this version + var DefaultRedisConfig = RedisResponseCacheConfig + var ErrIntOverflowResponse = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthResponse = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupResponse = fmt.Errorf("proto: unexpected end of group") + func DownsampledMiddleware(merger queryrange.Merger, registerer prometheus.Registerer) queryrange.Middleware + func NewCacheConfig(logger log.Logger, confContentYaml []byte) (*cortexcache.Config, error) + func NewThanosLabelsCodec(partialResponse bool, defaultMetadataTimeRange time.Duration) *labelsCodec + func NewThanosQueryRangeCodec(partialResponse bool) *queryRangeCodec + func NewTripperware(config Config, reg prometheus.Registerer, logger log.Logger) (queryrange.Tripperware, error) + func SplitByIntervalMiddleware(interval queryrange.IntervalFn, limits queryrange.Limits, ...) queryrange.Middleware + type CacheProviderConfig struct + Config interface{} + Type ResponseCacheProvider + type Config struct + CacheCompression string + CompressResponses bool + CortexHandlerConfig *transport.HandlerConfig + DownstreamURL string + ForwardHeaders []string + RequestLoggingDecision string + func (cfg *Config) Validate() error + type DownstreamTripperConfig struct + CachePathOrContent extflag.PathOrContent + ExpectContinueTimeout prommodel.Duration + IdleConnTimeout prommodel.Duration + MaxConnsPerHost *int + MaxIdleConns *int + MaxIdleConnsPerHost *int + ResponseHeaderTimeout prommodel.Duration + TLSHandshakeTimeout prommodel.Duration + type InMemoryResponseCacheConfig struct + MaxSize string + MaxSizeItems int + Validity time.Duration + type LabelsConfig struct + CachePathOrContent extflag.PathOrContent + DefaultTimeRange time.Duration + Limits *cortexvalidation.Limits + MaxRetries int + PartialResponseStrategy bool + ResultsCacheConfig *queryrange.ResultsCacheConfig + SplitQueriesByInterval time.Duration + type MemcachedResponseCacheConfig struct + Expiration time.Duration + Memcached cacheutil.MemcachedClientConfig + type QueryRangeConfig struct + AlignRangeWithStep bool + CachePathOrContent extflag.PathOrContent + Limits *cortexvalidation.Limits + MaxRetries int + PartialResponseStrategy bool + RequestDownsampled bool + ResultsCacheConfig *queryrange.ResultsCacheConfig + SplitQueriesByInterval time.Duration + type RedisResponseCacheConfig struct + Expiration time.Duration + Redis cacheutil.RedisClientConfig + type RequestHeader struct + Name string + Values []string + type ResponseCacheProvider string + const INMEMORY + const MEMCACHED + const REDIS + type ResponseHeader struct + Name string + Values []string + func (*ResponseHeader) Descriptor() ([]byte, []int) + func (*ResponseHeader) ProtoMessage() + func (m *ResponseHeader) Marshal() (dAtA []byte, err error) + func (m *ResponseHeader) MarshalTo(dAtA []byte) (int, error) + func (m *ResponseHeader) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResponseHeader) Reset() + func (m *ResponseHeader) Size() (n int) + func (m *ResponseHeader) String() string + func (m *ResponseHeader) Unmarshal(dAtA []byte) error + func (m *ResponseHeader) XXX_DiscardUnknown() + func (m *ResponseHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResponseHeader) XXX_Merge(src proto.Message) + func (m *ResponseHeader) XXX_Size() int + func (m *ResponseHeader) XXX_Unmarshal(b []byte) error + type ThanosLabelsRequest struct + CachingOptions queryrange.CachingOptions + End int64 + Headers []*RequestHeader + Label string + Matchers [][]*labels.Matcher + PartialResponse bool + Path string + Start int64 + StoreMatchers [][]*labels.Matcher + func (r *ThanosLabelsRequest) GetCachingOptions() queryrange.CachingOptions + func (r *ThanosLabelsRequest) GetEnd() int64 + func (r *ThanosLabelsRequest) GetQuery() string + func (r *ThanosLabelsRequest) GetStart() int64 + func (r *ThanosLabelsRequest) GetStep() int64 + func (r *ThanosLabelsRequest) GetStoreMatchers() [][]*labels.Matcher + func (r *ThanosLabelsRequest) LogToSpan(sp opentracing.Span) + func (r *ThanosLabelsRequest) ProtoMessage() + func (r *ThanosLabelsRequest) Reset() + func (r *ThanosLabelsRequest) String() string + func (r *ThanosLabelsRequest) WithQuery(_ string) queryrange.Request + func (r *ThanosLabelsRequest) WithStartEnd(start, end int64) queryrange.Request + type ThanosLabelsResponse struct + Data []string + Error string + ErrorType string + Headers []*ResponseHeader + Status string + func (*ThanosLabelsResponse) Descriptor() ([]byte, []int) + func (*ThanosLabelsResponse) ProtoMessage() + func (m *ThanosLabelsResponse) GetHeaders() []*queryrange.PrometheusResponseHeader + func (m *ThanosLabelsResponse) Marshal() (dAtA []byte, err error) + func (m *ThanosLabelsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ThanosLabelsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ThanosLabelsResponse) Reset() + func (m *ThanosLabelsResponse) Size() (n int) + func (m *ThanosLabelsResponse) String() string + func (m *ThanosLabelsResponse) Unmarshal(dAtA []byte) error + func (m *ThanosLabelsResponse) XXX_DiscardUnknown() + func (m *ThanosLabelsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ThanosLabelsResponse) XXX_Merge(src proto.Message) + func (m *ThanosLabelsResponse) XXX_Size() int + func (m *ThanosLabelsResponse) XXX_Unmarshal(b []byte) error + type ThanosQueryRangeRequest struct + AutoDownsampling bool + CachingOptions queryrange.CachingOptions + Dedup bool + End int64 + Headers []*RequestHeader + MaxSourceResolution int64 + PartialResponse bool + Path string + Query string + ReplicaLabels []string + Start int64 + Step int64 + StoreMatchers [][]*labels.Matcher + Timeout time.Duration + func (r *ThanosQueryRangeRequest) GetCachingOptions() queryrange.CachingOptions + func (r *ThanosQueryRangeRequest) GetEnd() int64 + func (r *ThanosQueryRangeRequest) GetQuery() string + func (r *ThanosQueryRangeRequest) GetStart() int64 + func (r *ThanosQueryRangeRequest) GetStep() int64 + func (r *ThanosQueryRangeRequest) GetStoreMatchers() [][]*labels.Matcher + func (r *ThanosQueryRangeRequest) LogToSpan(sp opentracing.Span) + func (r *ThanosQueryRangeRequest) ProtoMessage() + func (r *ThanosQueryRangeRequest) Reset() + func (r *ThanosQueryRangeRequest) String() string + func (r *ThanosQueryRangeRequest) WithQuery(query string) queryrange.Request + func (r *ThanosQueryRangeRequest) WithStartEnd(start, end int64) queryrange.Request + type ThanosRequest interface + GetStoreMatchers func() [][]*labels.Matcher + type ThanosResponseExtractor struct + func (ThanosResponseExtractor) Extract(_, _ int64, resp queryrange.Response) queryrange.Response + func (ThanosResponseExtractor) ResponseWithoutHeaders(resp queryrange.Response) queryrange.Response + type ThanosSeriesRequest struct + CachingOptions queryrange.CachingOptions + Dedup bool + End int64 + Headers []*RequestHeader + Matchers [][]*labels.Matcher + PartialResponse bool + Path string + ReplicaLabels []string + Start int64 + StoreMatchers [][]*labels.Matcher + func (r *ThanosSeriesRequest) GetCachingOptions() queryrange.CachingOptions + func (r *ThanosSeriesRequest) GetEnd() int64 + func (r *ThanosSeriesRequest) GetQuery() string + func (r *ThanosSeriesRequest) GetStart() int64 + func (r *ThanosSeriesRequest) GetStep() int64 + func (r *ThanosSeriesRequest) GetStoreMatchers() [][]*labels.Matcher + func (r *ThanosSeriesRequest) LogToSpan(sp opentracing.Span) + func (r *ThanosSeriesRequest) ProtoMessage() + func (r *ThanosSeriesRequest) Reset() + func (r *ThanosSeriesRequest) String() string + func (r *ThanosSeriesRequest) WithQuery(_ string) queryrange.Request + func (r *ThanosSeriesRequest) WithStartEnd(start, end int64) queryrange.Request + type ThanosSeriesResponse struct + Data []labelpb.ZLabelSet + Error string + ErrorType string + Headers []*ResponseHeader + Status string + func (*ThanosSeriesResponse) Descriptor() ([]byte, []int) + func (*ThanosSeriesResponse) ProtoMessage() + func (m *ThanosSeriesResponse) GetHeaders() []*queryrange.PrometheusResponseHeader + func (m *ThanosSeriesResponse) Marshal() (dAtA []byte, err error) + func (m *ThanosSeriesResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ThanosSeriesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ThanosSeriesResponse) Reset() + func (m *ThanosSeriesResponse) Size() (n int) + func (m *ThanosSeriesResponse) String() string + func (m *ThanosSeriesResponse) Unmarshal(dAtA []byte) error + func (m *ThanosSeriesResponse) XXX_DiscardUnknown() + func (m *ThanosSeriesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ThanosSeriesResponse) XXX_Merge(src proto.Message) + func (m *ThanosSeriesResponse) XXX_Size() int + func (m *ThanosSeriesResponse) XXX_Unmarshal(b []byte) error