queryrange

Nov 25, 2024

Changes in this version

type Middleware

+ func NewStatsMiddleware(forceStats bool) Middleware

type PrometheusResponseSamplesStats

+ PeakSamples int32

+ func (m *PrometheusResponseSamplesStats) GetPeakSamples() int32

May 2, 2024

Changes in this version

+ type Analysis struct

+ Children []*Analysis

+ ExecutionTime Duration

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func AnalyzesMerge(analysis ...*Analysis) *Analysis

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

+ func (*Analysis) ProtoMessage()

+ func (m *Analysis) GetChildren() []*Analysis

+ func (m *Analysis) GetName() string

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

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

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

+ func (m *Analysis) Reset()

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

+ func (m *Analysis) String() string

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

+ func (m *Analysis) XXX_DiscardUnknown()

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

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

+ func (m *Analysis) XXX_Size() int

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

+ type Duration time.Duration

+ func (d *Duration) MarshalTo(b []byte) (int, error)

+ func (d *Duration) Size() int

+ func (d *Duration) Unmarshal(b []byte) error

+ func (d *Duration) UnmarshalJSON(b []byte) error

+ func (d Duration) MarshalJSON() ([]byte, error)

type PrometheusData

+ Analysis *Analysis

+ func (m *PrometheusData) GetAnalysis() *Analysis

type PrometheusInstantQueryData

+ Analysis *Analysis

+ func (m *PrometheusInstantQueryData) GetAnalysis() *Analysis

type PrometheusInstantQueryResponse

+ Warnings []string

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

type PrometheusResponse

+ Warnings []string

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

Aug 23, 2023

Changes in this version

+ type Explanation struct

+ Children []*Explanation

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Explanation) ProtoMessage()

+ func (m *Explanation) GetChildren() []*Explanation

+ func (m *Explanation) GetName() string

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

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

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

+ func (m *Explanation) Reset()

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

+ func (m *Explanation) String() string

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

+ func (m *Explanation) XXX_DiscardUnknown()

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

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

+ func (m *Explanation) XXX_Size() int

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

+ type HistogramBucket struct

+ Boundaries int32

+ Count float64

+ Lower float64

+ Upper float64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*HistogramBucket) ProtoMessage()

+ func (m *HistogramBucket) GetBoundaries() int32

+ func (m *HistogramBucket) GetCount() float64

+ func (m *HistogramBucket) GetLower() float64

+ func (m *HistogramBucket) GetUpper() float64

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

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

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

+ func (m *HistogramBucket) Reset()

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

+ func (m *HistogramBucket) String() string

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

+ func (m *HistogramBucket) XXX_DiscardUnknown()

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

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

+ func (m *HistogramBucket) XXX_Size() int

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

type PrometheusData

+ Explanation *Explanation

+ func (m *PrometheusData) GetExplanation() *Explanation

type PrometheusInstantQueryData

+ Explanation *Explanation

+ func (m *PrometheusInstantQueryData) GetExplanation() *Explanation

type Sample

+ Histogram *SampleHistogram

+ SampleValue float64

+ Timestamp int64

+ func (m *Sample) GetHistogram() *SampleHistogram

+ func (m *Sample) GetSampleValue() float64

+ func (m *Sample) GetTimestamp() int64

+ type SampleHistogram struct

+ Buckets []*HistogramBucket

+ Count float64

+ Sum float64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SampleHistogram) ProtoMessage()

+ func (m *SampleHistogram) GetBuckets() []*HistogramBucket

+ func (m *SampleHistogram) GetCount() float64

+ func (m *SampleHistogram) GetSum() float64

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

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

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

+ func (m *SampleHistogram) Reset()

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

+ func (m *SampleHistogram) String() string

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

+ func (m *SampleHistogram) XXX_DiscardUnknown()

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

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

+ func (m *SampleHistogram) XXX_Size() int

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

+ type SampleHistogramPair struct

+ Histogram SampleHistogram

+ Timestamp int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func SliceHistogram(histograms []SampleHistogramPair, minTs int64) []SampleHistogramPair

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

+ func (*SampleHistogramPair) ProtoMessage()

+ func (m *SampleHistogramPair) GetHistogram() SampleHistogram

+ func (m *SampleHistogramPair) GetTimestamp() int64

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

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

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

+ func (m *SampleHistogramPair) Reset()

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

+ func (m *SampleHistogramPair) String() string

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

+ func (m *SampleHistogramPair) XXX_DiscardUnknown()

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

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

+ func (m *SampleHistogramPair) XXX_Size() int

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

