Versions in this module Expand all Collapse all v1 v1.6.3 Jan 15, 2024 Changes in this version + const DefaultDownstreamConcurrency + const LabelNamesOp + const QueryRangeOp + const SeriesOp + var ErrIntOverflowQueryrange = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthQueryrange = fmt.Errorf("proto: negative length found during unmarshaling") + var StatsHTTPMiddleware middleware.Interface = statsHTTPMiddleware(defaultMetricRecorder) + func NewLabelsTripperware(cfg Config, log log.Logger, limits Limits, codec queryrange.Codec, ...) (queryrange.Tripperware, error) + func NewLimitedRoundTripper(next http.RoundTripper, codec queryrange.Codec, limits Limits, ...) http.RoundTripper + func NewLogFilterTripperware(cfg Config, log log.Logger, limits Limits, schema chunk.SchemaConfig, ...) (queryrange.Tripperware, error) + func NewQueryShardMiddleware(logger log.Logger, confs queryrange.ShardingConfigs, ...) queryrange.Middleware + func NewSeriesTripperware(cfg Config, log log.Logger, limits Limits, codec queryrange.Codec, ...) (queryrange.Tripperware, error) + func ResponseToResult(resp queryrange.Response) (logqlmodel.Result, error) + func SplitByIntervalMiddleware(limits Limits, merger queryrange.Merger, splitter Splitter, ...) queryrange.Middleware + func StatsCollectorMiddleware() queryrange.Middleware + type Config struct + func (cfg *Config) RegisterFlags(f *flag.FlagSet) + type DownstreamHandler struct + func (h DownstreamHandler) Downstreamer() logql.Downstreamer + type Limits interface + MaxEntriesLimitPerQuery func(string) int + MaxQuerySeries func(string) int + QuerySplitDuration func(string) time.Duration + func WithDefaultLimits(l Limits, conf queryrange.Config) Limits + func WithSplitByLimits(l Limits, splitBy time.Duration) Limits + type LokiData struct + Result []github_com_grafarg_loki_pkg_logproto.Stream + ResultType string + func (*LokiData) Descriptor() ([]byte, []int) + func (*LokiData) ProtoMessage() + func (m *LokiData) GetResultType() string + func (m *LokiData) Marshal() (dAtA []byte, err error) + func (m *LokiData) MarshalTo(dAtA []byte) (int, error) + func (m *LokiData) Reset() + func (m *LokiData) Size() (n int) + func (m *LokiData) Unmarshal(dAtA []byte) error + func (m *LokiData) XXX_DiscardUnknown() + func (m *LokiData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LokiData) XXX_Merge(src proto.Message) + func (m *LokiData) XXX_Size() int + func (m *LokiData) XXX_Unmarshal(b []byte) error + func (this *LokiData) Equal(that interface{}) bool + func (this *LokiData) GoString() string + func (this *LokiData) String() string + type LokiLabelNamesRequest struct + EndTs time.Time + Path string + StartTs time.Time + func (*LokiLabelNamesRequest) Descriptor() ([]byte, []int) + func (*LokiLabelNamesRequest) GetCachingOptions() (res queryrange.CachingOptions) + func (*LokiLabelNamesRequest) ProtoMessage() + func (m *LokiLabelNamesRequest) GetEndTs() time.Time + func (m *LokiLabelNamesRequest) GetPath() string + func (m *LokiLabelNamesRequest) GetStartTs() time.Time + func (m *LokiLabelNamesRequest) Marshal() (dAtA []byte, err error) + func (m *LokiLabelNamesRequest) MarshalTo(dAtA []byte) (int, error) + func (m *LokiLabelNamesRequest) Reset() + func (m *LokiLabelNamesRequest) Size() (n int) + func (m *LokiLabelNamesRequest) Unmarshal(dAtA []byte) error + func (m *LokiLabelNamesRequest) XXX_DiscardUnknown() + func (m *LokiLabelNamesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LokiLabelNamesRequest) XXX_Merge(src proto.Message) + func (m *LokiLabelNamesRequest) XXX_Size() int + func (m *LokiLabelNamesRequest) XXX_Unmarshal(b []byte) error + func (r *LokiLabelNamesRequest) GetEnd() int64 + func (r *LokiLabelNamesRequest) GetQuery() string + func (r *LokiLabelNamesRequest) GetStart() int64 + func (r *LokiLabelNamesRequest) GetStep() int64 + func (r *LokiLabelNamesRequest) LogToSpan(sp opentracing.Span) + func (r *LokiLabelNamesRequest) WithQuery(query string) queryrange.Request + func (r *LokiLabelNamesRequest) WithStartEnd(s int64, e int64) queryrange.Request + func (this *LokiLabelNamesRequest) Equal(that interface{}) bool + func (this *LokiLabelNamesRequest) GoString() string + func (this *LokiLabelNamesRequest) String() string + type LokiLabelNamesResponse struct + Data []string + Headers []github_com_cortexproject_cortex_pkg_querier_queryrange.PrometheusResponseHeader + Status string + Version uint32 + func (*LokiLabelNamesResponse) Descriptor() ([]byte, []int) + func (*LokiLabelNamesResponse) ProtoMessage() + func (m *LokiLabelNamesResponse) GetData() []string + func (m *LokiLabelNamesResponse) GetHeaders() []*queryrange.PrometheusResponseHeader + func (m *LokiLabelNamesResponse) GetStatus() string + func (m *LokiLabelNamesResponse) GetVersion() uint32 + func (m *LokiLabelNamesResponse) Marshal() (dAtA []byte, err error) + func (m *LokiLabelNamesResponse) MarshalTo(dAtA []byte) (int, error) + func (m *LokiLabelNamesResponse) Reset() + func (m *LokiLabelNamesResponse) Size() (n int) + func (m *LokiLabelNamesResponse) Unmarshal(dAtA []byte) error + func (m *LokiLabelNamesResponse) XXX_DiscardUnknown() + func (m *LokiLabelNamesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LokiLabelNamesResponse) XXX_Merge(src proto.Message) + func (m *LokiLabelNamesResponse) XXX_Size() int + func (m *LokiLabelNamesResponse) XXX_Unmarshal(b []byte) error + func (this *LokiLabelNamesResponse) Equal(that interface{}) bool + func (this *LokiLabelNamesResponse) GoString() string + func (this *LokiLabelNamesResponse) String() string + type LokiPromResponse struct + Response *queryrange.PrometheusResponse + Statistics stats.Result + func (*LokiPromResponse) Descriptor() ([]byte, []int) + func (*LokiPromResponse) ProtoMessage() + func (m *LokiPromResponse) GetHeaders() []*queryrange.PrometheusResponseHeader + func (m *LokiPromResponse) GetResponse() *queryrange.PrometheusResponse + func (m *LokiPromResponse) GetStatistics() stats.Result + func (m *LokiPromResponse) Marshal() (dAtA []byte, err error) + func (m *LokiPromResponse) MarshalTo(dAtA []byte) (int, error) + func (m *LokiPromResponse) Reset() + func (m *LokiPromResponse) Size() (n int) + func (m *LokiPromResponse) Unmarshal(dAtA []byte) error + func (m *LokiPromResponse) XXX_DiscardUnknown() + func (m *LokiPromResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LokiPromResponse) XXX_Merge(src proto.Message) + func (m *LokiPromResponse) XXX_Size() int + func (m *LokiPromResponse) XXX_Unmarshal(b []byte) error + func (this *LokiPromResponse) Equal(that interface{}) bool + func (this *LokiPromResponse) GoString() string + func (this *LokiPromResponse) String() string + type LokiRequest struct + Direction logproto.Direction + EndTs time.Time + Limit uint32 + Path string + Query string + Shards []string + StartTs time.Time + Step int64 + func ParamsToLokiRequest(params logql.Params) *LokiRequest + func (*LokiRequest) Descriptor() ([]byte, []int) + func (*LokiRequest) GetCachingOptions() (res queryrange.CachingOptions) + func (*LokiRequest) ProtoMessage() + func (m *LokiRequest) GetDirection() logproto.Direction + func (m *LokiRequest) GetEndTs() time.Time + func (m *LokiRequest) GetLimit() uint32 + func (m *LokiRequest) GetPath() string + func (m *LokiRequest) GetQuery() string + func (m *LokiRequest) GetShards() []string + func (m *LokiRequest) GetStartTs() time.Time + func (m *LokiRequest) GetStep() int64 + func (m *LokiRequest) Marshal() (dAtA []byte, err error) + func (m *LokiRequest) MarshalTo(dAtA []byte) (int, error) + func (m *LokiRequest) Reset() + func (m *LokiRequest) Size() (n int) + func (m *LokiRequest) Unmarshal(dAtA []byte) error + func (m *LokiRequest) XXX_DiscardUnknown() + func (m *LokiRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LokiRequest) XXX_Merge(src proto.Message) + func (m *LokiRequest) XXX_Size() int + func (m *LokiRequest) XXX_Unmarshal(b []byte) error + func (r *LokiRequest) GetEnd() int64 + func (r *LokiRequest) GetStart() int64 + func (r *LokiRequest) LogToSpan(sp opentracing.Span) + func (r *LokiRequest) WithQuery(query string) queryrange.Request + func (r *LokiRequest) WithShards(shards logql.Shards) *LokiRequest + func (r *LokiRequest) WithStartEnd(s int64, e int64) queryrange.Request + func (this *LokiRequest) Equal(that interface{}) bool + func (this *LokiRequest) GoString() string + func (this *LokiRequest) String() string + type LokiResponse struct + Data LokiData + Direction logproto.Direction + Error string + ErrorType string + Headers []github_com_cortexproject_cortex_pkg_querier_queryrange.PrometheusResponseHeader + Limit uint32 + Statistics stats.Result + Status string + Version uint32 + func (*LokiResponse) Descriptor() ([]byte, []int) + func (*LokiResponse) ProtoMessage() + func (m *LokiResponse) GetData() LokiData + func (m *LokiResponse) GetDirection() logproto.Direction + func (m *LokiResponse) GetError() string + func (m *LokiResponse) GetErrorType() string + func (m *LokiResponse) GetHeaders() []*queryrange.PrometheusResponseHeader + func (m *LokiResponse) GetLimit() uint32 + func (m *LokiResponse) GetStatistics() stats.Result + func (m *LokiResponse) GetStatus() string + func (m *LokiResponse) GetVersion() uint32 + func (m *LokiResponse) Marshal() (dAtA []byte, err error) + func (m *LokiResponse) MarshalTo(dAtA []byte) (int, error) + func (m *LokiResponse) Reset() + func (m *LokiResponse) Size() (n int) + func (m *LokiResponse) Unmarshal(dAtA []byte) error + func (m *LokiResponse) XXX_DiscardUnknown() + func (m *LokiResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LokiResponse) XXX_Merge(src proto.Message) + func (m *LokiResponse) XXX_Size() int + func (m *LokiResponse) XXX_Unmarshal(b []byte) error + func (res LokiResponse) Count() int64 + func (this *LokiResponse) Equal(that interface{}) bool + func (this *LokiResponse) GoString() string + func (this *LokiResponse) String() string + type LokiSeriesRequest struct + EndTs time.Time + Match []string + Path string + StartTs time.Time + func (*LokiSeriesRequest) Descriptor() ([]byte, []int) + func (*LokiSeriesRequest) GetCachingOptions() (res queryrange.CachingOptions) + func (*LokiSeriesRequest) ProtoMessage() + func (m *LokiSeriesRequest) GetEndTs() time.Time + func (m *LokiSeriesRequest) GetMatch() []string + func (m *LokiSeriesRequest) GetPath() string + func (m *LokiSeriesRequest) GetStartTs() time.Time + func (m *LokiSeriesRequest) Marshal() (dAtA []byte, err error) + func (m *LokiSeriesRequest) MarshalTo(dAtA []byte) (int, error) + func (m *LokiSeriesRequest) Reset() + func (m *LokiSeriesRequest) Size() (n int) + func (m *LokiSeriesRequest) Unmarshal(dAtA []byte) error + func (m *LokiSeriesRequest) XXX_DiscardUnknown() + func (m *LokiSeriesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LokiSeriesRequest) XXX_Merge(src proto.Message) + func (m *LokiSeriesRequest) XXX_Size() int + func (m *LokiSeriesRequest) XXX_Unmarshal(b []byte) error + func (r *LokiSeriesRequest) GetEnd() int64 + func (r *LokiSeriesRequest) GetQuery() string + func (r *LokiSeriesRequest) GetStart() int64 + func (r *LokiSeriesRequest) GetStep() int64 + func (r *LokiSeriesRequest) LogToSpan(sp opentracing.Span) + func (r *LokiSeriesRequest) WithQuery(query string) queryrange.Request + func (r *LokiSeriesRequest) WithStartEnd(s int64, e int64) queryrange.Request + func (this *LokiSeriesRequest) Equal(that interface{}) bool + func (this *LokiSeriesRequest) GoString() string + func (this *LokiSeriesRequest) String() string + type LokiSeriesResponse struct + Data []logproto.SeriesIdentifier + Headers []github_com_cortexproject_cortex_pkg_querier_queryrange.PrometheusResponseHeader + Status string + Version uint32 + func (*LokiSeriesResponse) Descriptor() ([]byte, []int) + func (*LokiSeriesResponse) ProtoMessage() + func (m *LokiSeriesResponse) GetData() []logproto.SeriesIdentifier + func (m *LokiSeriesResponse) GetHeaders() []*queryrange.PrometheusResponseHeader + func (m *LokiSeriesResponse) GetStatus() string + func (m *LokiSeriesResponse) GetVersion() uint32 + func (m *LokiSeriesResponse) Marshal() (dAtA []byte, err error) + func (m *LokiSeriesResponse) MarshalTo(dAtA []byte) (int, error) + func (m *LokiSeriesResponse) Reset() + func (m *LokiSeriesResponse) Size() (n int) + func (m *LokiSeriesResponse) Unmarshal(dAtA []byte) error + func (m *LokiSeriesResponse) XXX_DiscardUnknown() + func (m *LokiSeriesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LokiSeriesResponse) XXX_Merge(src proto.Message) + func (m *LokiSeriesResponse) XXX_Size() int + func (m *LokiSeriesResponse) XXX_Unmarshal(b []byte) error + func (this *LokiSeriesResponse) Equal(that interface{}) bool + func (this *LokiSeriesResponse) GoString() string + func (this *LokiSeriesResponse) String() string + type PrometheusExtractor struct + func (PrometheusExtractor) Extract(start, end int64, from queryrange.Response) queryrange.Response + func (PrometheusExtractor) ResponseWithoutHeaders(resp queryrange.Response) queryrange.Response + type SplitByMetrics struct + func NewSplitByMetrics(r prometheus.Registerer) *SplitByMetrics + type Splitter func(req queryrange.Request, interval time.Duration) []queryrange.Request + type Stopper interface + Stop func() + func NewMetricTripperware(cfg Config, log log.Logger, limits Limits, schema chunk.SchemaConfig, ...) (queryrange.Tripperware, Stopper, error) + func NewTripperware(cfg Config, log log.Logger, limits Limits, schema chunk.SchemaConfig, ...) (queryrange.Tripperware, Stopper, error)
Go to main page