queryrange

Nov 4, 2019

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

+ 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

+ 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

Sep 4, 2019

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)