engine

package
v0.0.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 1, 2013 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source
const ALL_GROUP_IDENTIFIER = 1

Variables

This section is empty.

Functions

func SortInt64

func SortInt64(ints []int64)

Types

type Aggregator

type Aggregator interface {
	AggregatePoint(series string, group interface{}, p *protocol.Point) error
	InitializeFieldsMetadata(series *protocol.Series) error
	GetValue(series string, group interface{}) []*protocol.FieldValue
	ColumnName() string
}

func NewCountAggregator

func NewCountAggregator(_ *parser.Query, v *parser.Value) (Aggregator, error)

func NewCumulativeArithmeticAggregator

func NewCumulativeArithmeticAggregator(name string, value *parser.Value, initialValue float64, operation Operation) (Aggregator, error)

func NewDistinctAggregator

func NewDistinctAggregator(_ *parser.Query, value *parser.Value) (Aggregator, error)

func NewMaxAggregator

func NewMaxAggregator(_ *parser.Query, value *parser.Value) (Aggregator, error)

func NewMeanAggregator

func NewMeanAggregator(_ *parser.Query, value *parser.Value) (Aggregator, error)

func NewMedianAggregator

func NewMedianAggregator(_ *parser.Query, value *parser.Value) (Aggregator, error)

func NewMinAggregator

func NewMinAggregator(_ *parser.Query, value *parser.Value) (Aggregator, error)

func NewModeAggregator

func NewModeAggregator(_ *parser.Query, value *parser.Value) (Aggregator, error)

func NewPercentileAggregator

func NewPercentileAggregator(_ *parser.Query, value *parser.Value) (Aggregator, error)

func NewSumAggregator

func NewSumAggregator(_ *parser.Query, value *parser.Value) (Aggregator, error)

func NewTimestampAggregator

func NewTimestampAggregator(query *parser.Query, _ *parser.Value) (Aggregator, error)

type AggregatorInitializer

type AggregatorInitializer func(*parser.Query, *parser.Value) (Aggregator, error)

type CountAggregator

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

func (*CountAggregator) AggregatePoint

func (self *CountAggregator) AggregatePoint(series string, group interface{}, p *protocol.Point) error

func (*CountAggregator) ColumnName

func (self *CountAggregator) ColumnName() string

func (*CountAggregator) GetValue

func (self *CountAggregator) GetValue(series string, group interface{}) []*protocol.FieldValue

func (*CountAggregator) InitializeFieldsMetadata

func (self *CountAggregator) InitializeFieldsMetadata(series *protocol.Series) error

type CumulativeArithmeticAggregator

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

func (*CumulativeArithmeticAggregator) AggregatePoint

func (self *CumulativeArithmeticAggregator) AggregatePoint(series string, group interface{}, p *protocol.Point) error

func (*CumulativeArithmeticAggregator) ColumnName

func (self *CumulativeArithmeticAggregator) ColumnName() string

func (*CumulativeArithmeticAggregator) GetValue

func (self *CumulativeArithmeticAggregator) GetValue(series string, group interface{}) []*protocol.FieldValue

func (*CumulativeArithmeticAggregator) InitializeFieldsMetadata

func (self *CumulativeArithmeticAggregator) InitializeFieldsMetadata(series *protocol.Series) error

type DistinctAggregator

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

func (*DistinctAggregator) AggregatePoint

func (self *DistinctAggregator) AggregatePoint(series string, group interface{}, p *protocol.Point) error

func (*DistinctAggregator) ColumnName

func (self *DistinctAggregator) ColumnName() string

func (*DistinctAggregator) GetValue

func (self *DistinctAggregator) GetValue(series string, group interface{}) []*protocol.FieldValue

func (*DistinctAggregator) InitializeFieldsMetadata

func (self *DistinctAggregator) InitializeFieldsMetadata(series *protocol.Series) error

type EngineI

type EngineI interface {
	RunQuery(user common.User, database string, query string, yield func(*protocol.Series) error) error
}

func NewQueryEngine

func NewQueryEngine(c coordinator.Coordinator) (EngineI, error)

type Int64Slice

type Int64Slice []int64

Int64Slice attaches the methods of sort.Interface to []int64, sorting in increasing order.

func (Int64Slice) Len

func (p Int64Slice) Len() int

func (Int64Slice) Less

func (p Int64Slice) Less(i, j int) bool

func (Int64Slice) Swap

func (p Int64Slice) Swap(i, j int)

type InverseMapper

type InverseMapper func(interface{}, int) interface{}

type Mapper

type Mapper func(*protocol.Point) interface{}

type MeanAggregator

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

func (*MeanAggregator) AggregatePoint

func (self *MeanAggregator) AggregatePoint(series string, group interface{}, p *protocol.Point) error

func (*MeanAggregator) ColumnName

func (self *MeanAggregator) ColumnName() string

func (*MeanAggregator) GetValue

func (self *MeanAggregator) GetValue(series string, group interface{}) []*protocol.FieldValue

func (*MeanAggregator) InitializeFieldsMetadata

func (self *MeanAggregator) InitializeFieldsMetadata(series *protocol.Series) error

type ModeAggregator

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

func (*ModeAggregator) AggregatePoint

func (self *ModeAggregator) AggregatePoint(series string, group interface{}, p *protocol.Point) error

func (*ModeAggregator) ColumnName

func (self *ModeAggregator) ColumnName() string

func (*ModeAggregator) GetValue

func (self *ModeAggregator) GetValue(series string, group interface{}) []*protocol.FieldValue

func (*ModeAggregator) InitializeFieldsMetadata

func (self *ModeAggregator) InitializeFieldsMetadata(series *protocol.Series) error

type Operation

type Operation func(currentValue float64, newValue *protocol.FieldValue) float64

type PercentileAggregator

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

func (*PercentileAggregator) AggregatePoint

func (self *PercentileAggregator) AggregatePoint(series string, group interface{}, p *protocol.Point) error

func (*PercentileAggregator) ColumnName

func (self *PercentileAggregator) ColumnName() string

func (*PercentileAggregator) GetValue

func (self *PercentileAggregator) GetValue(series string, group interface{}) []*protocol.FieldValue

func (*PercentileAggregator) InitializeFieldsMetadata

func (self *PercentileAggregator) InitializeFieldsMetadata(series *protocol.Series) error

type PointSlice

type PointSlice []protocol.Point

type QueryEngine

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

func (*QueryEngine) RunQuery

func (self *QueryEngine) RunQuery(user common.User, database string, query string, yield func(*protocol.Series) error) (err error)

type TimestampAggregator

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

func (*TimestampAggregator) AggregatePoint

func (self *TimestampAggregator) AggregatePoint(series string, group interface{}, p *protocol.Point) error

func (*TimestampAggregator) ColumnName

func (self *TimestampAggregator) ColumnName() string

func (*TimestampAggregator) GetValue

func (self *TimestampAggregator) GetValue(series string, group interface{}) []*protocol.FieldValue

func (*TimestampAggregator) InitializeFieldsMetadata

func (self *TimestampAggregator) InitializeFieldsMetadata(series *protocol.Series) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL