Documentation ¶
Index ¶
- Constants
- Variables
- 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) (logql.Result, error)
- func SplitByIntervalMiddleware(limits Limits, merger queryrange.Merger, splitter Splitter, ...) queryrange.Middleware
- func StatsCollectorMiddleware() queryrange.Middleware
- type Config
- type DownstreamHandler
- type Limits
- type PrometheusExtractor
- type SplitByMetrics
- type Splitter
- type Stopper
- type ValiData
- func (*ValiData) Descriptor() ([]byte, []int)
- func (this *ValiData) Equal(that interface{}) bool
- func (m *ValiData) GetResultType() string
- func (this *ValiData) GoString() string
- func (m *ValiData) Marshal() (dAtA []byte, err error)
- func (m *ValiData) MarshalTo(dAtA []byte) (int, error)
- func (*ValiData) ProtoMessage()
- func (m *ValiData) Reset()
- func (m *ValiData) Size() (n int)
- func (this *ValiData) String() string
- func (m *ValiData) Unmarshal(dAtA []byte) error
- func (m *ValiData) XXX_DiscardUnknown()
- func (m *ValiData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ValiData) XXX_Merge(src proto.Message)
- func (m *ValiData) XXX_Size() int
- func (m *ValiData) XXX_Unmarshal(b []byte) error
- type ValiLabelNamesRequest
- func (*ValiLabelNamesRequest) Descriptor() ([]byte, []int)
- func (this *ValiLabelNamesRequest) Equal(that interface{}) bool
- func (*ValiLabelNamesRequest) GetCachingOptions() (res queryrange.CachingOptions)
- func (r *ValiLabelNamesRequest) GetEnd() int64
- func (m *ValiLabelNamesRequest) GetEndTs() time.Time
- func (m *ValiLabelNamesRequest) GetPath() string
- func (r *ValiLabelNamesRequest) GetQuery() string
- func (r *ValiLabelNamesRequest) GetStart() int64
- func (m *ValiLabelNamesRequest) GetStartTs() time.Time
- func (r *ValiLabelNamesRequest) GetStep() int64
- func (this *ValiLabelNamesRequest) GoString() string
- func (r *ValiLabelNamesRequest) LogToSpan(sp opentracing.Span)
- func (m *ValiLabelNamesRequest) Marshal() (dAtA []byte, err error)
- func (m *ValiLabelNamesRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ValiLabelNamesRequest) ProtoMessage()
- func (m *ValiLabelNamesRequest) Reset()
- func (m *ValiLabelNamesRequest) Size() (n int)
- func (this *ValiLabelNamesRequest) String() string
- func (m *ValiLabelNamesRequest) Unmarshal(dAtA []byte) error
- func (r *ValiLabelNamesRequest) WithQuery(query string) queryrange.Request
- func (r *ValiLabelNamesRequest) WithStartEnd(s int64, e int64) queryrange.Request
- func (m *ValiLabelNamesRequest) XXX_DiscardUnknown()
- func (m *ValiLabelNamesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ValiLabelNamesRequest) XXX_Merge(src proto.Message)
- func (m *ValiLabelNamesRequest) XXX_Size() int
- func (m *ValiLabelNamesRequest) XXX_Unmarshal(b []byte) error
- type ValiLabelNamesResponse
- func (*ValiLabelNamesResponse) Descriptor() ([]byte, []int)
- func (this *ValiLabelNamesResponse) Equal(that interface{}) bool
- func (m *ValiLabelNamesResponse) GetData() []string
- func (m *ValiLabelNamesResponse) GetHeaders() []*queryrange.PrometheusResponseHeader
- func (m *ValiLabelNamesResponse) GetStatus() string
- func (m *ValiLabelNamesResponse) GetVersion() uint32
- func (this *ValiLabelNamesResponse) GoString() string
- func (m *ValiLabelNamesResponse) Marshal() (dAtA []byte, err error)
- func (m *ValiLabelNamesResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ValiLabelNamesResponse) ProtoMessage()
- func (m *ValiLabelNamesResponse) Reset()
- func (m *ValiLabelNamesResponse) Size() (n int)
- func (this *ValiLabelNamesResponse) String() string
- func (m *ValiLabelNamesResponse) Unmarshal(dAtA []byte) error
- func (m *ValiLabelNamesResponse) XXX_DiscardUnknown()
- func (m *ValiLabelNamesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ValiLabelNamesResponse) XXX_Merge(src proto.Message)
- func (m *ValiLabelNamesResponse) XXX_Size() int
- func (m *ValiLabelNamesResponse) XXX_Unmarshal(b []byte) error
- type ValiPromResponse
- func (*ValiPromResponse) Descriptor() ([]byte, []int)
- func (this *ValiPromResponse) Equal(that interface{}) bool
- func (m *ValiPromResponse) GetHeaders() []*queryrange.PrometheusResponseHeader
- func (m *ValiPromResponse) GetResponse() *queryrange.PrometheusResponse
- func (m *ValiPromResponse) GetStatistics() stats.Result
- func (this *ValiPromResponse) GoString() string
- func (m *ValiPromResponse) Marshal() (dAtA []byte, err error)
- func (m *ValiPromResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ValiPromResponse) ProtoMessage()
- func (m *ValiPromResponse) Reset()
- func (m *ValiPromResponse) Size() (n int)
- func (this *ValiPromResponse) String() string
- func (m *ValiPromResponse) Unmarshal(dAtA []byte) error
- func (m *ValiPromResponse) XXX_DiscardUnknown()
- func (m *ValiPromResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ValiPromResponse) XXX_Merge(src proto.Message)
- func (m *ValiPromResponse) XXX_Size() int
- func (m *ValiPromResponse) XXX_Unmarshal(b []byte) error
- type ValiRequest
- func (*ValiRequest) Descriptor() ([]byte, []int)
- func (this *ValiRequest) Equal(that interface{}) bool
- func (*ValiRequest) GetCachingOptions() (res queryrange.CachingOptions)
- func (m *ValiRequest) GetDirection() logproto.Direction
- func (r *ValiRequest) GetEnd() int64
- func (m *ValiRequest) GetEndTs() time.Time
- func (m *ValiRequest) GetLimit() uint32
- func (m *ValiRequest) GetPath() string
- func (m *ValiRequest) GetQuery() string
- func (m *ValiRequest) GetShards() []string
- func (r *ValiRequest) GetStart() int64
- func (m *ValiRequest) GetStartTs() time.Time
- func (m *ValiRequest) GetStep() int64
- func (this *ValiRequest) GoString() string
- func (r *ValiRequest) LogToSpan(sp opentracing.Span)
- func (m *ValiRequest) Marshal() (dAtA []byte, err error)
- func (m *ValiRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ValiRequest) ProtoMessage()
- func (m *ValiRequest) Reset()
- func (m *ValiRequest) Size() (n int)
- func (this *ValiRequest) String() string
- func (m *ValiRequest) Unmarshal(dAtA []byte) error
- func (r *ValiRequest) WithQuery(query string) queryrange.Request
- func (r *ValiRequest) WithShards(shards logql.Shards) *ValiRequest
- func (r *ValiRequest) WithStartEnd(s int64, e int64) queryrange.Request
- func (m *ValiRequest) XXX_DiscardUnknown()
- func (m *ValiRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ValiRequest) XXX_Merge(src proto.Message)
- func (m *ValiRequest) XXX_Size() int
- func (m *ValiRequest) XXX_Unmarshal(b []byte) error
- type ValiResponse
- func (res ValiResponse) Count() int64
- func (*ValiResponse) Descriptor() ([]byte, []int)
- func (this *ValiResponse) Equal(that interface{}) bool
- func (m *ValiResponse) GetData() ValiData
- func (m *ValiResponse) GetDirection() logproto.Direction
- func (m *ValiResponse) GetError() string
- func (m *ValiResponse) GetErrorType() string
- func (m *ValiResponse) GetHeaders() []*queryrange.PrometheusResponseHeader
- func (m *ValiResponse) GetLimit() uint32
- func (m *ValiResponse) GetStatistics() stats.Result
- func (m *ValiResponse) GetStatus() string
- func (m *ValiResponse) GetVersion() uint32
- func (this *ValiResponse) GoString() string
- func (m *ValiResponse) Marshal() (dAtA []byte, err error)
- func (m *ValiResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ValiResponse) ProtoMessage()
- func (m *ValiResponse) Reset()
- func (m *ValiResponse) Size() (n int)
- func (this *ValiResponse) String() string
- func (m *ValiResponse) Unmarshal(dAtA []byte) error
- func (m *ValiResponse) XXX_DiscardUnknown()
- func (m *ValiResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ValiResponse) XXX_Merge(src proto.Message)
- func (m *ValiResponse) XXX_Size() int
- func (m *ValiResponse) XXX_Unmarshal(b []byte) error
- type ValiSeriesRequest
- func (*ValiSeriesRequest) Descriptor() ([]byte, []int)
- func (this *ValiSeriesRequest) Equal(that interface{}) bool
- func (*ValiSeriesRequest) GetCachingOptions() (res queryrange.CachingOptions)
- func (r *ValiSeriesRequest) GetEnd() int64
- func (m *ValiSeriesRequest) GetEndTs() time.Time
- func (m *ValiSeriesRequest) GetMatch() []string
- func (m *ValiSeriesRequest) GetPath() string
- func (r *ValiSeriesRequest) GetQuery() string
- func (r *ValiSeriesRequest) GetStart() int64
- func (m *ValiSeriesRequest) GetStartTs() time.Time
- func (r *ValiSeriesRequest) GetStep() int64
- func (this *ValiSeriesRequest) GoString() string
- func (r *ValiSeriesRequest) LogToSpan(sp opentracing.Span)
- func (m *ValiSeriesRequest) Marshal() (dAtA []byte, err error)
- func (m *ValiSeriesRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ValiSeriesRequest) ProtoMessage()
- func (m *ValiSeriesRequest) Reset()
- func (m *ValiSeriesRequest) Size() (n int)
- func (this *ValiSeriesRequest) String() string
- func (m *ValiSeriesRequest) Unmarshal(dAtA []byte) error
- func (r *ValiSeriesRequest) WithQuery(query string) queryrange.Request
- func (r *ValiSeriesRequest) WithStartEnd(s int64, e int64) queryrange.Request
- func (m *ValiSeriesRequest) XXX_DiscardUnknown()
- func (m *ValiSeriesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ValiSeriesRequest) XXX_Merge(src proto.Message)
- func (m *ValiSeriesRequest) XXX_Size() int
- func (m *ValiSeriesRequest) XXX_Unmarshal(b []byte) error
- type ValiSeriesResponse
- func (*ValiSeriesResponse) Descriptor() ([]byte, []int)
- func (this *ValiSeriesResponse) Equal(that interface{}) bool
- func (m *ValiSeriesResponse) GetData() []logproto.SeriesIdentifier
- func (m *ValiSeriesResponse) GetHeaders() []*queryrange.PrometheusResponseHeader
- func (m *ValiSeriesResponse) GetStatus() string
- func (m *ValiSeriesResponse) GetVersion() uint32
- func (this *ValiSeriesResponse) GoString() string
- func (m *ValiSeriesResponse) Marshal() (dAtA []byte, err error)
- func (m *ValiSeriesResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ValiSeriesResponse) ProtoMessage()
- func (m *ValiSeriesResponse) Reset()
- func (m *ValiSeriesResponse) Size() (n int)
- func (this *ValiSeriesResponse) String() string
- func (m *ValiSeriesResponse) Unmarshal(dAtA []byte) error
- func (m *ValiSeriesResponse) XXX_DiscardUnknown()
- func (m *ValiSeriesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ValiSeriesResponse) XXX_Merge(src proto.Message)
- func (m *ValiSeriesResponse) XXX_Size() int
- func (m *ValiSeriesResponse) XXX_Unmarshal(b []byte) error
Constants ¶
const ( QueryRangeOp = "query_range" SeriesOp = "series" LabelNamesOp = "labels" )
const (
DefaultDownstreamConcurrency = 32
)
Variables ¶
var ( ErrInvalidLengthQueryrange = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowQueryrange = fmt.Errorf("proto: integer overflow") )
var ( // StatsHTTPMiddleware is an http middleware to record stats for query_range filter. StatsHTTPMiddleware middleware.Interface = statsHTTPMiddleware(defaultMetricRecorder) )
Functions ¶
func NewLabelsTripperware ¶
func NewLabelsTripperware( cfg Config, log log.Logger, limits Limits, codec queryrange.Codec, instrumentMetrics *queryrange.InstrumentMiddlewareMetrics, retryMiddlewareMetrics *queryrange.RetryMiddlewareMetrics, splitByMetrics *SplitByMetrics, ) (queryrange.Tripperware, error)
NewLabelsTripperware creates a new frontend tripperware responsible for handling labels requests.
func NewLimitedRoundTripper ¶
func NewLimitedRoundTripper(next http.RoundTripper, codec queryrange.Codec, limits Limits, middlewares ...queryrange.Middleware) http.RoundTripper
NewLimitedRoundTripper creates a new roundtripper that enforces MaxQueryParallelism to the `next` roundtripper across `middlewares`.
func NewLogFilterTripperware ¶
func NewLogFilterTripperware( cfg Config, log log.Logger, limits Limits, schema chunk.SchemaConfig, minShardingLookback time.Duration, codec queryrange.Codec, instrumentMetrics *queryrange.InstrumentMiddlewareMetrics, retryMiddlewareMetrics *queryrange.RetryMiddlewareMetrics, shardingMetrics *logql.ShardingMetrics, splitByMetrics *SplitByMetrics, ) (queryrange.Tripperware, error)
NewLogFilterTripperware creates a new frontend tripperware responsible for handling log requests with regex.
func NewQueryShardMiddleware ¶
func NewQueryShardMiddleware( logger log.Logger, confs queryrange.ShardingConfigs, minShardingLookback time.Duration, middlewareMetrics *queryrange.InstrumentMiddlewareMetrics, shardingMetrics *logql.ShardingMetrics, limits logql.Limits, ) queryrange.Middleware
NewQueryShardMiddleware creates a middleware which downstreams queries after AST mapping and query encoding.
func NewSeriesTripperware ¶
func NewSeriesTripperware( cfg Config, log log.Logger, limits Limits, codec queryrange.Codec, instrumentMetrics *queryrange.InstrumentMiddlewareMetrics, retryMiddlewareMetrics *queryrange.RetryMiddlewareMetrics, splitByMetrics *SplitByMetrics, ) (queryrange.Tripperware, error)
NewSeriesripperware creates a new frontend tripperware responsible for handling series requests
func ResponseToResult ¶
func ResponseToResult(resp queryrange.Response) (logql.Result, error)
func SplitByIntervalMiddleware ¶
func SplitByIntervalMiddleware(limits Limits, merger queryrange.Merger, splitter Splitter, metrics *SplitByMetrics) queryrange.Middleware
SplitByIntervalMiddleware creates a new Middleware that splits log requests by a given interval.
func StatsCollectorMiddleware ¶
func StatsCollectorMiddleware() queryrange.Middleware
StatsCollectorMiddleware compute the stats summary based on the actual duration of the request and inject it in the request context.
Types ¶
type Config ¶
type Config struct {
queryrange.Config `yaml:",inline"`
}
Config is the configuration for the queryrange tripperware
func (*Config) RegisterFlags ¶
RegisterFlags adds the flags required to configure this flag set.
type DownstreamHandler ¶
type DownstreamHandler struct {
// contains filtered or unexported fields
}
func (DownstreamHandler) Downstreamer ¶
func (h DownstreamHandler) Downstreamer() logql.Downstreamer
type Limits ¶
type Limits interface { queryrange.Limits QuerySplitDuration(string) time.Duration MaxQuerySeries(string) int MaxEntriesLimitPerQuery(string) int }
Limits extends the cortex limits interface with support for per tenant splitby parameters
func WithDefaultLimits ¶
func WithDefaultLimits(l Limits, conf queryrange.Config) Limits
WithDefaults will construct a Limits with a default value for QuerySplitDuration when no overrides are present.
type PrometheusExtractor ¶
type PrometheusExtractor struct{}
PrometheusExtractor implements Extractor interface
func (PrometheusExtractor) Extract ¶
func (PrometheusExtractor) Extract(start, end int64, from queryrange.Response) queryrange.Response
Extract wraps the original prometheus cache extractor
func (PrometheusExtractor) ResponseWithoutHeaders ¶
func (PrometheusExtractor) ResponseWithoutHeaders(resp queryrange.Response) queryrange.Response
ResponseWithoutHeaders wraps the original prometheus caching without headers
type SplitByMetrics ¶
type SplitByMetrics struct {
// contains filtered or unexported fields
}
func NewSplitByMetrics ¶
func NewSplitByMetrics(r prometheus.Registerer) *SplitByMetrics
type Splitter ¶
type Splitter func(req queryrange.Request, interval time.Duration) []queryrange.Request
type Stopper ¶
type Stopper interface {
Stop()
}
Stopper gracefully shutdown resources created
func NewMetricTripperware ¶
func NewMetricTripperware( cfg Config, log log.Logger, limits Limits, schema chunk.SchemaConfig, minShardingLookback time.Duration, codec queryrange.Codec, extractor queryrange.Extractor, instrumentMetrics *queryrange.InstrumentMiddlewareMetrics, retryMiddlewareMetrics *queryrange.RetryMiddlewareMetrics, shardingMetrics *logql.ShardingMetrics, splitByMetrics *SplitByMetrics, registerer prometheus.Registerer, ) (queryrange.Tripperware, Stopper, error)
NewMetricTripperware creates a new frontend tripperware responsible for handling metric queries
func NewTripperware ¶
func NewTripperware( cfg Config, log log.Logger, limits Limits, schema chunk.SchemaConfig, minShardingLookback time.Duration, registerer prometheus.Registerer, ) (queryrange.Tripperware, Stopper, error)
NewTripperware returns a Tripperware configured with middlewares to align, split and cache requests.
type ValiData ¶
type ValiData struct { ResultType string `protobuf:"bytes,1,opt,name=ResultType,proto3" json:"resultType"` Result []github_com_credativ_vali_pkg_logproto.Stream `protobuf:"bytes,2,rep,name=Result,proto3,customtype=github.com/credativ/vali/pkg/logproto.Stream" json:"result"` }
func (*ValiData) Descriptor ¶
func (*ValiData) GetResultType ¶
func (*ValiData) ProtoMessage ¶
func (*ValiData) ProtoMessage()
func (*ValiData) XXX_DiscardUnknown ¶
func (m *ValiData) XXX_DiscardUnknown()
func (*ValiData) XXX_Marshal ¶
func (*ValiData) XXX_Unmarshal ¶
type ValiLabelNamesRequest ¶
type ValiLabelNamesRequest struct { StartTs time.Time `protobuf:"bytes,1,opt,name=startTs,proto3,stdtime" json:"startTs"` EndTs time.Time `protobuf:"bytes,2,opt,name=endTs,proto3,stdtime" json:"endTs"` Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"` }
func (*ValiLabelNamesRequest) Descriptor ¶
func (*ValiLabelNamesRequest) Descriptor() ([]byte, []int)
func (*ValiLabelNamesRequest) Equal ¶
func (this *ValiLabelNamesRequest) Equal(that interface{}) bool
func (*ValiLabelNamesRequest) GetCachingOptions ¶
func (*ValiLabelNamesRequest) GetCachingOptions() (res queryrange.CachingOptions)
func (*ValiLabelNamesRequest) GetEnd ¶
func (r *ValiLabelNamesRequest) GetEnd() int64
func (*ValiLabelNamesRequest) GetEndTs ¶
func (m *ValiLabelNamesRequest) GetEndTs() time.Time
func (*ValiLabelNamesRequest) GetPath ¶
func (m *ValiLabelNamesRequest) GetPath() string
func (*ValiLabelNamesRequest) GetQuery ¶
func (r *ValiLabelNamesRequest) GetQuery() string
func (*ValiLabelNamesRequest) GetStart ¶
func (r *ValiLabelNamesRequest) GetStart() int64
func (*ValiLabelNamesRequest) GetStartTs ¶
func (m *ValiLabelNamesRequest) GetStartTs() time.Time
func (*ValiLabelNamesRequest) GetStep ¶
func (r *ValiLabelNamesRequest) GetStep() int64
func (*ValiLabelNamesRequest) GoString ¶
func (this *ValiLabelNamesRequest) GoString() string
func (*ValiLabelNamesRequest) LogToSpan ¶
func (r *ValiLabelNamesRequest) LogToSpan(sp opentracing.Span)
func (*ValiLabelNamesRequest) Marshal ¶
func (m *ValiLabelNamesRequest) Marshal() (dAtA []byte, err error)
func (*ValiLabelNamesRequest) MarshalTo ¶
func (m *ValiLabelNamesRequest) MarshalTo(dAtA []byte) (int, error)
func (*ValiLabelNamesRequest) ProtoMessage ¶
func (*ValiLabelNamesRequest) ProtoMessage()
func (*ValiLabelNamesRequest) Reset ¶
func (m *ValiLabelNamesRequest) Reset()
func (*ValiLabelNamesRequest) Size ¶
func (m *ValiLabelNamesRequest) Size() (n int)
func (*ValiLabelNamesRequest) String ¶
func (this *ValiLabelNamesRequest) String() string
func (*ValiLabelNamesRequest) Unmarshal ¶
func (m *ValiLabelNamesRequest) Unmarshal(dAtA []byte) error
func (*ValiLabelNamesRequest) WithQuery ¶
func (r *ValiLabelNamesRequest) WithQuery(query string) queryrange.Request
func (*ValiLabelNamesRequest) WithStartEnd ¶
func (r *ValiLabelNamesRequest) WithStartEnd(s int64, e int64) queryrange.Request
func (*ValiLabelNamesRequest) XXX_DiscardUnknown ¶
func (m *ValiLabelNamesRequest) XXX_DiscardUnknown()
func (*ValiLabelNamesRequest) XXX_Marshal ¶
func (m *ValiLabelNamesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ValiLabelNamesRequest) XXX_Merge ¶
func (m *ValiLabelNamesRequest) XXX_Merge(src proto.Message)
func (*ValiLabelNamesRequest) XXX_Size ¶
func (m *ValiLabelNamesRequest) XXX_Size() int
func (*ValiLabelNamesRequest) XXX_Unmarshal ¶
func (m *ValiLabelNamesRequest) XXX_Unmarshal(b []byte) error
type ValiLabelNamesResponse ¶
type ValiLabelNamesResponse struct { Status string `protobuf:"bytes,1,opt,name=Status,proto3" json:"status"` Data []string `protobuf:"bytes,2,rep,name=Data,proto3" json:"data,omitempty"` Version uint32 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"` Headers []github_com_cortexproject_cortex_pkg_querier_queryrange.PrometheusResponseHeader `` /* 142-byte string literal not displayed */ }
func (*ValiLabelNamesResponse) Descriptor ¶
func (*ValiLabelNamesResponse) Descriptor() ([]byte, []int)
func (*ValiLabelNamesResponse) Equal ¶
func (this *ValiLabelNamesResponse) Equal(that interface{}) bool
func (*ValiLabelNamesResponse) GetData ¶
func (m *ValiLabelNamesResponse) GetData() []string
func (*ValiLabelNamesResponse) GetHeaders ¶
func (m *ValiLabelNamesResponse) GetHeaders() []*queryrange.PrometheusResponseHeader
func (*ValiLabelNamesResponse) GetStatus ¶
func (m *ValiLabelNamesResponse) GetStatus() string
func (*ValiLabelNamesResponse) GetVersion ¶
func (m *ValiLabelNamesResponse) GetVersion() uint32
func (*ValiLabelNamesResponse) GoString ¶
func (this *ValiLabelNamesResponse) GoString() string
func (*ValiLabelNamesResponse) Marshal ¶
func (m *ValiLabelNamesResponse) Marshal() (dAtA []byte, err error)
func (*ValiLabelNamesResponse) MarshalTo ¶
func (m *ValiLabelNamesResponse) MarshalTo(dAtA []byte) (int, error)
func (*ValiLabelNamesResponse) ProtoMessage ¶
func (*ValiLabelNamesResponse) ProtoMessage()
func (*ValiLabelNamesResponse) Reset ¶
func (m *ValiLabelNamesResponse) Reset()
func (*ValiLabelNamesResponse) Size ¶
func (m *ValiLabelNamesResponse) Size() (n int)
func (*ValiLabelNamesResponse) String ¶
func (this *ValiLabelNamesResponse) String() string
func (*ValiLabelNamesResponse) Unmarshal ¶
func (m *ValiLabelNamesResponse) Unmarshal(dAtA []byte) error
func (*ValiLabelNamesResponse) XXX_DiscardUnknown ¶
func (m *ValiLabelNamesResponse) XXX_DiscardUnknown()
func (*ValiLabelNamesResponse) XXX_Marshal ¶
func (m *ValiLabelNamesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ValiLabelNamesResponse) XXX_Merge ¶
func (m *ValiLabelNamesResponse) XXX_Merge(src proto.Message)
func (*ValiLabelNamesResponse) XXX_Size ¶
func (m *ValiLabelNamesResponse) XXX_Size() int
func (*ValiLabelNamesResponse) XXX_Unmarshal ¶
func (m *ValiLabelNamesResponse) XXX_Unmarshal(b []byte) error
type ValiPromResponse ¶
type ValiPromResponse struct { Response *queryrange.PrometheusResponse `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"` Statistics stats.Result `protobuf:"bytes,2,opt,name=statistics,proto3" json:"statistics"` }
ValiPromResponse wraps a Prometheus response with statistics.
func (*ValiPromResponse) Descriptor ¶
func (*ValiPromResponse) Descriptor() ([]byte, []int)
func (*ValiPromResponse) Equal ¶
func (this *ValiPromResponse) Equal(that interface{}) bool
func (*ValiPromResponse) GetHeaders ¶
func (m *ValiPromResponse) GetHeaders() []*queryrange.PrometheusResponseHeader
func (*ValiPromResponse) GetResponse ¶
func (m *ValiPromResponse) GetResponse() *queryrange.PrometheusResponse
func (*ValiPromResponse) GetStatistics ¶
func (m *ValiPromResponse) GetStatistics() stats.Result
func (*ValiPromResponse) GoString ¶
func (this *ValiPromResponse) GoString() string
func (*ValiPromResponse) Marshal ¶
func (m *ValiPromResponse) Marshal() (dAtA []byte, err error)
func (*ValiPromResponse) ProtoMessage ¶
func (*ValiPromResponse) ProtoMessage()
func (*ValiPromResponse) Reset ¶
func (m *ValiPromResponse) Reset()
func (*ValiPromResponse) Size ¶
func (m *ValiPromResponse) Size() (n int)
func (*ValiPromResponse) String ¶
func (this *ValiPromResponse) String() string
func (*ValiPromResponse) Unmarshal ¶
func (m *ValiPromResponse) Unmarshal(dAtA []byte) error
func (*ValiPromResponse) XXX_DiscardUnknown ¶
func (m *ValiPromResponse) XXX_DiscardUnknown()
func (*ValiPromResponse) XXX_Marshal ¶
func (m *ValiPromResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ValiPromResponse) XXX_Merge ¶
func (m *ValiPromResponse) XXX_Merge(src proto.Message)
func (*ValiPromResponse) XXX_Size ¶
func (m *ValiPromResponse) XXX_Size() int
func (*ValiPromResponse) XXX_Unmarshal ¶
func (m *ValiPromResponse) XXX_Unmarshal(b []byte) error
type ValiRequest ¶
type ValiRequest struct { Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` Step int64 `protobuf:"varint,3,opt,name=step,proto3" json:"step,omitempty"` StartTs time.Time `protobuf:"bytes,4,opt,name=startTs,proto3,stdtime" json:"startTs"` EndTs time.Time `protobuf:"bytes,5,opt,name=endTs,proto3,stdtime" json:"endTs"` Direction logproto.Direction `protobuf:"varint,6,opt,name=direction,proto3,enum=logproto.Direction" json:"direction,omitempty"` Path string `protobuf:"bytes,7,opt,name=path,proto3" json:"path,omitempty"` Shards []string `protobuf:"bytes,8,rep,name=shards,proto3" json:"shards"` }
func ParamsToValiRequest ¶
func ParamsToValiRequest(params logql.Params) *ValiRequest
func (*ValiRequest) Descriptor ¶
func (*ValiRequest) Descriptor() ([]byte, []int)
func (*ValiRequest) Equal ¶
func (this *ValiRequest) Equal(that interface{}) bool
func (*ValiRequest) GetCachingOptions ¶
func (*ValiRequest) GetCachingOptions() (res queryrange.CachingOptions)
func (*ValiRequest) GetDirection ¶
func (m *ValiRequest) GetDirection() logproto.Direction
func (*ValiRequest) GetEnd ¶
func (r *ValiRequest) GetEnd() int64
func (*ValiRequest) GetEndTs ¶
func (m *ValiRequest) GetEndTs() time.Time
func (*ValiRequest) GetLimit ¶
func (m *ValiRequest) GetLimit() uint32
func (*ValiRequest) GetPath ¶
func (m *ValiRequest) GetPath() string
func (*ValiRequest) GetQuery ¶
func (m *ValiRequest) GetQuery() string
func (*ValiRequest) GetShards ¶
func (m *ValiRequest) GetShards() []string
func (*ValiRequest) GetStart ¶
func (r *ValiRequest) GetStart() int64
func (*ValiRequest) GetStartTs ¶
func (m *ValiRequest) GetStartTs() time.Time
func (*ValiRequest) GetStep ¶
func (m *ValiRequest) GetStep() int64
func (*ValiRequest) GoString ¶
func (this *ValiRequest) GoString() string
func (*ValiRequest) LogToSpan ¶
func (r *ValiRequest) LogToSpan(sp opentracing.Span)
func (*ValiRequest) Marshal ¶
func (m *ValiRequest) Marshal() (dAtA []byte, err error)
func (*ValiRequest) ProtoMessage ¶
func (*ValiRequest) ProtoMessage()
func (*ValiRequest) Reset ¶
func (m *ValiRequest) Reset()
func (*ValiRequest) Size ¶
func (m *ValiRequest) Size() (n int)
func (*ValiRequest) String ¶
func (this *ValiRequest) String() string
func (*ValiRequest) Unmarshal ¶
func (m *ValiRequest) Unmarshal(dAtA []byte) error
func (*ValiRequest) WithQuery ¶
func (r *ValiRequest) WithQuery(query string) queryrange.Request
func (*ValiRequest) WithShards ¶
func (r *ValiRequest) WithShards(shards logql.Shards) *ValiRequest
func (*ValiRequest) WithStartEnd ¶
func (r *ValiRequest) WithStartEnd(s int64, e int64) queryrange.Request
func (*ValiRequest) XXX_DiscardUnknown ¶
func (m *ValiRequest) XXX_DiscardUnknown()
func (*ValiRequest) XXX_Marshal ¶
func (m *ValiRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ValiRequest) XXX_Merge ¶
func (m *ValiRequest) XXX_Merge(src proto.Message)
func (*ValiRequest) XXX_Size ¶
func (m *ValiRequest) XXX_Size() int
func (*ValiRequest) XXX_Unmarshal ¶
func (m *ValiRequest) XXX_Unmarshal(b []byte) error
type ValiResponse ¶
type ValiResponse struct { Status string `protobuf:"bytes,1,opt,name=Status,proto3" json:"status"` Data ValiData `protobuf:"bytes,2,opt,name=Data,proto3" json:"data,omitempty"` ErrorType string `protobuf:"bytes,3,opt,name=ErrorType,proto3" json:"errorType,omitempty"` Error string `protobuf:"bytes,4,opt,name=Error,proto3" json:"error,omitempty"` Direction logproto.Direction `protobuf:"varint,5,opt,name=direction,proto3,enum=logproto.Direction" json:"direction,omitempty"` Limit uint32 `protobuf:"varint,6,opt,name=limit,proto3" json:"limit,omitempty"` Version uint32 `protobuf:"varint,7,opt,name=version,proto3" json:"version,omitempty"` Statistics stats.Result `protobuf:"bytes,8,opt,name=statistics,proto3" json:"statistics"` Headers []github_com_cortexproject_cortex_pkg_querier_queryrange.PrometheusResponseHeader `` /* 142-byte string literal not displayed */ }
func (ValiResponse) Count ¶
func (res ValiResponse) Count() int64
func (*ValiResponse) Descriptor ¶
func (*ValiResponse) Descriptor() ([]byte, []int)
func (*ValiResponse) Equal ¶
func (this *ValiResponse) Equal(that interface{}) bool
func (*ValiResponse) GetData ¶
func (m *ValiResponse) GetData() ValiData
func (*ValiResponse) GetDirection ¶
func (m *ValiResponse) GetDirection() logproto.Direction
func (*ValiResponse) GetError ¶
func (m *ValiResponse) GetError() string
func (*ValiResponse) GetErrorType ¶
func (m *ValiResponse) GetErrorType() string
func (*ValiResponse) GetHeaders ¶
func (m *ValiResponse) GetHeaders() []*queryrange.PrometheusResponseHeader
func (*ValiResponse) GetLimit ¶
func (m *ValiResponse) GetLimit() uint32
func (*ValiResponse) GetStatistics ¶
func (m *ValiResponse) GetStatistics() stats.Result
func (*ValiResponse) GetStatus ¶
func (m *ValiResponse) GetStatus() string
func (*ValiResponse) GetVersion ¶
func (m *ValiResponse) GetVersion() uint32
func (*ValiResponse) GoString ¶
func (this *ValiResponse) GoString() string
func (*ValiResponse) Marshal ¶
func (m *ValiResponse) Marshal() (dAtA []byte, err error)
func (*ValiResponse) ProtoMessage ¶
func (*ValiResponse) ProtoMessage()
func (*ValiResponse) Reset ¶
func (m *ValiResponse) Reset()
func (*ValiResponse) Size ¶
func (m *ValiResponse) Size() (n int)
func (*ValiResponse) String ¶
func (this *ValiResponse) String() string
func (*ValiResponse) Unmarshal ¶
func (m *ValiResponse) Unmarshal(dAtA []byte) error
func (*ValiResponse) XXX_DiscardUnknown ¶
func (m *ValiResponse) XXX_DiscardUnknown()
func (*ValiResponse) XXX_Marshal ¶
func (m *ValiResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ValiResponse) XXX_Merge ¶
func (m *ValiResponse) XXX_Merge(src proto.Message)
func (*ValiResponse) XXX_Size ¶
func (m *ValiResponse) XXX_Size() int
func (*ValiResponse) XXX_Unmarshal ¶
func (m *ValiResponse) XXX_Unmarshal(b []byte) error
type ValiSeriesRequest ¶
type ValiSeriesRequest struct { Match []string `protobuf:"bytes,1,rep,name=match,proto3" json:"match,omitempty"` StartTs time.Time `protobuf:"bytes,2,opt,name=startTs,proto3,stdtime" json:"startTs"` EndTs time.Time `protobuf:"bytes,3,opt,name=endTs,proto3,stdtime" json:"endTs"` Path string `protobuf:"bytes,4,opt,name=path,proto3" json:"path,omitempty"` }
func (*ValiSeriesRequest) Descriptor ¶
func (*ValiSeriesRequest) Descriptor() ([]byte, []int)
func (*ValiSeriesRequest) Equal ¶
func (this *ValiSeriesRequest) Equal(that interface{}) bool
func (*ValiSeriesRequest) GetCachingOptions ¶
func (*ValiSeriesRequest) GetCachingOptions() (res queryrange.CachingOptions)
func (*ValiSeriesRequest) GetEnd ¶
func (r *ValiSeriesRequest) GetEnd() int64
func (*ValiSeriesRequest) GetEndTs ¶
func (m *ValiSeriesRequest) GetEndTs() time.Time
func (*ValiSeriesRequest) GetMatch ¶
func (m *ValiSeriesRequest) GetMatch() []string
func (*ValiSeriesRequest) GetPath ¶
func (m *ValiSeriesRequest) GetPath() string
func (*ValiSeriesRequest) GetQuery ¶
func (r *ValiSeriesRequest) GetQuery() string
func (*ValiSeriesRequest) GetStart ¶
func (r *ValiSeriesRequest) GetStart() int64
func (*ValiSeriesRequest) GetStartTs ¶
func (m *ValiSeriesRequest) GetStartTs() time.Time
func (*ValiSeriesRequest) GetStep ¶
func (r *ValiSeriesRequest) GetStep() int64
func (*ValiSeriesRequest) GoString ¶
func (this *ValiSeriesRequest) GoString() string
func (*ValiSeriesRequest) LogToSpan ¶
func (r *ValiSeriesRequest) LogToSpan(sp opentracing.Span)
func (*ValiSeriesRequest) Marshal ¶
func (m *ValiSeriesRequest) Marshal() (dAtA []byte, err error)
func (*ValiSeriesRequest) MarshalTo ¶
func (m *ValiSeriesRequest) MarshalTo(dAtA []byte) (int, error)
func (*ValiSeriesRequest) ProtoMessage ¶
func (*ValiSeriesRequest) ProtoMessage()
func (*ValiSeriesRequest) Reset ¶
func (m *ValiSeriesRequest) Reset()
func (*ValiSeriesRequest) Size ¶
func (m *ValiSeriesRequest) Size() (n int)
func (*ValiSeriesRequest) String ¶
func (this *ValiSeriesRequest) String() string
func (*ValiSeriesRequest) Unmarshal ¶
func (m *ValiSeriesRequest) Unmarshal(dAtA []byte) error
func (*ValiSeriesRequest) WithQuery ¶
func (r *ValiSeriesRequest) WithQuery(query string) queryrange.Request
func (*ValiSeriesRequest) WithStartEnd ¶
func (r *ValiSeriesRequest) WithStartEnd(s int64, e int64) queryrange.Request
func (*ValiSeriesRequest) XXX_DiscardUnknown ¶
func (m *ValiSeriesRequest) XXX_DiscardUnknown()
func (*ValiSeriesRequest) XXX_Marshal ¶
func (m *ValiSeriesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ValiSeriesRequest) XXX_Merge ¶
func (m *ValiSeriesRequest) XXX_Merge(src proto.Message)
func (*ValiSeriesRequest) XXX_Size ¶
func (m *ValiSeriesRequest) XXX_Size() int
func (*ValiSeriesRequest) XXX_Unmarshal ¶
func (m *ValiSeriesRequest) XXX_Unmarshal(b []byte) error
type ValiSeriesResponse ¶
type ValiSeriesResponse struct { Status string `protobuf:"bytes,1,opt,name=Status,proto3" json:"status"` Data []logproto.SeriesIdentifier `protobuf:"bytes,2,rep,name=Data,proto3" json:"data,omitempty"` Version uint32 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"` Headers []github_com_cortexproject_cortex_pkg_querier_queryrange.PrometheusResponseHeader `` /* 142-byte string literal not displayed */ }
func (*ValiSeriesResponse) Descriptor ¶
func (*ValiSeriesResponse) Descriptor() ([]byte, []int)
func (*ValiSeriesResponse) Equal ¶
func (this *ValiSeriesResponse) Equal(that interface{}) bool
func (*ValiSeriesResponse) GetData ¶
func (m *ValiSeriesResponse) GetData() []logproto.SeriesIdentifier
func (*ValiSeriesResponse) GetHeaders ¶
func (m *ValiSeriesResponse) GetHeaders() []*queryrange.PrometheusResponseHeader
func (*ValiSeriesResponse) GetStatus ¶
func (m *ValiSeriesResponse) GetStatus() string
func (*ValiSeriesResponse) GetVersion ¶
func (m *ValiSeriesResponse) GetVersion() uint32
func (*ValiSeriesResponse) GoString ¶
func (this *ValiSeriesResponse) GoString() string
func (*ValiSeriesResponse) Marshal ¶
func (m *ValiSeriesResponse) Marshal() (dAtA []byte, err error)
func (*ValiSeriesResponse) MarshalTo ¶
func (m *ValiSeriesResponse) MarshalTo(dAtA []byte) (int, error)
func (*ValiSeriesResponse) ProtoMessage ¶
func (*ValiSeriesResponse) ProtoMessage()
func (*ValiSeriesResponse) Reset ¶
func (m *ValiSeriesResponse) Reset()
func (*ValiSeriesResponse) Size ¶
func (m *ValiSeriesResponse) Size() (n int)
func (*ValiSeriesResponse) String ¶
func (this *ValiSeriesResponse) String() string
func (*ValiSeriesResponse) Unmarshal ¶
func (m *ValiSeriesResponse) Unmarshal(dAtA []byte) error
func (*ValiSeriesResponse) XXX_DiscardUnknown ¶
func (m *ValiSeriesResponse) XXX_DiscardUnknown()
func (*ValiSeriesResponse) XXX_Marshal ¶
func (m *ValiSeriesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ValiSeriesResponse) XXX_Merge ¶
func (m *ValiSeriesResponse) XXX_Merge(src proto.Message)
func (*ValiSeriesResponse) XXX_Size ¶
func (m *ValiSeriesResponse) XXX_Size() int
func (*ValiSeriesResponse) XXX_Unmarshal ¶
func (m *ValiSeriesResponse) XXX_Unmarshal(b []byte) error