engine

package
v0.0.8 Latest Latest
Warning

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

 Go to latest Published: Nov 6, 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 NewCompositeAggregator added in v0.0.6 

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

func NewCountAggregator 

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

func NewCumulativeArithmeticAggregator 

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

func NewDerivativeAggregator added in v0.0.8 

func NewDerivativeAggregator(q *parser.Query, v *parser.Value) (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 CompositeAggregator added in v0.0.6 

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

func (*CompositeAggregator) AggregatePoint added in v0.0.6 

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

func (*CompositeAggregator) ColumnName added in v0.0.6 

func (self *CompositeAggregator) ColumnName() string

func (*CompositeAggregator) GetValue added in v0.0.6 

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

func (*CompositeAggregator) InitializeFieldsMetadata added in v0.0.6 

func (self *CompositeAggregator) InitializeFieldsMetadata(series *protocol.Series) 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 DerivativeAggregator added in v0.0.8 

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

func (*DerivativeAggregator) AggregatePoint added in v0.0.8 

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

func (*DerivativeAggregator) ColumnName added in v0.0.8 

func (self *DerivativeAggregator) ColumnName() string

func (*DerivativeAggregator) GetValue added in v0.0.8 

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

func (*DerivativeAggregator) InitializeFieldsMetadata added in v0.0.8 

func (self *DerivativeAggregator) 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.