engine

package

Go to main page

Versions in this module

v0

v0.8.7

Nov 16, 2014

v0.8.6

Nov 16, 2014

Changes in this version

+ func ProcessorChain(p Processor) string

type AggregatorEngine

+ func (self *AggregatorEngine) Next() Processor

type ArithmeticEngine

+ func (self *ArithmeticEngine) Next() Processor

type CommonMergeEngine

+ func (self *CommonMergeEngine) Next() Processor

type FilteringEngine

+ func (self *FilteringEngine) Next() Processor

type JoinEngine

+ func (self *JoinEngine) Next() Processor

type MergeEngine

+ func (self *MergeEngine) Next() Processor

type Passthrough

+ func (self *Passthrough) Next() Processor

type Processor

+ Next func() Processor

v0.8.5

Oct 27, 2014

v0.8.4

Oct 24, 2014

Changes in this version

+ type AggregatorEngine struct

+ func NewAggregatorEngine(query *parser.SelectQuery, next Processor) (*AggregatorEngine, error)

+ func (self *AggregatorEngine) Close() error

+ func (self *AggregatorEngine) Name() string

+ func (self *AggregatorEngine) Yield(s *protocol.Series) (bool, error)

+ type ArithmeticEngine struct

+ func NewArithmeticEngine(query *parser.SelectQuery, next Processor) (*ArithmeticEngine, error)

+ func (ae *ArithmeticEngine) Yield(s *protocol.Series) (bool, error)

+ func (self *ArithmeticEngine) Close() error

+ func (self *ArithmeticEngine) Name() string

+ type CommonMergeEngine struct

+ func NewCommonMergeEngine(shards []uint32, mergeColumns bool, ascending bool, next Processor) *CommonMergeEngine

+ func (cme *CommonMergeEngine) Close() error

+ func (cme *CommonMergeEngine) Name() string

+ func (cme *CommonMergeEngine) Yield(s *protocol.Series) (bool, error)

type FilteringEngine

+ func (self *FilteringEngine) Name() string

+ func (self *FilteringEngine) Yield(seriesIncoming *p.Series) (bool, error)

+ type JoinEngine struct

+ func (je *JoinEngine) Close() error

+ func (je *JoinEngine) Name() string

+ func (je *JoinEngine) Yield(s *protocol.Series) (bool, error)

+ type MaxValueSlice struct

+ func (mvs MaxValueSlice) Less(i, j int) bool

+ type MergeEngine struct

+ func (me *MergeEngine) Close() error

+ func (me *MergeEngine) Name() string

+ func (me *MergeEngine) Yield(s *protocol.Series) (bool, error)

+ type Merger struct

+ func NewCME(name string, s []StreamQuery, h SeriesHeap, n Processor, mergeColumns bool) *Merger

+ func (cme *Merger) Update() (bool, error)

+ type MinValueSlice struct

+ func (mvs *MinValueSlice) Len() int

+ func (mvs *MinValueSlice) Less(i, j int) bool

+ func (mvs *MinValueSlice) Pop() interface{}

+ func (mvs *MinValueSlice) Push(x interface{})

+ func (mvs *MinValueSlice) Swap(i, j int)

+ type Passthrough struct

+ func (self *Passthrough) Close() error

+ func (self *Passthrough) Name() string

+ func (self *Passthrough) Yield(seriesIncoming *protocol.Series) (bool, error)

+ type Processor interface

+ Close func() error

+ Name func() string

+ Yield func(s *protocol.Series) (bool, error)

+ func NewJoinEngine(shards []uint32, query *parser.SelectQuery, next Processor) Processor

+ func NewMergeEngine(shards []uint32, ascending bool, next Processor) Processor

+ type SeriesHeap struct

+ Ascending bool

+ func NewSeriesHeap(asc bool) SeriesHeap

+ func (sh SeriesHeap) Add(streamId int, s *protocol.Series)

+ func (sh SeriesHeap) Next() (int, *protocol.Series)

+ func (sh SeriesHeap) Size() int

+ type Stream struct

+ func NewStream() *Stream

+ func (stream *Stream) Close()

+ func (stream *Stream) Closed() bool

+ func (stream *Stream) HasPoint() bool

+ func (stream *Stream) Next() *protocol.Series

+ func (stream *Stream) Yield(s *protocol.Series)

+ type StreamQuery interface

+ Closed func() bool

+ HasPoint func() bool

+ Next func() *protocol.Series

+ type StreamUpdate interface

+ Close func()

+ Yield func(*protocol.Series)

+ type Value struct

v0.8.4-rc.1

Oct 21, 2014

v0.8.2

Sep 5, 2014

v0.8.1

Sep 3, 2014

v0.8.0

Aug 22, 2014

Changes in this version

+ const MAX_SERIES_IN_RESPONSE

+ const MaxInt

+ const POINT_BATCH_SIZE

+ var TRUE = true

+ func DivideOperator(elems []*parser.Value, fields []string, point *protocol.Point) (*protocol.FieldValue, 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 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 SortInt64(ints []int64)

+ type AbstractAggregator struct

+ func (self *AbstractAggregator) CalculateSummaries(state interface{})

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

+ type Aggregator interface

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

+ CalculateSummaries func(state interface{})

+ ColumnNames func() []string

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

+ InitializeFieldsMetadata func(series *protocol.Series) error

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func NewSumAggregator(_ *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 AggregatorInitializer func(*parser.SelectQuery, *parser.Value, *parser.Value) (Aggregator, error)

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

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

+ type ByPointColumnAsc struct

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

+ type ByPointColumnDesc struct

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

+ type CompositeAggregator struct

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

+ func (self *CompositeAggregator) CalculateSummaries(state interface{})

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

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

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

+ type CompositeAggregatorState struct

+ type CountAggregator struct

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

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

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

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

+ type CountAggregatorState int64

+ type CumulativeArithmeticAggregator struct

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

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

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

+ type CumulativeArithmeticAggregatorState float64

+ type DerivativeAggregator struct

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

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

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

+ type DerivativeAggregatorState struct

+ 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

+ type DistinctAggregator struct

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

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

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

+ type DistinctAggregatorState struct

+ type EngineI interface

+ RunQuery func(user common.User, database string, query string, localOnly bool, ...) error

+ 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 FirstOrLastAggregator struct

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

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

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

+ type FirstOrLastAggregatorState *protocol.FieldValue

+ type HistogramAggregator struct

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

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

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

+ type HistogramAggregatorState map[int]int

+ type Int64Slice []int64

+ func (p Int64Slice) Len() int

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

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

+ 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 struct

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

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

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

+ type MeanAggregatorState struct

+ type ModeAggregator struct

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

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

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

+ type ModeAggregatorState struct

+ type Node struct

+ func (self *Node) CountLeafNodes() int

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

+ type Nodes []*Node

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

+ type OperatorResult int

+ const INVALID

+ const MATCH

+ const NO_MATCH

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

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

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

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

+ func RegexMatcherOperator(leftValue, rightValue *protocol.FieldValue) (OperatorResult, 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 struct

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

+ func (self *PercentileAggregator) CalculateSummaries(state interface{})

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

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

+ type PercentileAggregatorState struct

+ type PointRange struct

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

+ type PointSlice []protocol.Point

+ type QueryEngine struct

+ func NewQueryEngine(query *parser.SelectQuery, responseChan chan *protocol.Response) (*QueryEngine, error)

+ 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 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

+ type ReverseStringSlice []string

+ func (self ReverseStringSlice) Len() int

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

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

+ type SeriesState struct

+ type StandardDeviationAggregator struct

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

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

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

+ type StandardDeviationRunning struct

+ 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

+ 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

v0.8.0-rc.5

Aug 15, 2014

v0.8.0-rc.4

Jul 28, 2014

v0.8.0-rc.3

Jul 21, 2014

v0.8.0-rc.2

Jul 16, 2014

v0.8.0-rc.1

Jul 15, 2014

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