queryrange

Dec 18, 2022 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Oct 4, 2022 GO-2022-1175 +1 more

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

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jul 15, 2022 GO-2022-1175 +1 more

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

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

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

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

type Config

+ ForwardHeaders flagext.StringSlice

type Extractor

+ ResponseWithoutStats func(resp Response) Response

type PrometheusData

+ Stats *PrometheusResponseStats

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

type PrometheusRequest

+ Headers []*PrometheusRequestHeader

+ Stats string

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

+ func (m *PrometheusRequest) GetStats() string

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

+ type PrometheusRequestHeader struct

+ Name string

+ Values []string

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

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

+ func (this *PrometheusRequestHeader) GoString() string

+ func (this *PrometheusRequestHeader) String() string

type PrometheusResponseExtractor

+ func (PrometheusResponseExtractor) ResponseWithoutStats(resp Response) Response

+ type PrometheusResponseQueryableSamplesStatsPerStep struct

+ TimestampMs int64

+ Value int64

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

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

+ func (this *PrometheusResponseQueryableSamplesStatsPerStep) GoString() string

+ func (this *PrometheusResponseQueryableSamplesStatsPerStep) String() string

+ type PrometheusResponseSamplesStats struct

+ TotalQueryableSamples int64

+ TotalQueryableSamplesPerStep []*PrometheusResponseQueryableSamplesStatsPerStep

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

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

+ func (this *PrometheusResponseSamplesStats) GoString() string

+ func (this *PrometheusResponseSamplesStats) String() string

+ type PrometheusResponseStats struct

+ Samples *PrometheusResponseSamplesStats

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

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

+ func (this *PrometheusResponseStats) GoString() string

+ func (this *PrometheusResponseStats) String() string

type Request

+ GetStats func() string

+ WithStats func(stats string) Request

type ResultsCacheConfig

+ CacheQueryableSamplesStats bool

Jul 6, 2022 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jun 23, 2022 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Mar 17, 2022 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Mar 8, 2022 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Nov 25, 2021 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

+ type Buffer interface

+ Bytes func() []byte

Nov 4, 2021 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Oct 4, 2021 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Aug 3, 2021 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jul 21, 2021 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jun 29, 2021 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

May 14, 2021 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Apr 29, 2021 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Apr 19, 2021 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Mar 25, 2021 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Mar 15, 2021 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Mar 8, 2021 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Apr 19, 2021 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Feb 23, 2021 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Feb 19, 2021 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Feb 14, 2021 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jan 21, 2021 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Dec 29, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

type Limits

+ MaxQueryLookback func(userID string) time.Duration

type Middleware

+ func NewLimitsMiddleware(l Limits) Middleware

type PrometheusResponse

+ func NewEmptyPrometheusResponse() *PrometheusResponse

+ type RoundTripFunc func(*http.Request) (*http.Response, error)

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

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

Dec 19, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Dec 9, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Nov 9, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

type Response

+ GetHeaders func() []*PrometheusResponseHeader

type ResultsCacheConfig

+ Compression string

+ func (cfg *ResultsCacheConfig) Validate() error

Oct 29, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Nov 3, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Oct 29, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Oct 2, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

+ 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 IntervalFn func(r Request) time.Duration

type PrometheusRequest

+ CachingOptions CachingOptions

+ func (m *PrometheusRequest) GetCachingOptions() CachingOptions

type Request

+ GetCachingOptions func() CachingOptions

+ type ShouldCacheFn func(r Request) bool

Sep 22, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Sep 16, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Aug 21, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Aug 17, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Aug 10, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Aug 5, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jul 1, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

type Limits

+ MaxCacheFreshness func(string) time.Duration

type PrometheusRequest

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

type ResultsCacheConfig

+ LegacyMaxCacheFreshness time.Duration

Jun 26, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jun 24, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

May 21, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

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

+ type CacheGenNumberLoader interface

+ GetResultsCacheGenNumber func(userID string) string

type Extractor

+ ResponseWithoutHeaders func(resp Response) Response

type PrometheusResponseExtractor

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

+ func (PrometheusResponseExtractor) ResponseWithoutHeaders(resp Response) Response

