tripperware

Apr 30, 2024

Changes in this version

+ func GetPriority(query string, minTime, maxTime int64, now time.Time, ...) int64

type Limits

+ QueryPriority func(userID string) validation.QueryPriority

Nov 19, 2023

Changes in this version

+ const MaxStep

+ var ErrSubQueryStepTooSmall = "exceeded maximum resolution of %d points per timeseries in subquery. Try increasing the step size of your subquery"

+ func BodyBufferFromHTTPGRPCResponse(res *httpgrpc.HTTPResponse, logger log.Logger) ([]byte, error)

+ func SubQueryStepSizeCheck(query string, defaultSubQueryInterval time.Duration, maxStep int64) error

Dec 2, 2022 GO-2022-1175

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

Changes in this version

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

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

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

+ func EncodeTime(t int64) string

+ func MergeSampleStreams(output map[string]SampleStream, sampleStreams []SampleStream)

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

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

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

+ func TestQueryShardQuery(t *testing.T, instantQueryCodec Codec, shardedPrometheusCodec Codec)

+ type Buffer interface

+ Bytes func() []byte

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

+ 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 Limits interface

+ MaxCacheFreshness func(string) time.Duration

+ MaxQueryLength func(string) time.Duration

+ MaxQueryLookback func(userID string) time.Duration

+ MaxQueryParallelism func(string) int

+ QueryVerticalShardSize func(userID string) int

+ 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 ShardByMiddleware(logger log.Logger, limits Limits, merger Merger) Middleware

+ type MiddlewareFunc func(Handler) Handler

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

+ 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 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 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) MarshalToSizedBuffer(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 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 StatsMerge(stats map[int64]*PrometheusResponseQueryableSamplesStatsPerStep) *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) 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 interface

+ 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

+ HTTPHeaders func() map[string][]string

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

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

+ type SampleStream struct

+ Labels []github_com_cortexproject_cortex_pkg_cortexpb.LabelAdapter

+ Samples []cortexpb.Sample

+ 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) 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 Tripperware func(http.RoundTripper) http.RoundTripper

+ func NewQueryTripperware(log log.Logger, registerer prometheus.Registerer, forwardHeaders []string, ...) Tripperware