queryrange

package

Go to main page

Versions in this module

v3

v3.3.2

Dec 18, 2024

v3.3.1

Dec 4, 2024

v3.3.0

Nov 19, 2024

Changes in this version

+ func NewDetectedFieldsHandler(limitedHandler base.Handler, logHandler base.Handler, limits Limits) base.Handler

+ type CountMinSketchResponse struct

+ Headers []github_com_grafana_loki_v3_pkg_querier_queryrange_queryrangebase_definitions.PrometheusResponseHeader

+ Response *github_com_grafana_loki_v3_pkg_logproto.CountMinSketchVector

+ Statistics stats.Result

+ Warnings []string

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

+ func (*CountMinSketchResponse) ProtoMessage()

+ func (m *CountMinSketchResponse) GetHeaders() []*queryrangebase.PrometheusResponseHeader

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

+ func (m *CountMinSketchResponse) GetWarnings() []string

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

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

+ func (m *CountMinSketchResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CountMinSketchResponse) Reset()

+ func (m *CountMinSketchResponse) SetHeader(name, value string)

+ func (m *CountMinSketchResponse) Size() (n int)

+ func (m *CountMinSketchResponse) Unmarshal(dAtA []byte) error

+ func (m *CountMinSketchResponse) WithHeaders(h []queryrangebase.PrometheusResponseHeader) queryrangebase.Response

+ func (m *CountMinSketchResponse) XXX_DiscardUnknown()

+ func (m *CountMinSketchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CountMinSketchResponse) XXX_Merge(src proto.Message)

+ func (m *CountMinSketchResponse) XXX_Size() int

+ func (m *CountMinSketchResponse) XXX_Unmarshal(b []byte) error

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

+ func (this *CountMinSketchResponse) GoString() string

+ func (this *CountMinSketchResponse) String() string

type DetectedFieldsRequest

+ func (r *DetectedFieldsRequest) GetLimit() uint32

type QuantileSketchResponse

+ Statistics stats.Result

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

type QueryResponse

+ func (m *QueryResponse) GetCountMinSketches() *CountMinSketchResponse

+ type QueryResponse_CountMinSketches struct

+ CountMinSketches *CountMinSketchResponse

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

+ func (m *QueryResponse_CountMinSketches) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *QueryResponse_CountMinSketches) Size() (n int)

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

+ func (this *QueryResponse_CountMinSketches) GoString() string

+ func (this *QueryResponse_CountMinSketches) String() string

type TopKSketchesResponse

+ Statistics stats.Result

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

v3.2.2

Dec 4, 2024

v3.2.1

Oct 17, 2024

v3.2.0

Sep 18, 2024

v3.1.2

Oct 17, 2024

v3.1.1

Aug 8, 2024

v3.1.0

Jul 2, 2024

Changes in this version

+ func NewDetectedFieldsTripperware(cfg Config, engineOpts logql.EngineOpts, log log.Logger, limits Limits, ...) (base.Middleware, error)

+ func NewDetectedLabelsCardinalityFilter(rt queryrangebase.Handler) queryrangebase.Handler

+ func NewDetectedLabelsTripperware(cfg Config, opts logql.EngineOpts, logger log.Logger, l Limits, ...) (base.Middleware, error)

+ func NewSketchRemovingHandler(next queryrangebase.Handler, limits Limits, splitter splitter) queryrangebase.Handler

type DetectedFieldsRequest

+ func (r *DetectedFieldsRequest) GetFieldLimit() uint32

+ func (r *DetectedFieldsRequest) GetLineLimit() uint32

type LokiInstantRequest

+ CachingOptions resultscache.CachingOptions

+ StoreChunks *logproto.ChunkRefGroup

+ func (m *LokiInstantRequest) GetStoreChunks() *logproto.ChunkRefGroup

type LokiRequest

+ CachingOptions resultscache.CachingOptions

+ StoreChunks *logproto.ChunkRefGroup

+ func (m *LokiRequest) GetStoreChunks() *logproto.ChunkRefGroup

v3.0.1

Aug 9, 2024

v3.0.0

Apr 8, 2024

Changes in this version

+ const DefaultDownstreamConcurrency

+ const DetectedFieldsOp

+ const DetectedLabelsOp

+ const IndexShardsOp

+ const IndexStatsOp

+ const InstantQueryOp

+ const JSONType

+ const LabelNamesOp

+ const PatternsQueryOp

+ const ProtobufType

+ const QueryRangeOp

+ const SeriesOp

+ const VolumeOp

+ const VolumeRangeOp

+ var DefaultCodec = &Codec

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

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

+ var ErrMaxQueryParalellism = fmt.Errorf("querying is disabled, please contact your Loki operator")

+ var StatsHTTPMiddleware middleware.Interface = statsHTTPMiddleware(defaultMetricRecorder)

+ func MinWeightedParallelism(ctx context.Context, tenantIDs []string, configs []config.PeriodConfig, ...) int

+ func NewEmptyResponse(r queryrangebase.Request) (queryrangebase.Response, error)

+ func NewIndexStatsCacheMiddleware(log log.Logger, limits Limits, merger queryrangebase.Merger, c cache.Cache, ...) (queryrangebase.Middleware, error)

+ func NewIndexStatsTripperware(cfg Config, log log.Logger, limits Limits, schema config.SchemaConfig, ...) (base.Middleware, error)

+ func NewInstantMetricCacheMiddleware(log log.Logger, limits Limits, merger queryrangebase.Merger, c cache.Cache, ...) (queryrangebase.Middleware, error)

+ func NewInstantMetricTripperware(cfg Config, engineOpts logql.EngineOpts, log log.Logger, limits Limits, ...) (base.Middleware, error)

+ func NewLabelsCacheMiddleware(logger log.Logger, limits Limits, merger queryrangebase.Merger, c cache.Cache, ...) (queryrangebase.Middleware, error)

+ func NewLabelsTripperware(cfg Config, log log.Logger, limits Limits, merger base.Merger, ...) (base.Middleware, error)

+ func NewLimitedRoundTripper(next queryrangebase.Handler, limits Limits, configs []config.PeriodConfig, ...) queryrangebase.Handler

+ func NewLimitedTripperware(_ Config, engineOpts logql.EngineOpts, log log.Logger, limits Limits, ...) (base.Middleware, error)

+ func NewLimitsMiddleware(l Limits) queryrangebase.Middleware

+ func NewLogFilterTripperware(cfg Config, engineOpts logql.EngineOpts, log log.Logger, limits Limits, ...) (base.Middleware, error)

+ func NewLogResultCache(logger log.Logger, limits Limits, cache cache.Cache, ...) queryrangebase.Middleware

+ func NewMetricTripperware(cfg Config, engineOpts logql.EngineOpts, log log.Logger, limits Limits, ...) (base.Middleware, error)

+ func NewQuerierSizeLimiterMiddleware(cfg []config.PeriodConfig, engineOpts logql.EngineOpts, logger log.Logger, ...) queryrangebase.Middleware

+ func NewQueryShardMiddleware(logger log.Logger, confs ShardingConfigs, engineOpts logql.EngineOpts, ...) queryrangebase.Middleware

+ func NewQuerySizeLimiterMiddleware(cfg []config.PeriodConfig, engineOpts logql.EngineOpts, logger log.Logger, ...) queryrangebase.Middleware

+ func NewSerializeHTTPHandler(next queryrangebase.Handler, codec queryrangebase.Codec) http.Handler

+ func NewSerializeRoundTripper(next queryrangebase.Handler, codec queryrangebase.Codec) http.RoundTripper

+ func NewSeriesCacheMiddleware(logger log.Logger, limits Limits, merger queryrangebase.Merger, c cache.Cache, ...) (queryrangebase.Middleware, error)

+ func NewSeriesQueryShardMiddleware(logger log.Logger, confs ShardingConfigs, ...) queryrangebase.Middleware

+ func NewSeriesTripperware(cfg Config, log log.Logger, limits Limits, metrics *Metrics, ...) (base.Middleware, error)

+ func NewSplitByRangeMiddleware(logger log.Logger, engineOpts logql.EngineOpts, limits Limits, splitAlign bool, ...) queryrangebase.Middleware

+ func NewVolumeCacheMiddleware(log log.Logger, limits Limits, merger queryrangebase.Merger, c cache.Cache, ...) (queryrangebase.Middleware, error)

+ func NewVolumeMiddleware() queryrangebase.Middleware

+ func NewVolumeTripperware(cfg Config, log log.Logger, limits Limits, schema config.SchemaConfig, ...) (base.Middleware, error)

+ func ParamsFromRequest(req queryrangebase.Request) (logql.Params, error)

+ func ParamsToLokiRequest(params logql.Params) queryrangebase.Request

+ func QueryMetricsMiddleware(metrics *QueryMetrics) queryrangebase.Middleware

+ func QueryResponseUnwrap(res *QueryResponse) (queryrangebase.Response, error)

+ func ResponseToResult(resp queryrangebase.Response) (logqlmodel.Result, error)

+ func ResultToResponse(result logqlmodel.Result, params logql.Params) (queryrangebase.Response, error)

+ func SplitByIntervalMiddleware(configs []config.PeriodConfig, limits Limits, merger queryrangebase.Merger, ...) queryrangebase.Middleware

+ func SplitIntervalForTimeRange(iqo util.IngesterQueryOptions, limits Limits, ...) time.Duration

+ func StatsCollectorMiddleware() queryrangebase.Middleware

+ func WeightedParallelism(ctx context.Context, configs []config.PeriodConfig, user string, l Limits, ...) int

+ func WriteQueryResponseProtobuf(params logql.Params, v logqlmodel.Result, w io.Writer) error

+ func WriteSeriesResponseViewJSON(v *MergedSeriesResponseView, w io.Writer) error

+ type Buffer interface

+ Bytes func() []byte

+ type Codec struct

+ func (Codec) DecodeHTTPGrpcRequest(ctx context.Context, r *httpgrpc.HTTPRequest) (queryrangebase.Request, context.Context, error)

+ func (Codec) DecodeHTTPGrpcResponse(r *httpgrpc.HTTPResponse, req queryrangebase.Request) (queryrangebase.Response, error)

+ func (Codec) DecodeRequest(_ context.Context, r *http.Request, _ []string) (queryrangebase.Request, error)

+ func (Codec) DecodeResponse(_ context.Context, r *http.Response, req queryrangebase.Request) (queryrangebase.Response, error)

+ func (Codec) EncodeHTTPGrpcResponse(_ context.Context, req *httpgrpc.HTTPRequest, res queryrangebase.Response) (*httpgrpc.HTTPResponse, error)

+ func (Codec) EncodeResponse(ctx context.Context, req *http.Request, res queryrangebase.Response) (*http.Response, error)

+ func (Codec) MergeResponse(responses ...queryrangebase.Response) (queryrangebase.Response, error)

+ func (Codec) QueryRequestUnwrap(ctx context.Context, req *QueryRequest) (queryrangebase.Request, context.Context, error)

+ func (Codec) QueryRequestWrap(ctx context.Context, r queryrangebase.Request) (*QueryRequest, error)

+ func (c Codec) EncodeRequest(ctx context.Context, r queryrangebase.Request) (*http.Request, error)

+ func (c Codec) Path(r queryrangebase.Request) string

+ type Config struct

+ CacheIndexStatsResults bool

+ CacheInstantMetricResults bool

+ CacheLabelResults bool

+ CacheSeriesResults bool

+ CacheVolumeResults bool

+ InstantMetricCacheConfig InstantMetricCacheConfig

+ InstantMetricQuerySplitAlign bool

+ LabelsCacheConfig LabelsCacheConfig

+ SeriesCacheConfig SeriesCacheConfig

+ StatsCacheConfig IndexStatsCacheConfig

+ Transformer UserIDTransformer

+ VolumeCacheConfig VolumeCacheConfig

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

+ func (cfg *Config) Validate() error

+ type DetectedFieldsRequest struct

+ func NewDetectedFieldsRequest(start, end time.Time, query, path string) *DetectedFieldsRequest

+ func (*DetectedFieldsRequest) GetCachingOptions() (res queryrangebase.CachingOptions)

+ func (r *DetectedFieldsRequest) AsProto() *logproto.DetectedFieldsRequest

+ func (r *DetectedFieldsRequest) GetEnd() time.Time

+ func (r *DetectedFieldsRequest) GetEndTs() time.Time

+ func (r *DetectedFieldsRequest) GetStart() time.Time

+ func (r *DetectedFieldsRequest) GetStartTs() time.Time

+ func (r *DetectedFieldsRequest) GetStep() int64

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

+ func (r *DetectedFieldsRequest) Path() string

+ func (r *DetectedFieldsRequest) WithQuery(query string) queryrangebase.Request

+ func (r *DetectedFieldsRequest) WithStartEnd(s, e time.Time) queryrangebase.Request

+ func (r *DetectedFieldsRequest) WithStartEndForCache(s time.Time, e time.Time) resultscache.Request

+ type DetectedFieldsResponse struct

+ Headers []github_com_grafana_loki_v3_pkg_querier_queryrange_queryrangebase_definitions.PrometheusResponseHeader

+ Response *github_com_grafana_loki_v3_pkg_logproto.DetectedFieldsResponse

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

+ func (*DetectedFieldsResponse) ProtoMessage()

+ func (m *DetectedFieldsResponse) GetHeaders() []*queryrangebase.PrometheusResponseHeader

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

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

+ func (m *DetectedFieldsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DetectedFieldsResponse) Reset()

+ func (m *DetectedFieldsResponse) SetHeader(name, value string)

+ func (m *DetectedFieldsResponse) Size() (n int)

+ func (m *DetectedFieldsResponse) Unmarshal(dAtA []byte) error

+ func (m *DetectedFieldsResponse) WithHeaders(h []queryrangebase.PrometheusResponseHeader) queryrangebase.Response

+ func (m *DetectedFieldsResponse) XXX_DiscardUnknown()

+ func (m *DetectedFieldsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DetectedFieldsResponse) XXX_Merge(src proto.Message)

+ func (m *DetectedFieldsResponse) XXX_Size() int

+ func (m *DetectedFieldsResponse) XXX_Unmarshal(b []byte) error

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

+ func (this *DetectedFieldsResponse) GoString() string

+ func (this *DetectedFieldsResponse) String() string

+ type DetectedLabelsRequest struct

+ func NewDetectedLabelsRequest(start, end time.Time, query, path string) *DetectedLabelsRequest

+ func (*DetectedLabelsRequest) GetCachingOptions() (res queryrangebase.CachingOptions)

+ func (r *DetectedLabelsRequest) AsProto() *logproto.DetectedLabelsRequest

+ func (r *DetectedLabelsRequest) GetEnd() time.Time

+ func (r *DetectedLabelsRequest) GetEndTs() time.Time

+ func (r *DetectedLabelsRequest) GetStart() time.Time

+ func (r *DetectedLabelsRequest) GetStartTs() time.Time

+ func (r *DetectedLabelsRequest) GetStep() int64

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

+ func (r *DetectedLabelsRequest) Path() string

+ func (r *DetectedLabelsRequest) WithQuery(query string) queryrangebase.Request

+ func (r *DetectedLabelsRequest) WithStartEnd(s, e time.Time) queryrangebase.Request

+ func (r *DetectedLabelsRequest) WithStartEndForCache(s time.Time, e time.Time) resultscache.Request

+ type DetectedLabelsResponse struct

+ Headers []github_com_grafana_loki_v3_pkg_querier_queryrange_queryrangebase_definitions.PrometheusResponseHeader

+ Response *github_com_grafana_loki_v3_pkg_logproto.DetectedLabelsResponse

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

+ func (*DetectedLabelsResponse) ProtoMessage()

+ func (m *DetectedLabelsResponse) GetHeaders() []*queryrangebase.PrometheusResponseHeader

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

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

+ func (m *DetectedLabelsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DetectedLabelsResponse) Reset()

+ func (m *DetectedLabelsResponse) SetHeader(name, value string)

+ func (m *DetectedLabelsResponse) Size() (n int)

+ func (m *DetectedLabelsResponse) Unmarshal(dAtA []byte) error

+ func (m *DetectedLabelsResponse) WithHeaders(h []queryrangebase.PrometheusResponseHeader) queryrangebase.Response

+ func (m *DetectedLabelsResponse) XXX_DiscardUnknown()

+ func (m *DetectedLabelsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DetectedLabelsResponse) XXX_Merge(src proto.Message)

+ func (m *DetectedLabelsResponse) XXX_Size() int

+ func (m *DetectedLabelsResponse) XXX_Unmarshal(b []byte) error

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

+ func (this *DetectedLabelsResponse) GoString() string

+ func (this *DetectedLabelsResponse) String() string

+ type DownstreamHandler struct

+ func (h DownstreamHandler) Downstreamer(ctx context.Context) logql.Downstreamer

+ type IndexStatsCacheConfig struct

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

+ func (cfg *IndexStatsCacheConfig) Validate() error

+ type IndexStatsExtractor struct

+ func (p IndexStatsExtractor) Extract(start, end int64, res resultscache.Response, resStart, resEnd int64) resultscache.Response

+ func (p IndexStatsExtractor) ResponseWithoutHeaders(resp queryrangebase.Response) queryrangebase.Response

+ type IndexStatsResponse struct

+ Headers []github_com_grafana_loki_v3_pkg_querier_queryrange_queryrangebase_definitions.PrometheusResponseHeader

+ Response *github_com_grafana_loki_v3_pkg_logproto.IndexStatsResponse

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

+ func (*IndexStatsResponse) ProtoMessage()

+ func (m *IndexStatsResponse) GetHeaders() []*queryrangebase.PrometheusResponseHeader

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

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

+ func (m *IndexStatsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *IndexStatsResponse) Reset()

+ func (m *IndexStatsResponse) SetHeader(name, value string)

+ func (m *IndexStatsResponse) Size() (n int)

+ func (m *IndexStatsResponse) Unmarshal(dAtA []byte) error

+ func (m *IndexStatsResponse) WithHeaders(h []queryrangebase.PrometheusResponseHeader) queryrangebase.Response

+ func (m *IndexStatsResponse) XXX_DiscardUnknown()

+ func (m *IndexStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *IndexStatsResponse) XXX_Merge(src proto.Message)

+ func (m *IndexStatsResponse) XXX_Size() int

+ func (m *IndexStatsResponse) XXX_Unmarshal(b []byte) error

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

+ func (this *IndexStatsResponse) GoString() string

+ func (this *IndexStatsResponse) String() string

+ type IndexStatsSplitter struct

+ func (i IndexStatsSplitter) GenerateCacheKey(ctx context.Context, userID string, r resultscache.Request) string

+ type InstantMetricCacheConfig struct

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

+ func (cfg *InstantMetricCacheConfig) Validate() error

+ type InstantMetricSplitter struct

+ func (i InstantMetricSplitter) GenerateCacheKey(ctx context.Context, userID string, r resultscache.Request) string

+ type Instrument struct

+ func (i Instrument) Wrap(next queryrangebase.Handler) queryrangebase.Handler

+ type LabelRequest struct

+ func NewLabelRequest(start, end time.Time, query, name, path string) *LabelRequest

+ func (*LabelRequest) GetCachingOptions() (res queryrangebase.CachingOptions)

+ func (r *LabelRequest) AsProto() *logproto.LabelRequest

+ func (r *LabelRequest) GetEnd() time.Time

+ func (r *LabelRequest) GetEndTs() time.Time

+ func (r *LabelRequest) GetStart() time.Time

+ func (r *LabelRequest) GetStartTs() time.Time

+ func (r *LabelRequest) GetStep() int64

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

+ func (r *LabelRequest) Path() string

+ func (r *LabelRequest) WithQuery(query string) queryrangebase.Request

+ func (r *LabelRequest) WithStartEnd(s, e time.Time) queryrangebase.Request

+ func (r *LabelRequest) WithStartEndForCache(s time.Time, e time.Time) resultscache.Request

+ type LabelsCacheConfig struct

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

+ func (cfg *LabelsCacheConfig) Validate() error

+ type Limits queryrange_limits.Limits

+ func WithMaxParallelism(l Limits, maxParallelism int) Limits

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

+ type LogResultCacheMetrics struct

+ CacheHit prometheus.Counter

+ CacheMiss prometheus.Counter

+ func NewLogResultCacheMetrics(registerer prometheus.Registerer) *LogResultCacheMetrics

+ type LokiData struct

+ Result []github_com_grafana_loki_pkg_push.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) 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 LokiInstantRequest struct

+ Direction logproto.Direction

+ Limit uint32

+ Path string

+ Plan *github_com_grafana_loki_v3_pkg_querier_plan.QueryPlan

+ Query string

+ Shards []string

+ TimeTs time.Time

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

+ func (*LokiInstantRequest) GetCachingOptions() (res queryrangebase.CachingOptions)

+ func (*LokiInstantRequest) ProtoMessage()

+ func (m *LokiInstantRequest) GetDirection() logproto.Direction

+ func (m *LokiInstantRequest) GetLimit() uint32

+ func (m *LokiInstantRequest) GetPath() string

+ func (m *LokiInstantRequest) GetQuery() string

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

+ func (m *LokiInstantRequest) GetTimeTs() time.Time

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

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

+ func (m *LokiInstantRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LokiInstantRequest) Reset()

+ func (m *LokiInstantRequest) Size() (n int)

+ func (m *LokiInstantRequest) Unmarshal(dAtA []byte) error

+ func (m *LokiInstantRequest) XXX_DiscardUnknown()

+ func (m *LokiInstantRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LokiInstantRequest) XXX_Merge(src proto.Message)

+ func (m *LokiInstantRequest) XXX_Size() int

+ func (m *LokiInstantRequest) XXX_Unmarshal(b []byte) error

+ func (r *LokiInstantRequest) GetEnd() time.Time

+ func (r *LokiInstantRequest) GetStart() time.Time

+ func (r *LokiInstantRequest) GetStep() int64

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

+ func (r *LokiInstantRequest) WithQuery(query string) queryrangebase.Request

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

+ func (r *LokiInstantRequest) WithStartEnd(s time.Time, _ time.Time) queryrangebase.Request

+ func (r *LokiInstantRequest) WithStartEndForCache(s time.Time, e time.Time) resultscache.Request

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

+ func (this *LokiInstantRequest) GoString() string

+ func (this *LokiInstantRequest) String() string

+ type LokiLabelNamesResponse struct

+ Data []string

+ Headers []github_com_grafana_loki_v3_pkg_querier_queryrange_queryrangebase_definitions.PrometheusResponseHeader

+ Statistics stats.Result

+ Status string

+ Version uint32

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

+ func (*LokiLabelNamesResponse) ProtoMessage()

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

+ func (m *LokiLabelNamesResponse) GetHeaders() []*queryrangebase.PrometheusResponseHeader

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

+ 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) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LokiLabelNamesResponse) Reset()

+ func (m *LokiLabelNamesResponse) SetHeader(name, value string)

+ func (m *LokiLabelNamesResponse) Size() (n int)

+ func (m *LokiLabelNamesResponse) Unmarshal(dAtA []byte) error

+ func (m *LokiLabelNamesResponse) WithHeaders(h []queryrangebase.PrometheusResponseHeader) queryrangebase.Response

+ 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 *queryrangebase.PrometheusResponse

+ Statistics stats.Result

+ func ToPrometheusResponse(respsCh chan *bucketedVolumeResponse, aggregateBySeries bool) *LokiPromResponse

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

+ func (*LokiPromResponse) ProtoMessage()

+ func (m *LokiPromResponse) GetHeaders() []*queryrangebase.PrometheusResponseHeader

+ func (m *LokiPromResponse) GetResponse() *queryrangebase.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) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LokiPromResponse) Reset()

+ func (m *LokiPromResponse) SetHeader(name, value string)

+ func (m *LokiPromResponse) Size() (n int)

+ func (m *LokiPromResponse) Unmarshal(dAtA []byte) error

+ func (m *LokiPromResponse) WithHeaders(h []queryrangebase.PrometheusResponseHeader) queryrangebase.Response

+ 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

+ Interval int64

+ Limit uint32

+ Path string

+ Plan *github_com_grafana_loki_v3_pkg_querier_plan.QueryPlan

+ Query string

+ Shards []string

+ StartTs time.Time

+ Step int64

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

+ func (*LokiRequest) GetCachingOptions() (res queryrangebase.CachingOptions)

+ func (*LokiRequest) ProtoMessage()

+ func (m *LokiRequest) GetDirection() logproto.Direction

+ func (m *LokiRequest) GetEndTs() time.Time

+ func (m *LokiRequest) GetInterval() int64

+ 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) 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() time.Time