type SampleStream

+ Histograms []SampleHistogramPair

+ func (m *SampleStream) GetHistograms() []SampleHistogramPair

Jan 2, 2023

Changes in this version

+ func EvaluateAtModifierFunction(query string, start, end int64) (string, error)

+ func SliceSamples(samples []cortexpb.Sample, minTs int64) []cortexpb.Sample

Aug 26, 2022

Changes in this version

+ const StatusSuccess

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

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

+ var ErrUnexpectedEndOfGroupQueryrange = fmt.Errorf("proto: unexpected end of group")

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

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

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

+ func BodyBuffer(res *http.Response) ([]byte, error)

+ func NewRoundTripper(next http.RoundTripper, codec Codec, headers []string, ...) http.RoundTripper

+ func NewSeriesSet(results []SampleStream) storage.SeriesSet

+ func PrometheusResponseQueryableSamplesStatsPerStepJsoniterDecode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

+ func PrometheusResponseQueryableSamplesStatsPerStepJsoniterEncode(ptr unsafe.Pointer, stream *jsoniter.Stream)

+ type Buffer interface

+ Bytes func() []byte

+ type CacheGenNumberLoader interface

+ GetResultsCacheGenNumber func(tenantIDs []string) string

+ type CacheSplitter interface

+ GenerateCacheKey func(userID string, r Request) string

+ type CachedResponse struct

+ Extents []Extent

+ Key string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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) String() string

+ 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

+ type CachingOptions struct

+ Disabled bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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) String() string

+ 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

+ type Codec interface

+ DecodeRequest func(_ context.Context, request *http.Request, forwardHeaders []string) (Request, error)

+ DecodeResponse func(context.Context, *http.Response, Request) (Response, error)

+ EncodeRequest func(context.Context, Request) (*http.Request, error)

+ EncodeResponse func(context.Context, Response) (*http.Response, error)

+ var PrometheusCodec Codec = &prometheusCodec{}

+ type Config struct

+ AlignQueriesWithStep bool

+ CacheResults bool

+ ForwardHeaders flagext.StringSlice

+ MaxRetries int

+ ShardedQueries bool

+ SplitQueriesByInterval time.Duration

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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) String() string

+ 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

+ type Extractor interface

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

+ ResponseWithoutHeaders func(resp Response) Response

+ ResponseWithoutStats func(resp Response) Response

+ type Handler interface

+ Do func(context.Context, Request) (Response, error)

+ type HandlerFunc func(context.Context, Request) (Response, error)

+ func (q HandlerFunc) Do(ctx context.Context, req Request) (Response, error)

+ type InstrumentMiddlewareMetrics struct

+ func NewInstrumentMiddlewareMetrics(registerer prometheus.Registerer) *InstrumentMiddlewareMetrics

+ type IntervalFn func(r Request) time.Duration

+ type Limits interface

+ MaxCacheFreshness func(string) time.Duration

+ MaxQueryLength func(string) time.Duration

+ MaxQueryLookback func(userID string) time.Duration

+ MaxQueryParallelism func(string) int

+ type Matrix struct

+ SampleStreams []*SampleStream

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Matrix) ProtoMessage()

+ func (m *Matrix) GetSampleStreams() []*SampleStream

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

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

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

+ func (m *Matrix) Reset()

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

+ func (m *Matrix) String() string

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

+ func (m *Matrix) XXX_DiscardUnknown()

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

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

+ func (m *Matrix) XXX_Size() int

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

+ type Merger interface

+ MergeResponse func(...Response) (Response, error)

+ type Middleware interface

+ Wrap func(Handler) Handler

+ func InstrumentMiddleware(name string, metrics *InstrumentMiddlewareMetrics) Middleware

+ func MergeMiddlewares(middleware ...Middleware) Middleware

+ func NewLimitsMiddleware(l Limits) Middleware

+ func NewQueryShardMiddleware(logger log.Logger, engine *promql.Engine, confs ShardingConfigs, codec Codec, ...) Middleware

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

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

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

+ type MiddlewareFunc func(Handler) Handler

+ func (q MiddlewareFunc) Wrap(h Handler) Handler

+ type MockShardedQueryable struct

+ func NewMockShardedQueryable(nSamples int, labelSet []string, labelBuckets int, ...) *MockShardedQueryable

+ func (q *MockShardedQueryable) Close() error

+ func (q *MockShardedQueryable) LabelNames(matchers ...*labels.Matcher) ([]string, storage.Warnings, error)

+ func (q *MockShardedQueryable) LabelValues(name string, matchers ...*labels.Matcher) ([]string, storage.Warnings, error)

+ func (q *MockShardedQueryable) Querier(ctx context.Context, mint, maxt int64) (storage.Querier, error)

+ func (q *MockShardedQueryable) Select(_ bool, _ *storage.SelectHints, matchers ...*labels.Matcher) storage.SeriesSet

+ type NoopCollector struct

+ func (c *NoopCollector) After(ctx context.Context, method, statusCode string, start time.Time)

+ func (c *NoopCollector) Before(ctx context.Context, method string, start time.Time)

+ func (c *NoopCollector) Register()

+ type PrometheusData struct

+ Result []SampleStream

+ ResultType string

+ Stats *PrometheusResponseStats

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PrometheusData) ProtoMessage()

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

+ func (m *PrometheusData) GetResultType() string

+ func (m *PrometheusData) GetStats() *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) String() string

+ 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

+ type PrometheusInstantQueryData struct

+ Result PrometheusInstantQueryResult

+ ResultType string

+ Stats *PrometheusResponseStats

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PrometheusInstantQueryData) ProtoMessage()

+ func (m *PrometheusInstantQueryData) GetResult() PrometheusInstantQueryResult

+ func (m *PrometheusInstantQueryData) GetResultType() string

+ func (m *PrometheusInstantQueryData) GetStats() *PrometheusResponseStats

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

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

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

+ func (m *PrometheusInstantQueryData) Reset()

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

+ func (m *PrometheusInstantQueryData) String() string

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

+ func (m *PrometheusInstantQueryData) XXX_DiscardUnknown()

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

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

+ func (m *PrometheusInstantQueryData) XXX_Size() int

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

+ func (s *PrometheusInstantQueryData) MarshalJSON() ([]byte, error)

+ func (s *PrometheusInstantQueryData) UnmarshalJSON(data []byte) error

+ type PrometheusInstantQueryResponse struct

+ Data PrometheusInstantQueryData

+ Error string

+ ErrorType string

+ Headers []*PrometheusResponseHeader

+ Status string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func NewEmptyPrometheusInstantQueryResponse() *PrometheusInstantQueryResponse

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

+ func (*PrometheusInstantQueryResponse) ProtoMessage()

+ func (m *PrometheusInstantQueryResponse) GetData() PrometheusInstantQueryData

+ func (m *PrometheusInstantQueryResponse) GetError() string

+ func (m *PrometheusInstantQueryResponse) GetErrorType() string

+ func (m *PrometheusInstantQueryResponse) GetHeaders() []*PrometheusResponseHeader

+ func (m *PrometheusInstantQueryResponse) GetStatus() string

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

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

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

+ func (m *PrometheusInstantQueryResponse) Reset()

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

+ func (m *PrometheusInstantQueryResponse) String() string

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

+ func (m *PrometheusInstantQueryResponse) XXX_DiscardUnknown()

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

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

+ func (m *PrometheusInstantQueryResponse) XXX_Size() int

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

+ func (resp *PrometheusInstantQueryResponse) GetStats() *PrometheusResponseStats

+ type PrometheusInstantQueryResult struct

+ Result isPrometheusInstantQueryResult_Result

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PrometheusInstantQueryResult) ProtoMessage()

+ func (*PrometheusInstantQueryResult) XXX_OneofWrappers() []interface{}

+ func (m *PrometheusInstantQueryResult) GetMatrix() *Matrix

+ func (m *PrometheusInstantQueryResult) GetResult() isPrometheusInstantQueryResult_Result

+ func (m *PrometheusInstantQueryResult) GetScalar() *cortexpb.Sample

+ func (m *PrometheusInstantQueryResult) GetStringSample() *StringSample

+ func (m *PrometheusInstantQueryResult) GetVector() *Vector

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

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

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

+ func (m *PrometheusInstantQueryResult) Reset()

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

+ func (m *PrometheusInstantQueryResult) String() string

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

+ func (m *PrometheusInstantQueryResult) XXX_DiscardUnknown()

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

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

+ func (m *PrometheusInstantQueryResult) XXX_Size() int

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

+ type PrometheusInstantQueryResult_Matrix struct

+ Matrix *Matrix

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

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

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

+ type PrometheusInstantQueryResult_Scalar struct

+ Scalar *cortexpb.Sample

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

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

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

+ type PrometheusInstantQueryResult_StringSample struct

+ StringSample *StringSample

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

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

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

+ type PrometheusInstantQueryResult_Vector struct

+ Vector *Vector

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

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

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

+ type PrometheusRequest struct

+ CachingOptions CachingOptions

+ End int64

+ Headers []*PrometheusRequestHeader

+ Path string

+ Query string

+ Start int64

+ Stats string

+ Step int64

+ Timeout time.Duration

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PrometheusRequest) ProtoMessage()

+ func (m *PrometheusRequest) GetCachingOptions() CachingOptions

+ func (m *PrometheusRequest) GetEnd() int64

+ func (m *PrometheusRequest) GetHeaders() []*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) String() string

+ 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) Request

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

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

+ type PrometheusRequestHeader struct

+ Name string

+ Values []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PrometheusRequestHeader) ProtoMessage()

+ func (m *PrometheusRequestHeader) GetName() string

+ func (m *PrometheusRequestHeader) GetValues() []string

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

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

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

+ func (m *PrometheusRequestHeader) Reset()

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

+ func (m *PrometheusRequestHeader) String() string

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

+ func (m *PrometheusRequestHeader) XXX_DiscardUnknown()

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

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

+ func (m *PrometheusRequestHeader) XXX_Size() int

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

+ type PrometheusResponse struct

+ Data PrometheusData

+ Error string

+ ErrorType string

+ Headers []*PrometheusResponseHeader

+ Status string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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() []*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) String() string

+ 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) GetStats() *PrometheusResponseStats

+ type PrometheusResponseExtractor struct

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

+ func (PrometheusResponseExtractor) ResponseWithoutHeaders(resp Response) Response

+ func (PrometheusResponseExtractor) ResponseWithoutStats(resp Response) Response

+ type PrometheusResponseHeader struct

+ Name string

+ Values []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PrometheusResponseHeader) ProtoMessage()

+ func (m *PrometheusResponseHeader) GetName() string

+ func (m *PrometheusResponseHeader) GetValues() []string

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

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

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

+ func (m *PrometheusResponseHeader) Reset()

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

+ func (m *PrometheusResponseHeader) String() string

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

+ func (m *PrometheusResponseHeader) XXX_DiscardUnknown()

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

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

+ func (m *PrometheusResponseHeader) XXX_Size() int

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

+ type PrometheusResponseQueryableSamplesStatsPerStep struct

+ TimestampMs int64

+ Value int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PrometheusResponseQueryableSamplesStatsPerStep) ProtoMessage()

+ func (m *PrometheusResponseQueryableSamplesStatsPerStep) GetTimestampMs() int64

+ func (m *PrometheusResponseQueryableSamplesStatsPerStep) GetValue() int64

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

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

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

+ func (m *PrometheusResponseQueryableSamplesStatsPerStep) Reset()

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

+ func (m *PrometheusResponseQueryableSamplesStatsPerStep) String() string

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

+ func (m *PrometheusResponseQueryableSamplesStatsPerStep) XXX_DiscardUnknown()

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

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

+ func (m *PrometheusResponseQueryableSamplesStatsPerStep) XXX_Size() int

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

+ type PrometheusResponseSamplesStats struct

+ TotalQueryableSamples int64

+ TotalQueryableSamplesPerStep []*PrometheusResponseQueryableSamplesStatsPerStep

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PrometheusResponseSamplesStats) ProtoMessage()

+ func (m *PrometheusResponseSamplesStats) GetTotalQueryableSamples() int64

+ func (m *PrometheusResponseSamplesStats) GetTotalQueryableSamplesPerStep() []*PrometheusResponseQueryableSamplesStatsPerStep

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

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

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

+ func (m *PrometheusResponseSamplesStats) Reset()

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

+ func (m *PrometheusResponseSamplesStats) String() string

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

+ func (m *PrometheusResponseSamplesStats) XXX_DiscardUnknown()

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

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

+ func (m *PrometheusResponseSamplesStats) XXX_Size() int

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

+ type PrometheusResponseStats struct

+ Samples *PrometheusResponseSamplesStats

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func StatsMerge(resps []Response) *PrometheusResponseStats

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

+ func (*PrometheusResponseStats) ProtoMessage()

+ func (m *PrometheusResponseStats) GetSamples() *PrometheusResponseSamplesStats

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

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

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

+ func (m *PrometheusResponseStats) Reset()

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

+ func (m *PrometheusResponseStats) String() string

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

+ func (m *PrometheusResponseStats) XXX_DiscardUnknown()

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

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

+ func (m *PrometheusResponseStats) XXX_Size() int

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

+ type Request interface

+ GetCachingOptions func() CachingOptions

+ GetEnd func() int64