type ShardedQuerier

+ ResponseHeaders map[string][]string

+ ResponseHeadersMtx sync.Mutex

May 13, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Apr 23, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Apr 2, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Mar 31, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Mar 16, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

+ const StatusSuccess

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

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

+ func TimeFromMillis(ms int64) time.Time

+ func TimeToMillis(t time.Time) int64

+ type CacheSplitter interface

+ GenerateCacheKey func(userID string, r Request) string

type CachedResponse

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

type Config

+ ShardedQueries bool

+ func (cfg *Config) Validate(log log.Logger) error

type Extent

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

+ type InstrumentMiddlewareMetrics struct

+ func NewInstrumentMiddlewareMetrics(registerer prometheus.Registerer) *InstrumentMiddlewareMetrics

type Middleware

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

+ type MockShardedQueryable struct

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

+ func (q *MockShardedQueryable) Close() error

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

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

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

+ func (q *MockShardedQueryable) Select(sp *storage.SelectParams, matchers ...*labels.Matcher) (storage.SeriesSet, storage.Warnings, error)

+ func (q *MockShardedQueryable) SelectSorted(_ *storage.SelectParams, matchers ...*labels.Matcher) (storage.SeriesSet, storage.Warnings, error)

+ type NoopCollector struct

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

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

+ func (c *NoopCollector) Register()

type PrometheusData

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

type PrometheusRequest

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

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

type PrometheusResponse

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

type PrometheusResponseHeader

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

type Request

+ WithQuery func(string) Request

+ type RetryMiddlewareMetrics struct

+ func NewRetryMiddlewareMetrics(registerer prometheus.Registerer) *RetryMiddlewareMetrics

type SampleStream

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

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

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

+ type ShardLabelSeries struct

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

+ type ShardedQuerier struct

+ Ctx context.Context

+ Handler Handler

+ Req Request

+ func (q *ShardedQuerier) Close() error

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

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

+ func (q *ShardedQuerier) Select(sp *storage.SelectParams, matchers ...*labels.Matcher) (storage.SeriesSet, storage.Warnings, error)

+ func (q *ShardedQuerier) SelectSorted(_ *storage.SelectParams, matchers ...*labels.Matcher) (storage.SeriesSet, storage.Warnings, error)

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

Mar 9, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Feb 5, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jan 28, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

type PrometheusResponse

+ Headers []*PrometheusResponseHeader

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

+ type PrometheusResponseHeader struct

+ Name string

+ Values []string

+ 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) Reset()

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

+ 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

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

+ func (this *PrometheusResponseHeader) GoString() string

+ func (this *PrometheusResponseHeader) String() string

+ type RequestResponse struct

+ Request Request

+ Response Response

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

Jan 22, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jan 15, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jan 8, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Dec 2, 2019 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

+ var PrometheusResponseExtractor = ExtractorFunc(func(start, end int64, from Response) Response { ... })

+ func LogToSpan(ctx context.Context, r Request)

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

+ type Codec interface

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

+ DecodeResponse func(context.Context, *http.Response) (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

+ MaxRetries int

+ SplitQueriesByDay bool

+ SplitQueriesByInterval time.Duration

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

+ type Extractor interface

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

+ type ExtractorFunc func(start, end int64, from Response) Response

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

+ type Merger interface

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

type Middleware

+ func LimitsMiddleware(l Limits) Middleware

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

+ type PrometheusData struct

+ Result []SampleStream

+ ResultType string

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

+ func (*PrometheusData) ProtoMessage()

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

+ func (m *PrometheusData) GetResultType() string

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

+ func (m *PrometheusData) MarshalTo(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

+ End int64

+ Path string

+ Query string

+ Start int64

+ Step int64

+ Timeout time.Duration

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

+ func (*PrometheusRequest) ProtoMessage()

+ func (m *PrometheusRequest) GetEnd() int64

+ func (m *PrometheusRequest) GetPath() string

+ func (m *PrometheusRequest) GetQuery() string

+ func (m *PrometheusRequest) GetStart() int64

+ 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) 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) WithStartEnd(start int64, end int64) 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

+ Status string

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

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

