promql

Oct 6, 2017

retracted

Changes in this version

type Function

+ Variadic int

Nov 1, 2016

retracted

Changes in this version

+ type Queryable interface

+ Querier func() (local.Querier, error)

Jul 18, 2016

retracted

Changes in this version

+ const LowestPrec

+ var DefaultEngineOptions = &EngineOptions

+ var StalenessDelta = 5 * time.Minute

+ func Inspect(node Node, f func(Node) bool)

+ func ParseMetric(input string) (m model.Metric, err error)

+ func ParseMetricSelector(input string) (m metric.LabelMatchers, err error)

+ func Tree(node Node) string

+ func Walk(v Visitor, node Node)

+ type AggregateExpr struct

+ Expr Expr

+ Grouping model.LabelNames

+ KeepCommonLabels bool

+ Op itemType

+ Param Expr

+ Without bool

+ func (e *AggregateExpr) Type() model.ValueType

+ func (node *AggregateExpr) String() string

+ type AlertStmt struct

+ Annotations model.LabelSet

+ Duration time.Duration

+ Expr Expr

+ Labels model.LabelSet

+ Name string

+ func (node *AlertStmt) String() string

+ type Analyzer struct

+ End model.Time

+ Expr Expr

+ Start model.Time

+ Storage local.Querier

+ func (a *Analyzer) Analyze(ctx context.Context) error

+ func (a *Analyzer) Prepare(ctx context.Context) (local.Preloader, error)

+ type Benchmark struct

+ func NewBenchmark(b *testing.B, input string) *Benchmark

+ func (b *Benchmark) Run()

+ type BinaryExpr struct

+ LHS Expr

+ Op itemType

+ RHS Expr

+ ReturnBool bool

+ VectorMatching *VectorMatching

+ func (e *BinaryExpr) Type() model.ValueType

+ func (node *BinaryExpr) String() string

+ type Call struct

+ Args Expressions

+ Func *Function

+ func (e *Call) Type() model.ValueType

+ func (node *Call) String() string

type Engine

+ func (ng *Engine) Stop()

+ type EngineOptions struct

+ MaxConcurrentQueries int

+ Timeout time.Duration

+ type EvalStmt struct

+ End model.Time

+ Expr Expr

+ Interval time.Duration

+ Start model.Time

+ func (node *EvalStmt) String() string

+ type Expr interface

+ Type func() model.ValueType

+ func ParseExpr(input string) (Expr, error)

+ type Expressions []Expr

+ func (es Expressions) String() (s string)

+ type Function struct

+ ArgTypes []model.ValueType

+ Call func(ev *evaluator, args Expressions) model.Value

+ Name string

+ OptionalArgs int

+ ReturnType model.ValueType

+ type MatrixSelector struct

+ LabelMatchers metric.LabelMatchers

+ Name string

+ Offset time.Duration

+ Range time.Duration

+ func (e *MatrixSelector) Type() model.ValueType

+ func (node *MatrixSelector) String() string

+ type Node interface

+ String func() string

+ type NumberLiteral struct

+ Val model.SampleValue

+ func (e *NumberLiteral) Type() model.ValueType

+ func (node *NumberLiteral) String() string

+ type ParenExpr struct

+ Expr Expr

+ func (e *ParenExpr) Type() model.ValueType

+ func (node *ParenExpr) String() string

+ type ParseErr struct

+ Err error

+ Line int

+ Pos int

+ func (e *ParseErr) Error() string

+ type Pos int

+ type RecordStmt struct

+ Expr Expr

+ Labels model.LabelSet

+ Name string

+ func (node *RecordStmt) String() string

+ type Statement interface

+ type Statements []Statement

+ func ParseStmts(input string) (Statements, error)

+ func (stmts Statements) String() (s string)

+ type StringLiteral struct

+ Val string

+ func (e *StringLiteral) Type() model.ValueType

+ func (node *StringLiteral) String() string

type Test

+ func (t *Test) RunAsBenchmark(b *Benchmark) error

+ type UnaryExpr struct

+ Expr Expr

+ Op itemType

+ func (e *UnaryExpr) Type() model.ValueType

+ func (node *UnaryExpr) String() string

+ type VectorMatchCardinality int

+ const CardManyToMany

+ const CardManyToOne

+ const CardOneToMany

+ const CardOneToOne

+ func (vmc VectorMatchCardinality) String() string

+ type VectorMatching struct

+ Card VectorMatchCardinality

+ Include model.LabelNames

+ MatchingLabels model.LabelNames

+ On bool

+ type VectorSelector struct

+ LabelMatchers metric.LabelMatchers

+ Name string

+ Offset time.Duration

+ func (e *VectorSelector) Type() model.ValueType

+ func (node *VectorSelector) String() string

+ type Visitor interface

+ Visit func(node Node) (w Visitor)

Jan 15, 2024

Changes in this version

+ func FindMinMaxTime(s *parser.EvalStmt) (int64, int64)

type Vector

+ func (vec Vector) TotalSamples() int

Sep 6, 2023

Changes in this version

+ func HistogramTestExpression(h *histogram.FloatHistogram) string

+ func LoadedStorage(t testutil.T, input string) *teststorage.TestStorage

+ func RunBuiltinTests(t *testing.T, engine engineQuerier)

+ func RunTest(t testutil.T, input string, engine engineQuerier)

Jul 25, 2023

Changes in this version

type ActiveQueryTracker

+ func (tracker *ActiveQueryTracker) Close()

+ type PrometheusQueryOpts struct

+ func (p *PrometheusQueryOpts) EnablePerStepStats() bool

+ func (p *PrometheusQueryOpts) LookbackDelta() time.Duration

type QueryOpts

+ func NewPrometheusQueryOpts(enablePerStepStats bool, lookbackDelta time.Duration) QueryOpts

May 14, 2023

Changes in this version

+ type FPoint struct

+ F float64

+ T int64

+ func (p FPoint) MarshalJSON() ([]byte, error)

+ func (p FPoint) String() string

+ type HPoint struct

+ H *histogram.FloatHistogram

+ T int64

+ func (p HPoint) MarshalJSON() ([]byte, error)

+ func (p HPoint) String() string

type Sample

+ F float64

+ H *histogram.FloatHistogram

+ T int64

type Series

+ Floats []FPoint

+ Histograms []HPoint

Nov 7, 2022

Changes in this version

type Point

+ H *histogram.FloatHistogram

type Series

+ func (s Series) MarshalJSON() ([]byte, error)

Aug 16, 2022

Changes in this version

type QueryOpts

+ LookbackDelta time.Duration

Apr 21, 2022

Changes in this version

+ var AtModifierUnsafeFunctions = map[string]struct

+ var ErrValidationAtModifierDisabled = errors.New("@ modifier is disabled")

+ var ErrValidationNegativeOffsetDisabled = errors.New("negative offset is disabled")

+ var FunctionCalls = map[string]FunctionCall

+ func NewOriginContext(ctx context.Context, data map[string]interface{}) context.Context

+ func PreprocessExpr(expr parser.Expr, start, end time.Time) parser.Expr

+ type ActiveQueryTracker struct

+ func NewActiveQueryTracker(localStoragePath string, maxConcurrent int, logger log.Logger) *ActiveQueryTracker

+ func (tracker ActiveQueryTracker) Delete(insertIndex int)

+ func (tracker ActiveQueryTracker) GetMaxConcurrent() int

+ func (tracker ActiveQueryTracker) Insert(ctx context.Context, query string) (int, error)

+ type Engine struct

+ func NewEngine(opts EngineOpts) *Engine

+ func (ng *Engine) NewInstantQuery(q storage.Queryable, opts *QueryOpts, qs string, ts time.Time) (Query, error)

+ func (ng *Engine) NewRangeQuery(q storage.Queryable, opts *QueryOpts, qs string, start, end time.Time, ...) (Query, error)

+ func (ng *Engine) SetQueryLogger(l QueryLogger)

+ type EngineOpts struct

+ ActiveQueryTracker QueryTracker

+ EnableAtModifier bool

+ EnableNegativeOffset bool

+ EnablePerStepStats bool

+ Logger log.Logger

+ LookbackDelta time.Duration

+ MaxSamples int

+ NoStepSubqueryIntervalFn func(rangeMillis int64) int64

+ Reg prometheus.Registerer

+ Timeout time.Duration

+ type Entry struct

+ Query string

+ Timestamp int64

+ type ErrQueryCanceled string

+ func (e ErrQueryCanceled) Error() string

+ type ErrQueryTimeout string

+ func (e ErrQueryTimeout) Error() string

+ type ErrStorage struct

+ Err error

+ func (e ErrStorage) Error() string

+ type ErrTooManySamples string

+ func (e ErrTooManySamples) Error() string

+ type EvalNodeHelper struct

+ Dmn map[uint64]labels.Labels

+ Out Vector

+ Ts int64

+ func (enh *EvalNodeHelper) DropMetricName(l labels.Labels) labels.Labels

+ type EvalSeriesHelper struct

+ type FunctionCall func(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector

+ type LazyLoader struct

+ SubqueryInterval time.Duration

+ func NewLazyLoader(t testutil.T, input string, opts LazyLoaderOpts) (*LazyLoader, error)

+ func (ll *LazyLoader) Close()

+ func (ll *LazyLoader) Context() context.Context

+ func (ll *LazyLoader) QueryEngine() *Engine

+ func (ll *LazyLoader) Queryable() storage.Queryable

+ func (ll *LazyLoader) Storage() storage.Storage

+ func (ll *LazyLoader) WithSamplesTill(ts time.Time, fn func(error))

+ type LazyLoaderOpts struct

+ EnableAtModifier bool

+ EnableNegativeOffset bool

+ type Matrix []Series

+ func (Matrix) Type() parser.ValueType

+ func (m Matrix) ContainsSameLabelset() bool

+ func (m Matrix) Len() int

+ func (m Matrix) Less(i, j int) bool

+ func (m Matrix) String() string

+ func (m Matrix) Swap(i, j int)

+ func (m Matrix) TotalSamples() int

+ type Point struct

+ T int64

+ V float64

+ func (p Point) MarshalJSON() ([]byte, error)

+ func (p Point) String() string

+ type Query interface

+ Cancel func()

+ Close func()

+ Exec func(ctx context.Context) *Result

+ Statement func() parser.Statement

+ Stats func() *stats.Statistics

+ String func() string

+ type QueryLogger interface

+ Close func() error

+ Log func(...interface{}) error

+ type QueryOpts struct

+ EnablePerStepStats bool

+ type QueryOrigin struct

+ type QueryTracker interface

+ Delete func(insertIndex int)

+ GetMaxConcurrent func() int

+ Insert func(ctx context.Context, query string) (int, error)

+ type Result struct

+ Err error

+ Value parser.Value

+ Warnings storage.Warnings

+ func (r *Result) Matrix() (Matrix, error)

+ func (r *Result) Scalar() (Scalar, error)

+ func (r *Result) String() string

+ func (r *Result) Vector() (Vector, error)

+ type Sample struct

+ Metric labels.Labels

+ func (s Sample) MarshalJSON() ([]byte, error)

+ func (s Sample) String() string

+ type Scalar struct

+ T int64

+ V float64

+ func (Scalar) Type() parser.ValueType

+ func (s Scalar) MarshalJSON() ([]byte, error)

+ func (s Scalar) String() string

+ type Series struct

+ Metric labels.Labels

+ Points []Point

+ func (s Series) String() string

+ type StorageSeries struct

+ func NewStorageSeries(series Series) *StorageSeries

+ func (ss *StorageSeries) Iterator() chunkenc.Iterator

+ func (ss *StorageSeries) Labels() labels.Labels

+ type String struct

+ T int64

+ V string

+ func (String) Type() parser.ValueType

+ func (s String) MarshalJSON() ([]byte, error)

+ func (s String) String() string

+ type Test struct

+ func NewTest(t testutil.T, input string) (*Test, error)

+ func (t *Test) Close()

+ func (t *Test) Context() context.Context

+ func (t *Test) ExemplarQueryable() storage.ExemplarQueryable

+ func (t *Test) ExemplarStorage() storage.ExemplarStorage

+ func (t *Test) QueryEngine() *Engine

+ func (t *Test) Queryable() storage.Queryable

+ func (t *Test) Run() error

+ func (t *Test) Storage() storage.Storage

+ func (t *Test) TSDB() *tsdb.DB

+ type Vector []Sample

+ func (Vector) Type() parser.ValueType

+ func (vec Vector) ContainsSameLabelset() bool

+ func (vec Vector) String() string