engine

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Nov 19, 2013 License: MIT Imports: 13 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 AbstractAggregator added in v0.3.0 

type AbstractAggregator struct {
	Aggregator
	// contains filtered or unexported fields
}

func (*AbstractAggregator) InitializeFieldsMetadata added in v0.3.0 

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

type Aggregator 

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

func NewCompositeAggregator added in v0.3.0 

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.3.0 

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

func NewDistinctAggregator 

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

func NewFirstAggregator added in v0.3.0 

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

func NewFirstOrLastAggregator added in v0.3.0 

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

func NewHistogramAggregator added in v0.3.0 

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

func NewLastAggregator added in v0.3.0 

func NewLastAggregator(_ *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 NewStandardDeviationAggregator added in v0.3.0 

func NewStandardDeviationAggregator(q *parser.Query, v *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.3.0 

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

func (*CompositeAggregator) AggregatePoint added in v0.3.0 

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

func (*CompositeAggregator) ColumnNames added in v0.3.0 

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

func (*CompositeAggregator) GetValues added in v0.3.0 

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

func (*CompositeAggregator) InitializeFieldsMetadata added in v0.3.0 

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) ColumnNames added in v0.3.0 

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

func (*CountAggregator) GetValues added in v0.3.0 

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

func (*CountAggregator) InitializeFieldsMetadata 

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

type CumulativeArithmeticAggregator 

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

func (*CumulativeArithmeticAggregator) AggregatePoint 

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

func (*CumulativeArithmeticAggregator) ColumnNames added in v0.3.0 

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

func (*CumulativeArithmeticAggregator) GetValues added in v0.3.0 

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

type DerivativeAggregator added in v0.3.0 

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

func (*DerivativeAggregator) AggregatePoint added in v0.3.0 

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

func (*DerivativeAggregator) ColumnNames added in v0.3.0 

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

func (*DerivativeAggregator) GetValues added in v0.3.0 

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

type DistinctAggregator 

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

func (*DistinctAggregator) AggregatePoint 

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

func (*DistinctAggregator) ColumnNames added in v0.3.0 

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

func (*DistinctAggregator) GetValues added in v0.3.0 

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

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 FirstOrLastAggregator added in v0.3.0 

type FirstOrLastAggregator struct {
	AbstractAggregator
	// contains filtered or unexported fields
}

func (*FirstOrLastAggregator) AggregatePoint added in v0.3.0 

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

func (*FirstOrLastAggregator) ColumnNames added in v0.3.0 

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

func (*FirstOrLastAggregator) GetValues added in v0.3.0 

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

type HistogramAggregator added in v0.3.0 

type HistogramAggregator struct {
	AbstractAggregator
	// contains filtered or unexported fields
}

func (*HistogramAggregator) AggregatePoint added in v0.3.0 

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

func (*HistogramAggregator) ColumnNames added in v0.3.0 

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

func (*HistogramAggregator) GetValues added in v0.3.0 

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

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 {
	AbstractAggregator
	// contains filtered or unexported fields
}

func (*MeanAggregator) AggregatePoint 

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

func (*MeanAggregator) ColumnNames added in v0.3.0 

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

func (*MeanAggregator) GetValues added in v0.3.0 

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

type ModeAggregator 

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

func (*ModeAggregator) AggregatePoint 

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

func (*ModeAggregator) ColumnNames added in v0.3.0 

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

func (*ModeAggregator) GetValues added in v0.3.0 

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

type Operation 

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

type PercentileAggregator 

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

func (*PercentileAggregator) AggregatePoint 

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

func (*PercentileAggregator) ColumnNames added in v0.3.0 

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

func (*PercentileAggregator) GetValues added in v0.3.0 

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

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 SortableGroups added in v0.3.0 

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

func (SortableGroups) Len added in v0.3.0 

func (self SortableGroups) Len() int

func (SortableGroups) Less added in v0.3.0 

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

func (SortableGroups) Swap added in v0.3.0 

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

type StandardDeviationAggregator added in v0.3.0 

type StandardDeviationAggregator struct {
	AbstractAggregator
	// contains filtered or unexported fields
}

func (*StandardDeviationAggregator) AggregatePoint added in v0.3.0 

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

func (*StandardDeviationAggregator) ColumnNames added in v0.3.0 

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

func (*StandardDeviationAggregator) GetValues added in v0.3.0 

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

type StandardDeviationRunning added in v0.3.0 

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

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) ColumnNames added in v0.3.0 

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

func (*TimestampAggregator) GetValues added in v0.3.0 

func (self *TimestampAggregator) GetValues(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.