+ func (m *PrometheusResponse) MarshalTo(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 (this *PrometheusResponse) Equal(that interface{}) bool

+ func (this *PrometheusResponse) GoString() string

+ func (this *PrometheusResponse) String() string

type Request

+ WithStartEnd func(int64, int64) Request

type ResultsCacheConfig

+ SplitInterval time.Duration

Nov 17, 2019 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Oct 11, 2019 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Oct 3, 2019 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Sep 5, 2019 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Aug 30, 2019 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Aug 7, 2019 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

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

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

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

+ func NewRoundTripper(next http.RoundTripper, handler Handler, limits Limits) http.RoundTripper

+ func ParseTime(s string) (int64, error)

+ type APIResponse struct

+ Data Response

+ Error string

+ ErrorType string

+ Status string

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

+ func (*APIResponse) ProtoMessage()

+ func (m *APIResponse) GetData() Response

+ func (m *APIResponse) GetError() string

+ func (m *APIResponse) GetErrorType() string

+ func (m *APIResponse) GetStatus() string

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

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

+ func (m *APIResponse) Reset()

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

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

+ func (m *APIResponse) XXX_DiscardUnknown()

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

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

+ func (m *APIResponse) XXX_Size() int

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

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

+ func (this *APIResponse) GoString() string

+ func (this *APIResponse) String() 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) 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 Extent struct

+ End int64

+ Response *APIResponse

+ Start int64

+ TraceId string

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

+ func (*Extent) ProtoMessage()

+ func (m *Extent) GetEnd() int64

+ func (m *Extent) GetResponse() *APIResponse

+ 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) 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 Handler interface

+ Do func(context.Context, *Request) (*APIResponse, error)

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

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

+ type Limits interface

+ MaxQueryLength func(string) time.Duration

+ MaxQueryParallelism func(string) int

+ type Middleware interface

+ Wrap func(Handler) Handler

+ func InstrumentMiddleware(name string, queryRangeDuration *prometheus.HistogramVec) Middleware

+ func MergeMiddlewares(middleware ...Middleware) Middleware

+ func NewResultsCacheMiddleware(logger log.Logger, cfg ResultsCacheConfig, limits Limits) (Middleware, error)

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

+ func SplitByDayMiddleware(limits Limits) Middleware

+ type MiddlewareFunc func(Handler) Handler

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

+ type Request struct

+ End int64

+ Path string

+ Query string

+ Start int64

+ Step int64

+ Timeout time.Duration

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

+ func (*Request) ProtoMessage()

+ func (m *Request) GetEnd() int64

+ func (m *Request) GetPath() string

+ func (m *Request) GetQuery() string

+ func (m *Request) GetStart() int64

+ func (m *Request) GetStep() int64

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

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

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

+ func (m *Request) Reset()

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

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

+ func (m *Request) XXX_DiscardUnknown()

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

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

+ func (m *Request) XXX_Size() int

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

+ func (q Request) LogToSpan(ctx context.Context)

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

+ func (this *Request) GoString() string

+ func (this *Request) String() string

+ type Response struct

+ Result []SampleStream

+ ResultType string

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

+ func (*Response) ProtoMessage()

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

+ func (m *Response) GetResultType() string

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

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

+ func (m *Response) Reset()

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

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

+ func (m *Response) XXX_DiscardUnknown()

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

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

+ func (m *Response) XXX_Size() int

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

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

+ func (this *Response) GoString() string

+ func (this *Response) String() string

+ type ResultsCacheConfig struct

+ CacheConfig cache.Config

+ MaxCacheFreshness time.Duration

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

+ type SampleStream struct

+ Labels []github_com_cortexproject_cortex_pkg_ingester_client.LabelAdapter

+ Samples []client.Sample

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

+ func (*SampleStream) ProtoMessage()

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

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

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

+ func (m *SampleStream) Reset()

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

+ 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

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

+ func (this *SampleStream) GoString() string

+ func (this *SampleStream) String() string

+ type ToRoundTripperMiddleware struct

+ Next http.RoundTripper

+ func (q ToRoundTripperMiddleware) Do(ctx context.Context, r *Request) (*APIResponse, error)

Aug 1, 2019 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex