Versions in this module Expand all Collapse all v1 v1.0.1 Nov 19, 2019 Changes in this version + const AVG + const BOTTOMK + const BY + const CLOSE_BRACKET + const CLOSE_PARENTHESIS + const COUNT + const COUNT_OVER_TIME + const DURATION + const MAX + const MIN + const OPEN_BRACKET + const OPEN_PARENTHESIS + const OpTypeAvg + const OpTypeBottomK + const OpTypeCount + const OpTypeCountOverTime + const OpTypeMax + const OpTypeMin + const OpTypeRate + const OpTypeStddev + const OpTypeStdvar + const OpTypeSum + const OpTypeTopK + const RATE + const STDDEV + const STDVAR + const SUM + const TOPK + const ValueTypeStreams + const WITHOUT + type Engine struct + func NewEngine(opts EngineOpts) *Engine + func (ng *Engine) NewInstantQuery(q Querier, qs string, ts time.Time, direction logproto.Direction, limit uint32) Query + func (ng *Engine) NewRangeQuery(q Querier, qs string, start, end time.Time, step time.Duration, ...) Query + type EngineOpts struct + MaxLookBackPeriod time.Duration + Timeout time.Duration + type Filter func(line []byte) bool + type LogSelectorExpr interface + Filter func() (Filter, error) + Matchers func() []*labels.Matcher + func ParseLogSelector(input string) (LogSelectorExpr, error) type Querier + Select func(context.Context, SelectParams) (iter.EntryIterator, error) type QuerierFunc + func (q QuerierFunc) Select(ctx context.Context, p SelectParams) (iter.EntryIterator, error) + type Query interface + Exec func(ctx context.Context) (promql.Value, error) + type RangeVectorAggregator func(int64, []promql.Point) float64 + type RangeVectorIterator interface + At func(aggregator RangeVectorAggregator) (int64, promql.Vector) + Close func() error + Next func() bool + type SampleExpr interface + Close func() error + Evaluator func() StepEvaluator + Selector func() LogSelectorExpr + type SelectParams struct + func (s SelectParams) LogSelector() (LogSelectorExpr, error) + type StepEvaluator interface + Next func() (bool, int64, promql.Vector) + type StepEvaluatorFn func() (bool, int64, promql.Vector) + func (s StepEvaluatorFn) Next() (bool, int64, promql.Vector) + type Streams []*logproto.Stream + func (Streams) String() string + func (Streams) Type() promql.ValueType v0 v0.1.0 Jun 3, 2019 Changes in this version + const CLOSE_BRACE + const COMMA + const DOT + const EQ + const IDENTIFIER + const LABELS + const MATCHERS + const NEQ + const NRE + const OPEN_BRACE + const PIPE_EXACT + const PIPE_MATCH + const RE + const STRING + func ParseMatchers(input string) ([]*labels.Matcher, error) + type Expr interface + Eval func(Querier) (iter.EntryIterator, error) + func NewFilterExpr(left Expr, ty labels.MatchType, match string) Expr + func ParseExpr(input string) (Expr, error) + type ParseError struct + func (p ParseError) Error() string + type Querier interface + Query func([]*labels.Matcher) (iter.EntryIterator, error) + type QuerierFunc func([]*labels.Matcher) (iter.EntryIterator, error) + func (q QuerierFunc) Query(ms []*labels.Matcher) (iter.EntryIterator, error)
Go to main page