Versions in this module Expand all Collapse all v3 v3.0.0 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