+ func (r *LokiRequest) GetStart() time.Time

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

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

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

+ func (r *LokiRequest) WithStartEnd(s time.Time, e time.Time) queryrangebase.Request

+ func (r *LokiRequest) WithStartEndForCache(s time.Time, e time.Time) resultscache.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_grafana_loki_v3_pkg_querier_queryrange_queryrangebase_definitions.PrometheusResponseHeader

+ Limit uint32

+ Statistics stats.Result

+ Status string

+ Version uint32

+ Warnings []string

+ 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() []*queryrangebase.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) GetWarnings() []string

+ 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) SetHeader(name, value string)

+ func (m *LokiResponse) Size() (n int)

+ func (m *LokiResponse) Unmarshal(dAtA []byte) error

+ func (m *LokiResponse) WithHeaders(h []queryrangebase.PrometheusResponseHeader) queryrangebase.Response

+ 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

+ Shards []string

+ StartTs time.Time

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

+ func (*LokiSeriesRequest) GetCachingOptions() (res queryrangebase.CachingOptions)

+ func (*LokiSeriesRequest) ProtoMessage()

+ func (m *LokiSeriesRequest) GetEndTs() time.Time

+ func (m *LokiSeriesRequest) GetMatch() []string

+ func (m *LokiSeriesRequest) GetPath() string

+ func (m *LokiSeriesRequest) GetShards() []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) MarshalToSizedBuffer(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() time.Time

+ func (r *LokiSeriesRequest) GetQuery() string

+ func (r *LokiSeriesRequest) GetStart() time.Time

+ func (r *LokiSeriesRequest) GetStep() int64

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

+ func (r *LokiSeriesRequest) WithQuery(_ string) queryrangebase.Request

+ func (r *LokiSeriesRequest) WithStartEnd(s, e time.Time) queryrangebase.Request

+ func (r *LokiSeriesRequest) WithStartEndForCache(s time.Time, e time.Time) resultscache.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_grafana_loki_v3_pkg_querier_queryrange_queryrangebase_definitions.PrometheusResponseHeader

+ Statistics stats.Result

+ Status string

+ Version uint32

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

+ func (*LokiSeriesResponse) ProtoMessage()

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

+ func (m *LokiSeriesResponse) GetHeaders() []*queryrangebase.PrometheusResponseHeader

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

+ 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) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LokiSeriesResponse) Reset()

+ func (m *LokiSeriesResponse) SetHeader(name, value string)

+ func (m *LokiSeriesResponse) Size() (n int)

+ func (m *LokiSeriesResponse) Unmarshal(dAtA []byte) error

+ func (m *LokiSeriesResponse) UnmarshalJSON(data []byte) error

+ func (m *LokiSeriesResponse) WithHeaders(h []queryrangebase.PrometheusResponseHeader) queryrangebase.Response

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

+ func GetLokiSeriesResponseView(data []byte) (view *LokiSeriesResponseView, err error)

+ func (v *LokiSeriesResponseView) ForEachSeries(fn func(view *SeriesIdentifierView) error) error

+ func (v *LokiSeriesResponseView) GetHeaders() []*queryrangebase.PrometheusResponseHeader

+ func (v *LokiSeriesResponseView) ProtoMessage()

+ func (v *LokiSeriesResponseView) Reset()

+ func (v *LokiSeriesResponseView) SetHeader(name, value string)

+ func (v *LokiSeriesResponseView) String() string

+ func (v *LokiSeriesResponseView) WithHeaders(h []queryrangebase.PrometheusResponseHeader) queryrangebase.Response

+ type MergedSeriesResponseView struct

+ func (v *MergedSeriesResponseView) ForEachUniqueSeries(fn func(*SeriesIdentifierView) error) error

+ func (v *MergedSeriesResponseView) GetHeaders() []*queryrangebase.PrometheusResponseHeader

+ func (v *MergedSeriesResponseView) Materialize() (*LokiSeriesResponse, error)

+ func (v *MergedSeriesResponseView) ProtoMessage()

+ func (v *MergedSeriesResponseView) Reset()

+ func (v *MergedSeriesResponseView) SetHeader(name, value string)

+ func (v *MergedSeriesResponseView) String() string

+ func (v *MergedSeriesResponseView) WithHeaders(headers []queryrangebase.PrometheusResponseHeader) queryrangebase.Response

+ type Metrics struct

+ func NewMetrics(registerer prometheus.Registerer, metricsNamespace string) *Metrics

+ type MiddlewareMapperMetrics struct

+ func NewMiddlewareMapperMetrics(registerer prometheus.Registerer) *MiddlewareMapperMetrics

+ type Plan struct

+ Raw []byte

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

+ func (*Plan) ProtoMessage()

+ func (m *Plan) GetRaw() []byte

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

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

+ func (m *Plan) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Plan) Reset()

+ func (m *Plan) Size() (n int)

+ func (m *Plan) Unmarshal(dAtA []byte) error

+ func (m *Plan) XXX_DiscardUnknown()

+ func (m *Plan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Plan) XXX_Merge(src proto.Message)

+ func (m *Plan) XXX_Size() int

+ func (m *Plan) XXX_Unmarshal(b []byte) error

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

+ func (this *Plan) GoString() string

+ func (this *Plan) String() string

+ type PrometheusExtractor struct

+ func (PrometheusExtractor) Extract(start, end int64, res resultscache.Response, resStart, resEnd int64) resultscache.Response

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

+ type QuantileSketchResponse struct

+ Headers []github_com_grafana_loki_v3_pkg_querier_queryrange_queryrangebase_definitions.PrometheusResponseHeader

+ Response *github_com_grafana_loki_v3_pkg_logproto.QuantileSketchMatrix

+ Warnings []string

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

+ func (*QuantileSketchResponse) ProtoMessage()

+ func (m *QuantileSketchResponse) GetHeaders() []*queryrangebase.PrometheusResponseHeader

+ func (m *QuantileSketchResponse) GetWarnings() []string

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

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

+ func (m *QuantileSketchResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *QuantileSketchResponse) Reset()

+ func (m *QuantileSketchResponse) SetHeader(name, value string)

+ func (m *QuantileSketchResponse) Size() (n int)

+ func (m *QuantileSketchResponse) Unmarshal(dAtA []byte) error

+ func (m *QuantileSketchResponse) WithHeaders(h []queryrangebase.PrometheusResponseHeader) queryrangebase.Response

+ func (m *QuantileSketchResponse) XXX_DiscardUnknown()

+ func (m *QuantileSketchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *QuantileSketchResponse) XXX_Merge(src proto.Message)

+ func (m *QuantileSketchResponse) XXX_Size() int

+ func (m *QuantileSketchResponse) XXX_Unmarshal(b []byte) error

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

+ func (this *QuantileSketchResponse) GoString() string

+ func (this *QuantileSketchResponse) String() string

+ type QueryMetrics struct

+ func NewMiddlewareQueryMetrics(registerer prometheus.Registerer, metricsNamespace string) *QueryMetrics

+ type QueryPatternsResponse struct

+ Headers []github_com_grafana_loki_v3_pkg_querier_queryrange_queryrangebase_definitions.PrometheusResponseHeader

+ Response *github_com_grafana_loki_v3_pkg_logproto.QueryPatternsResponse

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

+ func (*QueryPatternsResponse) ProtoMessage()

+ func (m *QueryPatternsResponse) GetHeaders() []*queryrangebase.PrometheusResponseHeader

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

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

+ func (m *QueryPatternsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *QueryPatternsResponse) Reset()

+ func (m *QueryPatternsResponse) SetHeader(name, value string)

+ func (m *QueryPatternsResponse) Size() (n int)

+ func (m *QueryPatternsResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryPatternsResponse) WithHeaders(h []queryrangebase.PrometheusResponseHeader) queryrangebase.Response

+ func (m *QueryPatternsResponse) XXX_DiscardUnknown()

+ func (m *QueryPatternsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *QueryPatternsResponse) XXX_Merge(src proto.Message)

+ func (m *QueryPatternsResponse) XXX_Size() int

+ func (m *QueryPatternsResponse) XXX_Unmarshal(b []byte) error

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

+ func (this *QueryPatternsResponse) GoString() string

+ func (this *QueryPatternsResponse) String() string

+ type QueryRequest struct

+ Metadata map[string]string

+ Request isQueryRequest_Request

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

+ func (*QueryRequest) ProtoMessage()

+ func (*QueryRequest) XXX_OneofWrappers() []interface{}

+ func (m *QueryRequest) GetDetectedFields() *logproto.DetectedFieldsRequest

+ func (m *QueryRequest) GetDetectedLabels() *logproto.DetectedLabelsRequest

+ func (m *QueryRequest) GetInstant() *LokiInstantRequest

+ func (m *QueryRequest) GetLabels() *logproto.LabelRequest

+ func (m *QueryRequest) GetMetadata() map[string]string

+ func (m *QueryRequest) GetPatternsRequest() *logproto.QueryPatternsRequest

+ func (m *QueryRequest) GetRequest() isQueryRequest_Request

+ func (m *QueryRequest) GetSeries() *LokiSeriesRequest

+ func (m *QueryRequest) GetShardsRequest() *logproto.ShardsRequest

+ func (m *QueryRequest) GetStats() *logproto.IndexStatsRequest

+ func (m *QueryRequest) GetStreams() *LokiRequest

+ func (m *QueryRequest) GetVolume() *logproto.VolumeRequest

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

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

+ func (m *QueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *QueryRequest) Reset()

+ func (m *QueryRequest) Size() (n int)

+ func (m *QueryRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryRequest) XXX_DiscardUnknown()

+ func (m *QueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *QueryRequest) XXX_Merge(src proto.Message)

+ func (m *QueryRequest) XXX_Size() int

+ func (m *QueryRequest) XXX_Unmarshal(b []byte) error

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

+ func (this *QueryRequest) GoString() string

+ func (this *QueryRequest) String() string

+ type QueryRequest_DetectedFields struct

+ DetectedFields *logproto.DetectedFieldsRequest

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

+ func (m *QueryRequest_DetectedFields) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *QueryRequest_DetectedFields) Size() (n int)

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

+ func (this *QueryRequest_DetectedFields) GoString() string

+ func (this *QueryRequest_DetectedFields) String() string

+ type QueryRequest_DetectedLabels struct

+ DetectedLabels *logproto.DetectedLabelsRequest

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

+ func (m *QueryRequest_DetectedLabels) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *QueryRequest_DetectedLabels) Size() (n int)

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

+ func (this *QueryRequest_DetectedLabels) GoString() string

+ func (this *QueryRequest_DetectedLabels) String() string

+ type QueryRequest_Instant struct

+ Instant *LokiInstantRequest

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

+ func (m *QueryRequest_Instant) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *QueryRequest_Instant) Size() (n int)

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

+ func (this *QueryRequest_Instant) GoString() string

+ func (this *QueryRequest_Instant) String() string

+ type QueryRequest_Labels struct

+ Labels *logproto.LabelRequest

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

+ func (m *QueryRequest_Labels) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *QueryRequest_Labels) Size() (n int)

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

+ func (this *QueryRequest_Labels) GoString() string

+ func (this *QueryRequest_Labels) String() string

+ type QueryRequest_PatternsRequest struct

+ PatternsRequest *logproto.QueryPatternsRequest

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

+ func (m *QueryRequest_PatternsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *QueryRequest_PatternsRequest) Size() (n int)

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

+ func (this *QueryRequest_PatternsRequest) GoString() string

+ func (this *QueryRequest_PatternsRequest) String() string

+ type QueryRequest_Series struct

+ Series *LokiSeriesRequest

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

+ func (m *QueryRequest_Series) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *QueryRequest_Series) Size() (n int)

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

+ func (this *QueryRequest_Series) GoString() string

+ func (this *QueryRequest_Series) String() string

+ type QueryRequest_ShardsRequest struct

+ ShardsRequest *logproto.ShardsRequest

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

+ func (m *QueryRequest_ShardsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *QueryRequest_ShardsRequest) Size() (n int)

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

+ func (this *QueryRequest_ShardsRequest) GoString() string

+ func (this *QueryRequest_ShardsRequest) String() string

+ type QueryRequest_Stats struct

+ Stats *logproto.IndexStatsRequest

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

+ func (m *QueryRequest_Stats) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *QueryRequest_Stats) Size() (n int)

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

+ func (this *QueryRequest_Stats) GoString() string

+ func (this *QueryRequest_Stats) String() string

