engine

Jan 17, 2014

Changes in this version

+ type AscendingAggregatorSortableGroups struct

+ func (self *AscendingAggregatorSortableGroups) Less(i, j int) bool

+ type AscendingGroupTimestampSortableGroups struct

+ func (self *AscendingGroupTimestampSortableGroups) Less(i, j int) bool

+ type CommonSortableGroups struct

+ func (self *CommonSortableGroups) GetSortedGroups() []Group

+ func (self *CommonSortableGroups) Len() int

+ func (self *CommonSortableGroups) Swap(i, j int)

+ type DescendingAggregatorSortableGroups struct

+ func (self *DescendingAggregatorSortableGroups) Less(i, j int) bool

+ type DescendingGroupTimestampSortableGroups struct

+ func (self *DescendingGroupTimestampSortableGroups) Less(i, j int) bool

+ type Group interface

+ GetTimestamp func() int64

+ GetValue func(int) interface{}

+ HasTimestamp func() bool

+ WithTimestamp func(int64) Group

+ WithoutTimestamp func() Group

+ type Group0 struct

+ func (self Group0) GetTimestamp() int64

+ func (self Group0) GetValue(idx int) interface{}

+ func (self Group0) HasTimestamp() bool

+ func (self Group0) WithTimestamp(timestamp int64) Group

+ func (self Group0) WithoutTimestamp() Group

+ type Group1 struct

+ func (self Group1) GetTimestamp() int64

+ func (self Group1) GetValue(idx int) interface{}

+ func (self Group1) HasTimestamp() bool

+ func (self Group1) WithTimestamp(timestamp int64) Group

+ func (self Group1) WithoutTimestamp() Group

+ type Group2 struct

+ func (self Group2) GetTimestamp() int64

+ func (self Group2) GetValue(idx int) interface{}

+ func (self Group2) HasTimestamp() bool

+ func (self Group2) WithTimestamp(timestamp int64) Group

+ func (self Group2) WithoutTimestamp() Group

+ type Group3 struct

+ func (self Group3) GetTimestamp() int64

+ func (self Group3) GetValue(idx int) interface{}

+ func (self Group3) HasTimestamp() bool

+ func (self Group3) WithTimestamp(timestamp int64) Group

+ func (self Group3) WithoutTimestamp() Group

+ type PointRange struct

+ func (self *PointRange) UpdateRange(point *protocol.Point)

type SortableGroups

+ GetSortedGroups func() []Group

Nov 19, 2013

Changes in this version

+ type AbstractAggregator struct

+ func (self *AbstractAggregator) InitializeFieldsMetadata(series *protocol.Series) error

type Aggregator

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

+ func NewFirstOrLastAggregator(name string, v *parser.Value, isFirst bool) (Aggregator, error)

+ func NewHistogramAggregator(q *parser.Query, v *parser.Value) (Aggregator, error)

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

+ ColumnNames func() []string

+ GetValues func(series string, group interface{}) [][]*protocol.FieldValue

type CompositeAggregator

+ func (self *CompositeAggregator) ColumnNames() []string

+ func (self *CompositeAggregator) GetValues(series string, group interface{}) [][]*protocol.FieldValue

type CountAggregator

+ func (self *CountAggregator) ColumnNames() []string

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

type CumulativeArithmeticAggregator

+ func (self *CumulativeArithmeticAggregator) ColumnNames() []string

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

type DerivativeAggregator

+ func (self *DerivativeAggregator) ColumnNames() []string

+ func (self *DerivativeAggregator) GetValues(series string, group interface{}) [][]*protocol.FieldValue

type DistinctAggregator

+ func (self *DistinctAggregator) ColumnNames() []string

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

+ type FirstOrLastAggregator struct

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

+ func (self *FirstOrLastAggregator) ColumnNames() []string

+ func (self *FirstOrLastAggregator) GetValues(series string, group interface{}) [][]*protocol.FieldValue

+ type HistogramAggregator struct

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

+ func (self *HistogramAggregator) ColumnNames() []string

+ func (self *HistogramAggregator) GetValues(series string, group interface{}) [][]*protocol.FieldValue

type MeanAggregator

+ func (self *MeanAggregator) ColumnNames() []string

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

type ModeAggregator

+ func (self *ModeAggregator) ColumnNames() []string

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

type PercentileAggregator

+ func (self *PercentileAggregator) ColumnNames() []string

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

type StandardDeviationAggregator

+ func (self *StandardDeviationAggregator) ColumnNames() []string

+ func (self *StandardDeviationAggregator) GetValues(series string, group interface{}) [][]*protocol.FieldValue

type TimestampAggregator

+ func (self *TimestampAggregator) ColumnNames() []string

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

Nov 14, 2013

Changes in this version

+ type SortableGroups struct

+ func (self SortableGroups) Len() int

+ func (self SortableGroups) Less(i, j int) bool

+ func (self SortableGroups) Swap(i, j int)

Nov 7, 2013

Changes in this version

type Aggregator

+ func NewStandardDeviationAggregator(q *parser.Query, v *parser.Value) (Aggregator, error)

+ type StandardDeviationAggregator struct

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

+ func (self *StandardDeviationAggregator) ColumnName() string

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

+ func (self *StandardDeviationAggregator) InitializeFieldsMetadata(series *protocol.Series) error

+ type StandardDeviationRunning struct

Nov 6, 2013

Changes in this version

type Aggregator

+ func NewDerivativeAggregator(q *parser.Query, v *parser.Value) (Aggregator, error)

+ type DerivativeAggregator struct

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

+ func (self *DerivativeAggregator) ColumnName() string

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

+ func (self *DerivativeAggregator) InitializeFieldsMetadata(series *protocol.Series) error

Nov 5, 2013

Changes in this version

type Aggregator

+ func NewCompositeAggregator(left, right Aggregator) (Aggregator, error)

+ type CompositeAggregator struct

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

+ func (self *CompositeAggregator) ColumnName() string

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

+ func (self *CompositeAggregator) InitializeFieldsMetadata(series *protocol.Series) error

Oct 24, 2013

Changes in this version

+ const ALL_GROUP_IDENTIFIER

+ func SortInt64(ints []int64)

+ type Aggregator interface

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

+ ColumnName func() string

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

+ InitializeFieldsMetadata func(series *protocol.Series) error

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

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

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

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

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

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

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

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

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

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

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

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

+ type CountAggregator struct

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

+ func (self *CountAggregator) ColumnName() string

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

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

+ type CumulativeArithmeticAggregator struct

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

+ func (self *CumulativeArithmeticAggregator) ColumnName() string

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

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

+ type DistinctAggregator struct

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

+ func (self *DistinctAggregator) ColumnName() string

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

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

+ type EngineI interface

+ RunQuery func(database string, query string, yield func(*protocol.Series) error) error

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

+ type Int64Slice []int64

+ func (p Int64Slice) Len() int

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

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

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

+ type Mapper func(*protocol.Point) interface

+ type MeanAggregator struct

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

+ func (self *MeanAggregator) ColumnName() string

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

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

+ type ModeAggregator struct

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

+ func (self *ModeAggregator) ColumnName() string

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

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

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

+ type PercentileAggregator struct

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

+ func (self *PercentileAggregator) ColumnName() string

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

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

+ type PointSlice []protocol.Point

+ type QueryEngine struct

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

+ type TimestampAggregator struct

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

+ func (self *TimestampAggregator) ColumnName() string

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

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