+ GetQuery func() string

+ GetStart func() int64

+ GetStats func() string

+ GetStep func() int64

+ LogToSpan func(opentracing.Span)

+ WithQuery func(string) Request

+ WithStartEnd func(startTime int64, endTime int64) Request

+ WithStats func(stats string) Request

+ type RequestResponse struct

+ Request Request

+ Response Response

+ func DoRequests(ctx context.Context, downstream Handler, reqs []Request, limits Limits) ([]RequestResponse, error)

+ type Response interface

+ GetHeaders func() []*PrometheusResponseHeader

+ GetStats func() *PrometheusResponseStats

+ 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 RoundTripFunc func(*http.Request) (*http.Response, error)

+ func (f RoundTripFunc) RoundTrip(r *http.Request) (*http.Response, error)

+ type Sample struct

+ Labels []github_com_thanos_io_thanos_internal_cortex_cortexpb.LabelAdapter

+ Sample cortexpb.Sample

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Sample) ProtoMessage()

+ func (m *Sample) GetSample() cortexpb.Sample

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

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

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

+ func (m *Sample) Reset()

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

+ func (m *Sample) String() string

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

+ func (m *Sample) XXX_DiscardUnknown()

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

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

+ func (m *Sample) XXX_Size() int

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

+ func (s *Sample) MarshalJSON() ([]byte, error)

+ func (s *Sample) UnmarshalJSON(data []byte) error

+ type SampleStream struct

+ Labels []github_com_thanos_io_thanos_internal_cortex_cortexpb.LabelAdapter

+ Samples []cortexpb.Sample

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

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

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

+ func (*SampleStream) ProtoMessage()

+ func (m *SampleStream) GetSamples() []cortexpb.Sample

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

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

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

+ func (m *SampleStream) Reset()

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

+ func (m *SampleStream) String() string

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

+ func (m *SampleStream) XXX_DiscardUnknown()

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

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

+ func (m *SampleStream) XXX_Size() int

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

+ func (s *SampleStream) MarshalJSON() ([]byte, error)

+ func (s *SampleStream) UnmarshalJSON(data []byte) error

+ type ShardLabelSeries struct

+ func (s *ShardLabelSeries) Labels() labels.Labels

+ type ShardedQuerier struct

+ Ctx context.Context

+ Handler Handler

+ Req Request

+ ResponseHeaders map[string][]string

+ ResponseHeadersMtx sync.Mutex

+ func (q *ShardedQuerier) Close() error

+ func (q *ShardedQuerier) LabelNames(matchers ...*labels.Matcher) ([]string, storage.Warnings, error)

+ func (q *ShardedQuerier) LabelValues(name string, matchers ...*labels.Matcher) ([]string, storage.Warnings, error)

+ func (q *ShardedQuerier) Select(_ bool, _ *storage.SelectHints, matchers ...*labels.Matcher) storage.SeriesSet

+ type ShardedQueryable struct

+ Handler Handler

+ Req Request

+ func (q *ShardedQueryable) Querier(ctx context.Context, mint, maxt int64) (storage.Querier, error)

+ type ShardingConfigs []chunk.PeriodConfig

+ func (confs ShardingConfigs) GetConf(r Request) (chunk.PeriodConfig, error)

+ func (confs ShardingConfigs) ValidRange(start, end int64) (chunk.PeriodConfig, error)

+ type ShouldCacheFn func(r Request) bool

+ type StringSample struct

+ TimestampMs int64

+ Value string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StringSample) ProtoMessage()

+ func (m *StringSample) GetTimestampMs() int64

+ func (m *StringSample) GetValue() string

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

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

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

+ func (m *StringSample) Reset()

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

+ func (m *StringSample) String() string

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

+ func (m *StringSample) XXX_DiscardUnknown()

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

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

+ func (m *StringSample) XXX_Size() int

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

+ func (s *StringSample) UnmarshalJSON(b []byte) error

+ func (s StringSample) MarshalJSON() ([]byte, error)

+ type Tripperware func(http.RoundTripper) http.RoundTripper

+ func NewTripperware(cfg Config, log log.Logger, limits Limits, codec Codec, ...) (Tripperware, cache.Cache, error)

+ type Vector struct

+ Samples []*Sample

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Vector) ProtoMessage()

+ func (m *Vector) GetSamples() []*Sample

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

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

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

+ func (m *Vector) Reset()

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

+ func (m *Vector) String() string

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

+ func (m *Vector) XXX_DiscardUnknown()

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

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

+ func (m *Vector) XXX_Size() int

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