evql

Documentation

Index

• func AggregateData(s evdb.DataPoints, agg Aggregator) float64
• func MergeData(m Merger, s, v evdb.DataPoints) error
• type Aggregator
  • func BlankAggregator(agg Aggregator) Aggregator
  • func NewAggregator(name string) Aggregator
• type Execer
  • func NewExecer(scanner db.Scanner) Execer
• type Merger
  • func NewMerger(op token.Token) Merger
• type Query
  • func Parse(query string) (*Query, error)
  • func (q *Query) Eval(out []interface{}, t db.TimeRange, results db.Results) []interface{}
  • func (q *Query) Queries(t db.TimeRange) []db.ScanQuery

Functions

func AggregateData

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

func MergeData

func MergeData(m Merger, s, v evdb.DataPoints) error

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) ([]interface{}, error)
}

Execer executes evql queries

func NewExecer

func NewExecer(scanner db.Scanner) Execer

NewExecer turns a Scanner to an Execer

type Merger

type Merger interface {
	Merge(a, b float64) float64
}

Merger provides a method to merge values

func NewMerger

func NewMerger(op token.Token) Merger

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 []interface{}, t db.TimeRange, results db.Results) []interface{}

Eval executes the query against some results

func (*Query) Queries

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