forked from influxdata/kapacitor
-
Notifications
You must be signed in to change notification settings - Fork 0
/
influxql.gen.go
38 lines (29 loc) · 1.28 KB
/
influxql.gen.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
// Generated by tmpl
// https://github.com/benbjohnson/tmpl
//
// DO NOT EDIT!
// Source: influxql.gen.go.tmpl
package pipeline
import "github.com/influxdata/influxdb/influxql"
//tick:ignore
type ReduceCreater struct {
CreateFloatReducer func() (influxql.FloatPointAggregator, influxql.FloatPointEmitter)
CreateFloatBulkReducer func() (FloatBulkPointAggregator, influxql.FloatPointEmitter)
CreateFloatIntegerReducer func() (influxql.FloatPointAggregator, influxql.IntegerPointEmitter)
CreateFloatBulkIntegerReducer func() (FloatBulkPointAggregator, influxql.IntegerPointEmitter)
CreateIntegerFloatReducer func() (influxql.IntegerPointAggregator, influxql.FloatPointEmitter)
CreateIntegerBulkFloatReducer func() (IntegerBulkPointAggregator, influxql.FloatPointEmitter)
CreateIntegerReducer func() (influxql.IntegerPointAggregator, influxql.IntegerPointEmitter)
CreateIntegerBulkReducer func() (IntegerBulkPointAggregator, influxql.IntegerPointEmitter)
TopBottomCallInfo *TopBottomCallInfo
IsSimpleSelector bool
IsStreamTransformation bool
}
type FloatBulkPointAggregator interface {
influxql.FloatPointAggregator
influxql.FloatBulkPointAggregator
}
type IntegerBulkPointAggregator interface {
influxql.IntegerPointAggregator
influxql.IntegerBulkPointAggregator
}