engine

Jun 13, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

May 31, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

May 29, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

May 23, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

type Aggregator

+ func NewDifferenceAggregator(q *parser.SelectQuery, v *parser.Value, defaultValue *parser.Value) (Aggregator, error)

+ type DifferenceAggregator struct

+ func (self *DifferenceAggregator) AggregatePoint(state interface{}, p *protocol.Point) (interface{}, error)

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

+ func (self *DifferenceAggregator) GetValues(state interface{}) [][]*protocol.FieldValue

+ type DifferenceAggregatorState struct

May 19, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

type Aggregator

+ func NewBottomAggregator(_ *parser.SelectQuery, value *parser.Value, defaultValue *parser.Value) (Aggregator, error)

+ func NewTopAggregator(_ *parser.SelectQuery, value *parser.Value, defaultValue *parser.Value) (Aggregator, error)

+ func NewTopOrBottomAggregator(name string, v *parser.Value, isTop bool, defaultValue *parser.Value) (Aggregator, error)

+ type ByPointColumnAsc struct

+ func (s ByPointColumnAsc) Less(i, j int) bool

+ type ByPointColumnDesc struct

+ func (s ByPointColumnDesc) Less(i, j int) bool

+ type TopOrBottomAggregator struct

+ func (self *TopOrBottomAggregator) AggregatePoint(state interface{}, p *protocol.Point) (interface{}, error)

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

+ func (self *TopOrBottomAggregator) GetValues(state interface{}) [][]*protocol.FieldValue

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

+ type TopOrBottomAggregatorState struct

May 16, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

May 13, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

May 8, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

May 6, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

May 2, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Apr 29, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Apr 25, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

+ const MaxInt

+ type CompositeAggregatorState struct

+ type CountAggregatorState int64

+ type CumulativeArithmeticAggregatorState float64

+ type DerivativeAggregatorState struct

+ type DistinctAggregatorState struct

+ type FirstOrLastAggregatorState *protocol.FieldValue

+ type HistogramAggregatorState map[int]int

+ type MeanAggregatorState struct

+ type ModeAggregatorState struct

+ type Node struct

+ func (self *Node) CountLeafNodes() int

+ func (self *Node) GetChildNode(value *protocol.FieldValue) *Node

+ type Nodes []*Node

+ type PercentileAggregatorState struct

+ type SeriesState struct

+ type Trie struct

+ func NewTrie(numLevels, numStates int) *Trie

+ func (self *Trie) Clear()

+ func (self *Trie) CountLeafNodes() int

+ func (self *Trie) GetNode(values []*protocol.FieldValue) *Node

+ func (self *Trie) Traverse(f func([]*protocol.FieldValue, *Node) error) error

+ func (self *Trie) TraverseLevel(level int, f func([]*protocol.FieldValue, *Node) error) error

Apr 22, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Apr 18, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

+ var TRUE = true

+ type OperatorResult int

+ const INVALID

+ const MATCH

+ const NO_MATCH

Apr 17, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

type AbstractAggregator

+ func (self *AbstractAggregator) CalculateSummaries(series string, group interface{})

type Aggregator

+ CalculateSummaries func(series string, group interface{})

type CompositeAggregator

+ func (self *CompositeAggregator) CalculateSummaries(series string, group interface{})

type ModeAggregator

+ func (self *ModeAggregator) CalculateSummaries(series string, group interface{})

type PercentileAggregator

+ func (self *PercentileAggregator) CalculateSummaries(series string, group interface{})

Apr 15, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Apr 9, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Apr 4, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

+ type NullGroup struct

+ func (self NullGroup) GetTimestamp() int64

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

+ func (self NullGroup) HasTimestamp() bool

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

+ func (self NullGroup) WithoutTimestamp() Group

+ type ReverseStringSlice []string

+ func (self ReverseStringSlice) Len() int

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

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

Apr 2, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Mar 31, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

+ type FilteringEngine struct

+ func NewFilteringEngine(query *parser.SelectQuery, processor QueryProcessor) *FilteringEngine

+ func (self *FilteringEngine) Close()

+ func (self *FilteringEngine) GetName() string

+ func (self *FilteringEngine) SetShardInfo(shardId int, shardLocal bool)

+ func (self *FilteringEngine) YieldPoint(seriesName *string, columnNames []string, point *p.Point) bool

+ func (self *FilteringEngine) YieldSeries(seriesIncoming *p.Series) bool

+ type QueryProcessor interface

+ Close func()

+ GetName func() string

+ SetShardInfo func(shardId int, shardLocal bool)

+ YieldPoint func(seriesName *string, columnNames []string, point *p.Point) bool

+ YieldSeries func(seriesIncoming *p.Series) bool

Mar 28, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Mar 25, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Mar 24, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

+ const MAX_SERIES_IN_RESPONSE

+ const POINT_BATCH_SIZE

+ func DivideOperator(elems []*parser.Value, fields []string, point *protocol.Point) (*protocol.FieldValue, error)

+ func EqualityOperator(leftValue, rightValue *protocol.FieldValue) (bool, error)

+ func Filter(query *parser.SelectQuery, series *protocol.Series) (*protocol.Series, error)

+ func GetRegisteredAggregators() (names []string)

+ func GetValue(value *parser.Value, fields []string, point *protocol.Point) (*protocol.FieldValue, error)

+ func GreaterThanOperator(leftValue, rightValue *protocol.FieldValue) (bool, error)

+ func GreaterThanOrEqualOperator(leftValue, rightValue *protocol.FieldValue) (bool, error)

+ func InOperator(leftValue *protocol.FieldValue, rightValue []*protocol.FieldValue) (bool, error)

+ func MinusOperator(elems []*parser.Value, fields []string, point *protocol.Point) (*protocol.FieldValue, error)

+ func MultiplyOperator(elems []*parser.Value, fields []string, point *protocol.Point) (*protocol.FieldValue, error)

+ func PlusOperator(elems []*parser.Value, fields []string, point *protocol.Point) (*protocol.FieldValue, error)

+ func RegexMatcherOperator(leftValue, rightValue *protocol.FieldValue) (bool, error)

type Aggregator

+ AggregateSeries func(series string, group interface{}, s *protocol.Series) error

+ type ArithmeticOperator func(elems []*parser.Value, fields []string, point *protocol.Point) (*protocol.FieldValue, error)

+ type BooleanOperation func(leftValue *protocol.FieldValue, rightValues []*protocol.FieldValue) (bool, error)

type CompositeAggregator

+ func (self *CompositeAggregator) AggregateSeries(series string, group interface{}, s *protocol.Series) error

type CountAggregator

+ func (self *CountAggregator) AggregateSeries(series string, group interface{}, s *protocol.Series) error

type CumulativeArithmeticAggregator

+ func (self *CumulativeArithmeticAggregator) AggregateSeries(series string, group interface{}, s *protocol.Series) error

type DerivativeAggregator

+ func (self *DerivativeAggregator) AggregateSeries(series string, group interface{}, s *protocol.Series) error

type DistinctAggregator

+ func (self *DistinctAggregator) AggregateSeries(series string, group interface{}, s *protocol.Series) error

type FirstOrLastAggregator

+ func (self *FirstOrLastAggregator) AggregateSeries(series string, group interface{}, s *protocol.Series) error

type HistogramAggregator

+ func (self *HistogramAggregator) AggregateSeries(series string, group interface{}, s *protocol.Series) error

+ type Limiter struct

+ func NewLimiter(limit int) *Limiter

+ type ListSeriesEngine struct

+ func NewListSeriesEngine(responseChan chan *protocol.Response) *ListSeriesEngine

+ func (self *ListSeriesEngine) Close()

+ func (self *ListSeriesEngine) GetName() string

+ func (self *ListSeriesEngine) SetShardInfo(shardId int, shardLocal bool)

+ func (self *ListSeriesEngine) YieldPoint(seriesName *string, columnNames []string, point *protocol.Point) bool

+ func (self *ListSeriesEngine) YieldSeries(seriesIncoming *protocol.Series) bool

type MeanAggregator

+ func (self *MeanAggregator) AggregateSeries(series string, group interface{}, s *protocol.Series) error

type ModeAggregator

+ func (self *ModeAggregator) AggregateSeries(series string, group interface{}, s *protocol.Series) error

+ type PassthroughEngine struct

+ func NewPassthroughEngine(responseChan chan *protocol.Response, maxPointsInResponse int) *PassthroughEngine

+ func NewPassthroughEngineWithLimit(responseChan chan *protocol.Response, maxPointsInResponse, limit int) *PassthroughEngine

+ func (self *PassthroughEngine) Close()

+ func (self *PassthroughEngine) GetName() string

+ func (self *PassthroughEngine) SetShardInfo(shardId int, shardLocal bool)

+ func (self *PassthroughEngine) YieldPoint(seriesName *string, columnNames []string, point *protocol.Point) bool

+ func (self *PassthroughEngine) YieldSeries(seriesIncoming *protocol.Series) bool

type PercentileAggregator

+ func (self *PercentileAggregator) AggregateSeries(series string, group interface{}, s *protocol.Series) error

+ type PointFilter struct

+ func NewPointFilter(query *parser.SelectQuery, queryColumnNames []string) *PointFilter

type QueryEngine

+ func (self *QueryEngine) Close()

+ func (self *QueryEngine) GetName() string

+ func (self *QueryEngine) SendQueryStats()

+ func (self *QueryEngine) SetShardInfo(shardId int, shardLocal bool)

+ func (self *QueryEngine) YieldPoint(seriesName *string, fieldNames []string, point *protocol.Point) (shouldContinue bool)

+ func (self *QueryEngine) YieldSeries(seriesIncoming *protocol.Series) (shouldContinue bool)

type StandardDeviationAggregator

+ func (self *StandardDeviationAggregator) AggregateSeries(series string, group interface{}, s *protocol.Series) error

type TimestampAggregator

+ func (self *TimestampAggregator) AggregateSeries(series string, group interface{}, s *protocol.Series) error

Mar 20, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Mar 11, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Mar 7, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Mar 3, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Feb 27, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Feb 25, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Feb 5, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Jan 31, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Jan 31, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Jan 30, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Jan 17, 2014 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

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

Dec 2, 2013 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Dec 2, 2013 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Nov 19, 2013 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

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 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

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 11, 2013 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Nov 7, 2013 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

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 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

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 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Nov 5, 2013 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

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

Nov 1, 2013 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Oct 28, 2013 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Oct 28, 2013 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Oct 28, 2013 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Oct 24, 2013 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

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