queryrangebase

Apr 8, 2024

Changes in this version

+ const ResultsCacheGenNumberHeaderName

+ const StatusSuccess

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

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

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

+ var PrometheusCodecForInstantQueries = &prometheusCodec

+ var PrometheusCodecForRangeQueries = &prometheusCodec

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

+ func CacheGenNumberHeaderSetterMiddleware(cacheGenNumbersLoader resultscache.CacheGenNumberLoader) middleware.Interface

+ func FromQueryResponseMergerToCacheResponseMerger(m Merger) resultscache.ResponseMerger

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

+ type Buffer interface

+ Bytes func() []byte

+ type CacheGenNumberLoader = resultscache.CacheGenNumberLoader

+ type CachingOptions = definitions.CachingOptions

+ type Codec = definitions.Codec

+ type Config struct

+ AlignQueriesWithStep bool

+ CacheResults bool

+ MaxRetries int

+ ResultsCacheConfig ResultsCacheConfig

+ ShardAggregations flagext.StringSliceCSV

+ ShardedQueries bool

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

+ func (cfg *Config) Validate() error

+ type Extent = resultscache.Extent

+ type Extractor interface

+ ResponseWithoutHeaders 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, metricsNamespace string) *InstrumentMiddlewareMetrics

+ type Limits interface

+ MaxCacheFreshness func(context.Context, string) time.Duration

+ MaxQueryLength func(context.Context, string) time.Duration

+ MaxQueryLookback func(context.Context, string) time.Duration

+ MaxQueryParallelism func(context.Context, string) int

+ type Merger = definitions.Merger

+ type Middleware interface

+ Wrap func(Handler) Handler

+ func CacheGenNumberContextSetterMiddleware(cacheGenNumbersLoader resultscache.CacheGenNumberLoader) Middleware

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

+ func MergeMiddlewares(middleware ...Middleware) Middleware

+ func NewResultsCacheMiddleware(logger log.Logger, c cache.Cache, keygen resultscache.KeyGenerator, ...) (Middleware, error)

+ func NewRetryMiddleware(log log.Logger, maxRetries int, metrics *RetryMiddlewareMetrics, ...) 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(_ context.Context, _ ...*labels.Matcher) ([]string, annotations.Annotations, error)

+ func (q *MockShardedQueryable) LabelValues(_ context.Context, _ string, _ ...*labels.Matcher) ([]string, annotations.Annotations, error)

+ func (q *MockShardedQueryable) Querier(_ context.Context, _, _ int64) (storage.Querier, error)

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

+ type NoopCollector struct

+ func (c *NoopCollector) After(_ context.Context, _, _ string, _ time.Time)

+ func (c *NoopCollector) Before(_ context.Context, _ string, _ time.Time)

+ func (c *NoopCollector) Register()

+ type ParallelismForReqFn func(ctx context.Context, tenantIDs []string, r Request) int

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

+ CachingOptions resultscache.CachingOptions

+ End time.Time

+ Headers []*definitions.PrometheusRequestHeader

+ Path string

+ Query string

+ Start time.Time

+ Step int64

+ Timeout time.Duration

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

+ func (*PrometheusRequest) ProtoMessage()

+ func (m *PrometheusRequest) GetCachingOptions() resultscache.CachingOptions

+ func (m *PrometheusRequest) GetEnd() time.Time

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

+ func (m *PrometheusRequest) GetPath() string

+ func (m *PrometheusRequest) GetQuery() string

+ func (m *PrometheusRequest) GetStart() time.Time

+ 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) 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, end time.Time) Request

+ func (q *PrometheusRequest) WithStartEndForCache(s time.Time, e time.Time) resultscache.Request

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

+ func (this *PrometheusRequest) GoString() string

+ func (this *PrometheusRequest) String() string

+ type PrometheusRequestHeader = definitions.PrometheusRequestHeader

+ type PrometheusResponse struct

+ Data PrometheusData

+ Error string

+ ErrorType string

+ Headers []*definitions.PrometheusResponseHeader

+ Status string

+ Warnings []string

+ func NewEmptyPrometheusResponse(v model.ValueType) *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() []*definitions.PrometheusResponseHeader

+ func (m *PrometheusResponse) GetStatus() string

+ func (m *PrometheusResponse) GetWarnings() []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) 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) SetHeader(name, value string)

+ func (resp *PrometheusResponse) WithHeaders(h []PrometheusResponseHeader) Response

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

+ func (this *PrometheusResponse) GoString() string

+ func (this *PrometheusResponse) String() string

+ type PrometheusResponseExtractor struct

+ func (PrometheusResponseExtractor) Extract(start, end int64, res resultscache.Response, _, _ int64) resultscache.Response

+ func (PrometheusResponseExtractor) ResponseWithoutHeaders(resp Response) Response

+ type PrometheusResponseHeader = definitions.PrometheusResponseHeader

+ type Request = definitions.Request

+ type RequestResponse struct

+ Request Request

+ Response Response

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

+ type Response = definitions.Response

+ type ResultsCacheConfig struct

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

+ type ResultsCacheMetrics struct

+ func NewResultsCacheMetrics(registerer prometheus.Registerer) *ResultsCacheMetrics

+ type RetryMiddlewareMetrics struct

+ func NewRetryMiddlewareMetrics(registerer prometheus.Registerer, metricsNamespace string) *RetryMiddlewareMetrics

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

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

+ type SampleStream struct

+ Labels []github_com_grafana_loki_v3_pkg_logproto.LabelAdapter

+ Samples []logproto.LegacySample

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

+ func FromValue(value parser.Value) ([]SampleStream, error)

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

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

+ func (*SampleStream) ProtoMessage()

+ func (m *SampleStream) GetSamples() []logproto.LegacySample

+ 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 ShardLabelSeries struct

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

+ type ShouldCacheFn func(ctx context.Context, r Request) bool

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