queryrange

package

Go to main page

Versions in this module

v1

v1.6.1

Aug 24, 2020

v1.6.0

Aug 13, 2020

Changes in this version

+ const DefaultDownstreamConcurrency

+ const LabelNamesOp

+ const QueryRangeOp

+ const SeriesOp

+ func NewLabelsTripperware(cfg Config, log log.Logger, limits Limits, codec queryrange.Codec, ...) (frontend.Tripperware, error)

+ func NewQueryShardMiddleware(logger log.Logger, confs queryrange.ShardingConfigs, ...) queryrange.Middleware

+ func NewSeriesTripperware(cfg Config, log log.Logger, limits Limits, codec queryrange.Codec, ...) (frontend.Tripperware, error)

+ func ResponseToResult(resp queryrange.Response) (logql.Result, error)

+ type DownstreamHandler struct

+ func (h DownstreamHandler) Downstreamer() logql.Downstreamer

type Limits

+ func WithSplitByLimits(l Limits, splitBy time.Duration) Limits

+ type LokiLabelNamesRequest struct

+ EndTs time.Time

+ Path string

+ StartTs time.Time

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

+ 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

+ Status string

+ Version uint32

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

+ func (*LokiLabelNamesResponse) ProtoMessage()

+ func (m *LokiLabelNamesResponse) GetData() []string

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

+ Shards []string

+ func ParamsToLokiRequest(params logql.Params) *LokiRequest

+ func (m *LokiRequest) GetShards() []string

+ func (r *LokiRequest) LogToSpan(sp opentracing.Span)

+ func (r *LokiRequest) WithShards(shards logql.Shards) *LokiRequest

+ type LokiSeriesRequest struct

+ EndTs time.Time

+ Match []string

+ Path string

+ StartTs time.Time

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

+ 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

+ Status string

+ Version uint32

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

+ func (*LokiSeriesResponse) ProtoMessage()

+ func (m *LokiSeriesResponse) GetData() []logproto.SeriesIdentifier

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

+ func NewSplitByMetrics(r prometheus.Registerer) *SplitByMetrics

v1.5.0

May 20, 2020

Changes in this version

type Limits

+ MaxEntriesLimitPerQuery func(string) int

+ type PrometheusExtractor struct

+ func (PrometheusExtractor) Extract(start, end int64, from queryrange.Response) queryrange.Response

+ func (PrometheusExtractor) ResponseWithoutHeaders(resp queryrange.Response) queryrange.Response

v1.4.1

Apr 6, 2020

v1.4.0

Apr 1, 2020

Changes in this version

+ var StatsHTTPMiddleware middleware.Interface = statsHTTPMiddleware(defaultMetricRecorder)

+ func StatsCollectorMiddleware() queryrange.Middleware

+ type Limits interface

+ QuerySplitDuration func(string) time.Duration

+ func WithDefaultLimits(l Limits, conf queryrange.Config) Limits

+ type LokiPromResponse struct

+ Response *queryrange.PrometheusResponse

+ Statistics stats.Result

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

+ func (*LokiPromResponse) ProtoMessage()

+ 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

+ func (r *LokiRequest) WithQuery(query string) queryrange.Request

type LokiResponse

+ Statistics stats.Result

+ func (m *LokiResponse) GetStatistics() stats.Result

type Stopper

+ func NewMetricTripperware(cfg Config, log log.Logger, limits Limits, codec queryrange.Codec, ...) (frontend.Tripperware, Stopper, error)

v1.3.0

Jan 22, 2020

Changes in this version

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

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

+ func NewLogFilterTripperware(cfg Config, log log.Logger, limits queryrange.Limits, codec queryrange.Codec) (frontend.Tripperware, error)

+ func SplitByIntervalMiddleware(interval time.Duration, limits queryrange.Limits, merger queryrange.Merger) queryrange.Middleware

+ type Config struct

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

+ type LokiData struct

+ Result []logproto.Stream

+ ResultType string

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

+ func (*LokiData) ProtoMessage()

+ func (m *LokiData) GetResult() []logproto.Stream

+ func (m *LokiData) GetResultType() string

+ func (m *LokiData) Marshal() (dAtA []byte, err error)

+ func (m *LokiData) MarshalTo(dAtA []byte) (int, error)

+ func (m *LokiData) MarshalToSizedBuffer(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 LokiRequest struct

+ Direction logproto.Direction

+ EndTs time.Time

+ Limit uint32

+ Path string

+ Query string

+ StartTs time.Time

+ Step int64

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

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

+ Limit uint32

+ 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) GetLimit() uint32

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

+ Stop func() error

+ func NewTripperware(cfg Config, log log.Logger, limits queryrange.Limits) (frontend.Tripperware, Stopper, error)

Other modules containing this package

github.com/grafana/loki/v3

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL