evql

Documentation

Index

• func AggregateData(s evdb.DataPoints, agg Aggregator) float64
• type Aggregator
  • func BlankAggregator(agg Aggregator) Aggregator
  • func NewAggregator(name string) Aggregator
• type Execer
  • func NewExecer(scanner db.Scanner) Execer
• type Query
  • func Parse(query string) (*Query, error)
  • func (q *Query) Eval(out []db.Results, t db.TimeRange, results db.Results) []db.Results
  • func (q *Query) Queries(t db.TimeRange) []db.ScanQuery

Functions

func AggregateData

func AggregateData(s evdb.DataPoints, agg Aggregator) float64

Types

type Aggregator

type Aggregator interface {
	Aggregate(acc, v float64) float64
	Reset()
	Zero() float64
}

Aggregator aggregates values

func BlankAggregator

func BlankAggregator(agg Aggregator) Aggregator

BlankAggregator returns a separate Aggregator instance

func NewAggregator

func NewAggregator(name string) Aggregator

NewAggregator creates a new Aggregator

type Execer

type Execer interface {
	Exec(ctx context.Context, t db.TimeRange, q string) ([]db.Results, error)
}

Execer executes evql queries

func NewExecer

func NewExecer(scanner db.Scanner) Execer

NewExecer turns a Scanner to an Execer

type Query

type Query struct {
	// contains filtered or unexported fields
}

func Parse

func Parse(query string) (*Query, error)

func (*Query) Eval

func (q *Query) Eval(out []db.Results, t db.TimeRange, results db.Results) []db.Results

Eval executes the query against some results

func (*Query) Queries

func (q *Query) Queries(t db.TimeRange) []db.ScanQuery