+ type QueryRequest_Streams struct

+ Streams *LokiRequest

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

+ func (m *QueryRequest_Streams) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *QueryRequest_Streams) Size() (n int)

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

+ func (this *QueryRequest_Streams) GoString() string

+ func (this *QueryRequest_Streams) String() string

+ type QueryRequest_Volume struct

+ Volume *logproto.VolumeRequest

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

+ func (m *QueryRequest_Volume) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *QueryRequest_Volume) Size() (n int)

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

+ func (this *QueryRequest_Volume) GoString() string

+ func (this *QueryRequest_Volume) String() string

+ type QueryResponse struct

+ Response isQueryResponse_Response

+ Status *rpc.Status

+ func QueryResponseWrap(res queryrangebase.Response) (*QueryResponse, error)

+ func QueryResponseWrapError(err error) *QueryResponse

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

+ func (*QueryResponse) ProtoMessage()

+ func (*QueryResponse) XXX_OneofWrappers() []interface{}

+ func (m *QueryResponse) GetDetectedFields() *DetectedFieldsResponse

+ func (m *QueryResponse) GetDetectedLabels() *DetectedLabelsResponse

+ func (m *QueryResponse) GetLabels() *LokiLabelNamesResponse

+ func (m *QueryResponse) GetPatternsResponse() *QueryPatternsResponse

+ func (m *QueryResponse) GetProm() *LokiPromResponse

+ func (m *QueryResponse) GetQuantileSketches() *QuantileSketchResponse

+ func (m *QueryResponse) GetResponse() isQueryResponse_Response

+ func (m *QueryResponse) GetSeries() *LokiSeriesResponse

+ func (m *QueryResponse) GetShardsResponse() *ShardsResponse

+ func (m *QueryResponse) GetStats() *IndexStatsResponse

+ func (m *QueryResponse) GetStatus() *rpc.Status

+ func (m *QueryResponse) GetStreams() *LokiResponse

+ func (m *QueryResponse) GetTopkSketches() *TopKSketchesResponse

+ func (m *QueryResponse) GetVolume() *VolumeResponse

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

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

+ func (m *QueryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *QueryResponse) Reset()

+ func (m *QueryResponse) Size() (n int)

+ func (m *QueryResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryResponse) XXX_DiscardUnknown()

+ func (m *QueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *QueryResponse) XXX_Merge(src proto.Message)

+ func (m *QueryResponse) XXX_Size() int

+ func (m *QueryResponse) XXX_Unmarshal(b []byte) error

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

+ func (this *QueryResponse) GoString() string

+ func (this *QueryResponse) String() string

+ type QueryResponse_DetectedFields struct

+ DetectedFields *DetectedFieldsResponse

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

+ func (m *QueryResponse_DetectedFields) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *QueryResponse_DetectedFields) Size() (n int)

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

+ func (this *QueryResponse_DetectedFields) GoString() string

+ func (this *QueryResponse_DetectedFields) String() string

+ type QueryResponse_DetectedLabels struct

+ DetectedLabels *DetectedLabelsResponse

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

+ func (m *QueryResponse_DetectedLabels) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *QueryResponse_DetectedLabels) Size() (n int)

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

+ func (this *QueryResponse_DetectedLabels) GoString() string

+ func (this *QueryResponse_DetectedLabels) String() string

+ type QueryResponse_Labels struct

+ Labels *LokiLabelNamesResponse

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

+ func (m *QueryResponse_Labels) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *QueryResponse_Labels) Size() (n int)

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

+ func (this *QueryResponse_Labels) GoString() string

+ func (this *QueryResponse_Labels) String() string

+ type QueryResponse_PatternsResponse struct

+ PatternsResponse *QueryPatternsResponse

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

+ func (m *QueryResponse_PatternsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *QueryResponse_PatternsResponse) Size() (n int)

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

+ func (this *QueryResponse_PatternsResponse) GoString() string

+ func (this *QueryResponse_PatternsResponse) String() string

+ type QueryResponse_Prom struct

+ Prom *LokiPromResponse

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

+ func (m *QueryResponse_Prom) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *QueryResponse_Prom) Size() (n int)

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

+ func (this *QueryResponse_Prom) GoString() string

+ func (this *QueryResponse_Prom) String() string

+ type QueryResponse_QuantileSketches struct

+ QuantileSketches *QuantileSketchResponse

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

+ func (m *QueryResponse_QuantileSketches) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *QueryResponse_QuantileSketches) Size() (n int)

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

+ func (this *QueryResponse_QuantileSketches) GoString() string

+ func (this *QueryResponse_QuantileSketches) String() string

+ type QueryResponse_Series struct

+ Series *LokiSeriesResponse

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

+ func (m *QueryResponse_Series) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *QueryResponse_Series) Size() (n int)

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

+ func (this *QueryResponse_Series) GoString() string

+ func (this *QueryResponse_Series) String() string

+ type QueryResponse_ShardsResponse struct

+ ShardsResponse *ShardsResponse

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

+ func (m *QueryResponse_ShardsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *QueryResponse_ShardsResponse) Size() (n int)

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

+ func (this *QueryResponse_ShardsResponse) GoString() string

+ func (this *QueryResponse_ShardsResponse) String() string

+ type QueryResponse_Stats struct

+ Stats *IndexStatsResponse

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

+ func (m *QueryResponse_Stats) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *QueryResponse_Stats) Size() (n int)

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

+ func (this *QueryResponse_Stats) GoString() string

+ func (this *QueryResponse_Stats) String() string

+ type QueryResponse_Streams struct

+ Streams *LokiResponse

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

+ func (m *QueryResponse_Streams) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *QueryResponse_Streams) Size() (n int)

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

+ func (this *QueryResponse_Streams) GoString() string

+ func (this *QueryResponse_Streams) String() string

+ type QueryResponse_TopkSketches struct

+ TopkSketches *TopKSketchesResponse

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

+ func (m *QueryResponse_TopkSketches) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *QueryResponse_TopkSketches) Size() (n int)

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

+ func (this *QueryResponse_TopkSketches) GoString() string

+ func (this *QueryResponse_TopkSketches) String() string

+ type QueryResponse_Volume struct

+ Volume *VolumeResponse

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

+ func (m *QueryResponse_Volume) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *QueryResponse_Volume) Size() (n int)

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

+ func (this *QueryResponse_Volume) GoString() string

+ func (this *QueryResponse_Volume) String() string

+ type RequestProtobufCodec struct

+ func (p RequestProtobufCodec) EncodeRequest(ctx context.Context, r queryrangebase.Request) (*http.Request, error)

+ type SemaphoreWithTiming struct

+ func NewSemaphoreWithTiming(max int64) *SemaphoreWithTiming

+ func (s *SemaphoreWithTiming) Acquire(ctx context.Context, n int64) (time.Duration, error)

+ type SeriesCacheConfig struct

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

+ func (cfg *SeriesCacheConfig) Validate() error

+ type SeriesIdentifierView struct

+ func (v *SeriesIdentifierView) ForEachLabel(fn func(string, string) error) error

+ func (v *SeriesIdentifierView) Hash(b []byte, keyLabelPairs []string) (uint64, []string, error)

+ func (v *SeriesIdentifierView) HashFast(b []byte, keyLabelPairs []string) (uint64, []string, error)

+ type ShardingConfigs []config.PeriodConfig

+ func (confs ShardingConfigs) GetConf(start, end int64) (config.PeriodConfig, error)

+ func (confs ShardingConfigs) ValidRange(start, end int64) (config.PeriodConfig, error)

+ type ShardsResponse struct

+ Headers []github_com_grafana_loki_v3_pkg_querier_queryrange_queryrangebase_definitions.PrometheusResponseHeader

+ Response *github_com_grafana_loki_v3_pkg_logproto.ShardsResponse

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

+ func (*ShardsResponse) ProtoMessage()

+ func (m *ShardsResponse) GetHeaders() []*queryrangebase.PrometheusResponseHeader

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

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

+ func (m *ShardsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ShardsResponse) Reset()

+ func (m *ShardsResponse) SetHeader(name, value string)

+ func (m *ShardsResponse) Size() (n int)

+ func (m *ShardsResponse) Unmarshal(dAtA []byte) error

+ func (m *ShardsResponse) WithHeaders(h []queryrangebase.PrometheusResponseHeader) queryrangebase.Response

+ func (m *ShardsResponse) XXX_DiscardUnknown()

+ func (m *ShardsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ShardsResponse) XXX_Merge(src proto.Message)

+ func (m *ShardsResponse) XXX_Size() int

+ func (m *ShardsResponse) XXX_Unmarshal(b []byte) error

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

+ func (this *ShardsResponse) GoString() string

+ func (this *ShardsResponse) String() string

+ type SplitByMetrics struct

+ func NewSplitByMetrics(r prometheus.Registerer) *SplitByMetrics

+ type Stopper interface

+ Stop func()

+ func NewMiddleware(cfg Config, engineOpts logql.EngineOpts, iqo util.IngesterQueryOptions, ...) (base.Middleware, Stopper, error)

+ type StopperWrapper []Stopper

+ func (s StopperWrapper) Stop()

+ type TopKSketchesResponse struct

+ Headers []github_com_grafana_loki_v3_pkg_querier_queryrange_queryrangebase_definitions.PrometheusResponseHeader

+ Response *github_com_grafana_loki_v3_pkg_logproto.TopKMatrix

+ Warnings []string

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

+ func (*TopKSketchesResponse) ProtoMessage()

+ func (m *TopKSketchesResponse) GetHeaders() []*queryrangebase.PrometheusResponseHeader

+ func (m *TopKSketchesResponse) GetWarnings() []string

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

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

+ func (m *TopKSketchesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TopKSketchesResponse) Reset()

+ func (m *TopKSketchesResponse) SetHeader(name, value string)

+ func (m *TopKSketchesResponse) Size() (n int)

+ func (m *TopKSketchesResponse) Unmarshal(dAtA []byte) error

+ func (m *TopKSketchesResponse) WithHeaders(h []queryrangebase.PrometheusResponseHeader) queryrangebase.Response

+ func (m *TopKSketchesResponse) XXX_DiscardUnknown()

+ func (m *TopKSketchesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TopKSketchesResponse) XXX_Merge(src proto.Message)

+ func (m *TopKSketchesResponse) XXX_Size() int

+ func (m *TopKSketchesResponse) XXX_Unmarshal(b []byte) error

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

+ func (this *TopKSketchesResponse) GoString() string

+ func (this *TopKSketchesResponse) String() string

+ type Tracer struct

+ func (t Tracer) Wrap(next queryrangebase.Handler) queryrangebase.Handler

+ type UserIDTransformer func(context.Context, string) string

+ type VolumeCacheConfig struct

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

+ func (cfg *VolumeCacheConfig) Validate() error

+ type VolumeExtractor struct

+ func (p VolumeExtractor) Extract(start, end int64, res resultscache.Response, resStart, resEnd int64) resultscache.Response

+ func (p VolumeExtractor) ResponseWithoutHeaders(resp queryrangebase.Response) queryrangebase.Response

+ type VolumeResponse struct

+ Headers []github_com_grafana_loki_v3_pkg_querier_queryrange_queryrangebase_definitions.PrometheusResponseHeader

+ Response *github_com_grafana_loki_v3_pkg_logproto.VolumeResponse

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

+ func (*VolumeResponse) ProtoMessage()

+ func (m *VolumeResponse) GetHeaders() []*queryrangebase.PrometheusResponseHeader

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

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

+ func (m *VolumeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *VolumeResponse) Reset()

+ func (m *VolumeResponse) SetHeader(name, value string)

+ func (m *VolumeResponse) Size() (n int)

+ func (m *VolumeResponse) Unmarshal(dAtA []byte) error

+ func (m *VolumeResponse) WithHeaders(h []queryrangebase.PrometheusResponseHeader) queryrangebase.Response

+ func (m *VolumeResponse) XXX_DiscardUnknown()

+ func (m *VolumeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *VolumeResponse) XXX_Merge(src proto.Message)

+ func (m *VolumeResponse) XXX_Size() int

+ func (m *VolumeResponse) XXX_Unmarshal(b []byte) error

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

+ func (this *VolumeResponse) GoString() string

+ func (this *VolumeResponse) String() string

+ type VolumeSplitter struct

+ func (i VolumeSplitter) GenerateCacheKey(ctx context.Context, userID string, r resultscache.Request) string

Other modules containing this package

github.com/grafana/loki

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