35 type FloatReduceFunc func(prev *FloatPoint, curr *FloatPoint) (t int64, v float64, aux []interface{…
40 	prev *FloatPoint  member
45 func NewFloatFuncReducer(fn FloatReduceFunc, prev *FloatPoint) *FloatFuncReducer {
46 	return &FloatFuncReducer{fn: fn, prev: prev}
52 	t, v, aux := r.fn(r.prev, p)
53 	if r.prev == nil {
54 		r.prev = &FloatPoint{}
56 	r.prev.Time = t
57 	r.prev.Value = v
58 	r.prev.Aux = aux
60 		r.prev.Aggregated += p.Aggregated
62 		r.prev.Aggregated++
68 	return []FloatPoint{*r.prev}
105 type FloatReduceIntegerFunc func(prev *IntegerPoint, curr *FloatPoint) (t int64, v int64, aux []int…
110 	prev *IntegerPoint  member
115 func NewFloatFuncIntegerReducer(fn FloatReduceIntegerFunc, prev *IntegerPoint) *FloatFuncIntegerRed…
116 	return &FloatFuncIntegerReducer{fn: fn, prev: prev}
122 	t, v, aux := r.fn(r.prev, p)
123 	if r.prev == nil {
124 		r.prev = &IntegerPoint{}
126 	r.prev.Time = t
127 	r.prev.Value = v
128 	r.prev.Aux = aux
130 		r.prev.Aggregated += p.Aggregated
132 		r.prev.Aggregated++
138 	return []IntegerPoint{*r.prev}
175 type FloatReduceUnsignedFunc func(prev *UnsignedPoint, curr *FloatPoint) (t int64, v uint64, aux []…
180 	prev *UnsignedPoint  member
185 func NewFloatFuncUnsignedReducer(fn FloatReduceUnsignedFunc, prev *UnsignedPoint) *FloatFuncUnsigne…
186 	return &FloatFuncUnsignedReducer{fn: fn, prev: prev}
192 	t, v, aux := r.fn(r.prev, p)
193 	if r.prev == nil {
194 		r.prev = &UnsignedPoint{}
196 	r.prev.Time = t
197 	r.prev.Value = v
198 	r.prev.Aux = aux
200 		r.prev.Aggregated += p.Aggregated
202 		r.prev.Aggregated++
208 	return []UnsignedPoint{*r.prev}
245 type FloatReduceStringFunc func(prev *StringPoint, curr *FloatPoint) (t int64, v string, aux []inte…
250 	prev *StringPoint  member
255 func NewFloatFuncStringReducer(fn FloatReduceStringFunc, prev *StringPoint) *FloatFuncStringReducer…
256 	return &FloatFuncStringReducer{fn: fn, prev: prev}
262 	t, v, aux := r.fn(r.prev, p)
263 	if r.prev == nil {
264 		r.prev = &StringPoint{}
266 	r.prev.Time = t
267 	r.prev.Value = v
268 	r.prev.Aux = aux
270 		r.prev.Aggregated += p.Aggregated
272 		r.prev.Aggregated++
278 	return []StringPoint{*r.prev}
315 type FloatReduceBooleanFunc func(prev *BooleanPoint, curr *FloatPoint) (t int64, v bool, aux []inte…
320 	prev *BooleanPoint  member
325 func NewFloatFuncBooleanReducer(fn FloatReduceBooleanFunc, prev *BooleanPoint) *FloatFuncBooleanRed…
326 	return &FloatFuncBooleanReducer{fn: fn, prev: prev}
332 	t, v, aux := r.fn(r.prev, p)
333 	if r.prev == nil {
334 		r.prev = &BooleanPoint{}
336 	r.prev.Time = t
337 	r.prev.Value = v
338 	r.prev.Aux = aux
340 		r.prev.Aggregated += p.Aggregated
342 		r.prev.Aggregated++
348 	return []BooleanPoint{*r.prev}
441 	prev           FloatPoint  member
449 		prev:           FloatPoint{Nil: true},
456 	r.prev = r.curr
462 	if !r.prev.Nil {
463 		elapsed := (r.curr.Time - r.prev.Time) / r.unitConversion
532 type IntegerReduceFloatFunc func(prev *FloatPoint, curr *IntegerPoint) (t int64, v float64, aux []i…
537 	prev *FloatPoint  member
542 func NewIntegerFuncFloatReducer(fn IntegerReduceFloatFunc, prev *FloatPoint) *IntegerFuncFloatReduc…
543 	return &IntegerFuncFloatReducer{fn: fn, prev: prev}
549 	t, v, aux := r.fn(r.prev, p)
550 	if r.prev == nil {
551 		r.prev = &FloatPoint{}
553 	r.prev.Time = t
554 	r.prev.Value = v
555 	r.prev.Aux = aux
557 		r.prev.Aggregated += p.Aggregated
559 		r.prev.Aggregated++
565 	return []FloatPoint{*r.prev}
602 type IntegerReduceFunc func(prev *IntegerPoint, curr *IntegerPoint) (t int64, v int64, aux []interf…
607 	prev *IntegerPoint  member
612 func NewIntegerFuncReducer(fn IntegerReduceFunc, prev *IntegerPoint) *IntegerFuncReducer {
613 	return &IntegerFuncReducer{fn: fn, prev: prev}
619 	t, v, aux := r.fn(r.prev, p)
620 	if r.prev == nil {
621 		r.prev = &IntegerPoint{}
623 	r.prev.Time = t
624 	r.prev.Value = v
625 	r.prev.Aux = aux
627 		r.prev.Aggregated += p.Aggregated
629 		r.prev.Aggregated++
635 	return []IntegerPoint{*r.prev}
672 type IntegerReduceUnsignedFunc func(prev *UnsignedPoint, curr *IntegerPoint) (t int64, v uint64, au…
677 	prev *UnsignedPoint  member
682 func NewIntegerFuncUnsignedReducer(fn IntegerReduceUnsignedFunc, prev *UnsignedPoint) *IntegerFuncU…
683 	return &IntegerFuncUnsignedReducer{fn: fn, prev: prev}
689 	t, v, aux := r.fn(r.prev, p)
690 	if r.prev == nil {
691 		r.prev = &UnsignedPoint{}
693 	r.prev.Time = t
694 	r.prev.Value = v
695 	r.prev.Aux = aux
697 		r.prev.Aggregated += p.Aggregated
699 		r.prev.Aggregated++
705 	return []UnsignedPoint{*r.prev}
742 type IntegerReduceStringFunc func(prev *StringPoint, curr *IntegerPoint) (t int64, v string, aux []…
747 	prev *StringPoint  member
752 func NewIntegerFuncStringReducer(fn IntegerReduceStringFunc, prev *StringPoint) *IntegerFuncStringR…
753 	return &IntegerFuncStringReducer{fn: fn, prev: prev}
759 	t, v, aux := r.fn(r.prev, p)
760 	if r.prev == nil {
761 		r.prev = &StringPoint{}
763 	r.prev.Time = t
764 	r.prev.Value = v
765 	r.prev.Aux = aux
767 		r.prev.Aggregated += p.Aggregated
769 		r.prev.Aggregated++
775 	return []StringPoint{*r.prev}
812 type IntegerReduceBooleanFunc func(prev *BooleanPoint, curr *IntegerPoint) (t int64, v bool, aux []…
817 	prev *BooleanPoint  member
822 func NewIntegerFuncBooleanReducer(fn IntegerReduceBooleanFunc, prev *BooleanPoint) *IntegerFuncBool…
823 	return &IntegerFuncBooleanReducer{fn: fn, prev: prev}
829 	t, v, aux := r.fn(r.prev, p)
830 	if r.prev == nil {
831 		r.prev = &BooleanPoint{}
833 	r.prev.Time = t
834 	r.prev.Value = v
835 	r.prev.Aux = aux
837 		r.prev.Aggregated += p.Aggregated
839 		r.prev.Aggregated++
845 	return []BooleanPoint{*r.prev}
938 	prev           IntegerPoint  member
946 		prev:           IntegerPoint{Nil: true},
953 	r.prev = r.curr
959 	if !r.prev.Nil {
960 		elapsed := (r.curr.Time - r.prev.Time) / r.unitConversion
1029 type UnsignedReduceFloatFunc func(prev *FloatPoint, curr *UnsignedPoint) (t int64, v float64, aux […
1034 	prev *FloatPoint  member
1039 func NewUnsignedFuncFloatReducer(fn UnsignedReduceFloatFunc, prev *FloatPoint) *UnsignedFuncFloatRe…
1040 	return &UnsignedFuncFloatReducer{fn: fn, prev: prev}
1046 	t, v, aux := r.fn(r.prev, p)
1047 	if r.prev == nil {
1048 		r.prev = &FloatPoint{}
1050 	r.prev.Time = t
1051 	r.prev.Value = v
1052 	r.prev.Aux = aux
1054 		r.prev.Aggregated += p.Aggregated
1056 		r.prev.Aggregated++
1062 	return []FloatPoint{*r.prev}
1099 type UnsignedReduceIntegerFunc func(prev *IntegerPoint, curr *UnsignedPoint) (t int64, v int64, aux…
1104 	prev *IntegerPoint  member
1109 func NewUnsignedFuncIntegerReducer(fn UnsignedReduceIntegerFunc, prev *IntegerPoint) *UnsignedFuncI…
1110 	return &UnsignedFuncIntegerReducer{fn: fn, prev: prev}
1116 	t, v, aux := r.fn(r.prev, p)
1117 	if r.prev == nil {
1118 		r.prev = &IntegerPoint{}
1120 	r.prev.Time = t
1121 	r.prev.Value = v
1122 	r.prev.Aux = aux
1124 		r.prev.Aggregated += p.Aggregated
1126 		r.prev.Aggregated++
1132 	return []IntegerPoint{*r.prev}
1169 type UnsignedReduceFunc func(prev *UnsignedPoint, curr *UnsignedPoint) (t int64, v uint64, aux []in…
1174 	prev *UnsignedPoint  member
1179 func NewUnsignedFuncReducer(fn UnsignedReduceFunc, prev *UnsignedPoint) *UnsignedFuncReducer {
1180 	return &UnsignedFuncReducer{fn: fn, prev: prev}
1186 	t, v, aux := r.fn(r.prev, p)
1187 	if r.prev == nil {
1188 		r.prev = &UnsignedPoint{}
1190 	r.prev.Time = t
1191 	r.prev.Value = v
1192 	r.prev.Aux = aux
1194 		r.prev.Aggregated += p.Aggregated
1196 		r.prev.Aggregated++
1202 	return []UnsignedPoint{*r.prev}
1239 type UnsignedReduceStringFunc func(prev *StringPoint, curr *UnsignedPoint) (t int64, v string, aux …
1244 	prev *StringPoint  member
1249 func NewUnsignedFuncStringReducer(fn UnsignedReduceStringFunc, prev *StringPoint) *UnsignedFuncStri…
1250 	return &UnsignedFuncStringReducer{fn: fn, prev: prev}
1256 	t, v, aux := r.fn(r.prev, p)
1257 	if r.prev == nil {
1258 		r.prev = &StringPoint{}
1260 	r.prev.Time = t
1261 	r.prev.Value = v
1262 	r.prev.Aux = aux
1264 		r.prev.Aggregated += p.Aggregated
1266 		r.prev.Aggregated++
1272 	return []StringPoint{*r.prev}
1309 type UnsignedReduceBooleanFunc func(prev *BooleanPoint, curr *UnsignedPoint) (t int64, v bool, aux …
1314 	prev *BooleanPoint  member
1319 func NewUnsignedFuncBooleanReducer(fn UnsignedReduceBooleanFunc, prev *BooleanPoint) *UnsignedFuncB…
1320 	return &UnsignedFuncBooleanReducer{fn: fn, prev: prev}
1326 	t, v, aux := r.fn(r.prev, p)
1327 	if r.prev == nil {
1328 		r.prev = &BooleanPoint{}
1330 	r.prev.Time = t
1331 	r.prev.Value = v
1332 	r.prev.Aux = aux
1334 		r.prev.Aggregated += p.Aggregated
1336 		r.prev.Aggregated++
1342 	return []BooleanPoint{*r.prev}
1435 	prev           UnsignedPoint  member
1443 		prev:           UnsignedPoint{Nil: true},
1450 	r.prev = r.curr
1456 	if !r.prev.Nil {
1457 		elapsed := (r.curr.Time - r.prev.Time) / r.unitConversion
1526 type StringReduceFloatFunc func(prev *FloatPoint, curr *StringPoint) (t int64, v float64, aux []int…
1531 	prev *FloatPoint  member
1536 func NewStringFuncFloatReducer(fn StringReduceFloatFunc, prev *FloatPoint) *StringFuncFloatReducer {
1537 	return &StringFuncFloatReducer{fn: fn, prev: prev}
1543 	t, v, aux := r.fn(r.prev, p)
1544 	if r.prev == nil {
1545 		r.prev = &FloatPoint{}
1547 	r.prev.Time = t
1548 	r.prev.Value = v
1549 	r.prev.Aux = aux
1551 		r.prev.Aggregated += p.Aggregated
1553 		r.prev.Aggregated++
1559 	return []FloatPoint{*r.prev}
1596 type StringReduceIntegerFunc func(prev *IntegerPoint, curr *StringPoint) (t int64, v int64, aux []i…
1601 	prev *IntegerPoint  member
1606 func NewStringFuncIntegerReducer(fn StringReduceIntegerFunc, prev *IntegerPoint) *StringFuncInteger…
1607 	return &StringFuncIntegerReducer{fn: fn, prev: prev}
1613 	t, v, aux := r.fn(r.prev, p)
1614 	if r.prev == nil {
1615 		r.prev = &IntegerPoint{}
1617 	r.prev.Time = t
1618 	r.prev.Value = v
1619 	r.prev.Aux = aux
1621 		r.prev.Aggregated += p.Aggregated
1623 		r.prev.Aggregated++
1629 	return []IntegerPoint{*r.prev}
1666 type StringReduceUnsignedFunc func(prev *UnsignedPoint, curr *StringPoint) (t int64, v uint64, aux …
1671 	prev *UnsignedPoint  member
1676 func NewStringFuncUnsignedReducer(fn StringReduceUnsignedFunc, prev *UnsignedPoint) *StringFuncUnsi…
1677 	return &StringFuncUnsignedReducer{fn: fn, prev: prev}
1683 	t, v, aux := r.fn(r.prev, p)
1684 	if r.prev == nil {
1685 		r.prev = &UnsignedPoint{}
1687 	r.prev.Time = t
1688 	r.prev.Value = v
1689 	r.prev.Aux = aux
1691 		r.prev.Aggregated += p.Aggregated
1693 		r.prev.Aggregated++
1699 	return []UnsignedPoint{*r.prev}
1736 type StringReduceFunc func(prev *StringPoint, curr *StringPoint) (t int64, v string, aux []interfac…
1741 	prev *StringPoint  member
1746 func NewStringFuncReducer(fn StringReduceFunc, prev *StringPoint) *StringFuncReducer {
1747 	return &StringFuncReducer{fn: fn, prev: prev}
1753 	t, v, aux := r.fn(r.prev, p)
1754 	if r.prev == nil {
1755 		r.prev = &StringPoint{}
1757 	r.prev.Time = t
1758 	r.prev.Value = v
1759 	r.prev.Aux = aux
1761 		r.prev.Aggregated += p.Aggregated
1763 		r.prev.Aggregated++
1769 	return []StringPoint{*r.prev}
1806 type StringReduceBooleanFunc func(prev *BooleanPoint, curr *StringPoint) (t int64, v bool, aux []in…
1811 	prev *BooleanPoint  member
1816 func NewStringFuncBooleanReducer(fn StringReduceBooleanFunc, prev *BooleanPoint) *StringFuncBoolean…
1817 	return &StringFuncBooleanReducer{fn: fn, prev: prev}
1823 	t, v, aux := r.fn(r.prev, p)
1824 	if r.prev == nil {
1825 		r.prev = &BooleanPoint{}
1827 	r.prev.Time = t
1828 	r.prev.Value = v
1829 	r.prev.Aux = aux
1831 		r.prev.Aggregated += p.Aggregated
1833 		r.prev.Aggregated++
1839 	return []BooleanPoint{*r.prev}
1930 	prev           StringPoint  member
1938 		prev:           StringPoint{Nil: true},
1945 	r.prev = r.curr
1951 	if !r.prev.Nil {
1952 		elapsed := (r.curr.Time - r.prev.Time) / r.unitConversion
2021 type BooleanReduceFloatFunc func(prev *FloatPoint, curr *BooleanPoint) (t int64, v float64, aux []i…
2026 	prev *FloatPoint  member
2031 func NewBooleanFuncFloatReducer(fn BooleanReduceFloatFunc, prev *FloatPoint) *BooleanFuncFloatReduc…
2032 	return &BooleanFuncFloatReducer{fn: fn, prev: prev}
2038 	t, v, aux := r.fn(r.prev, p)
2039 	if r.prev == nil {
2040 		r.prev = &FloatPoint{}
2042 	r.prev.Time = t
2043 	r.prev.Value = v
2044 	r.prev.Aux = aux
2046 		r.prev.Aggregated += p.Aggregated
2048 		r.prev.Aggregated++
2054 	return []FloatPoint{*r.prev}
2091 type BooleanReduceIntegerFunc func(prev *IntegerPoint, curr *BooleanPoint) (t int64, v int64, aux […
2096 	prev *IntegerPoint  member
2101 func NewBooleanFuncIntegerReducer(fn BooleanReduceIntegerFunc, prev *IntegerPoint) *BooleanFuncInte…
2102 	return &BooleanFuncIntegerReducer{fn: fn, prev: prev}
2108 	t, v, aux := r.fn(r.prev, p)
2109 	if r.prev == nil {
2110 		r.prev = &IntegerPoint{}
2112 	r.prev.Time = t
2113 	r.prev.Value = v
2114 	r.prev.Aux = aux
2116 		r.prev.Aggregated += p.Aggregated
2118 		r.prev.Aggregated++
2124 	return []IntegerPoint{*r.prev}
2161 type BooleanReduceUnsignedFunc func(prev *UnsignedPoint, curr *BooleanPoint) (t int64, v uint64, au…
2166 	prev *UnsignedPoint  member
2171 func NewBooleanFuncUnsignedReducer(fn BooleanReduceUnsignedFunc, prev *UnsignedPoint) *BooleanFuncU…
2172 	return &BooleanFuncUnsignedReducer{fn: fn, prev: prev}
2178 	t, v, aux := r.fn(r.prev, p)
2179 	if r.prev == nil {
2180 		r.prev = &UnsignedPoint{}
2182 	r.prev.Time = t
2183 	r.prev.Value = v
2184 	r.prev.Aux = aux
2186 		r.prev.Aggregated += p.Aggregated
2188 		r.prev.Aggregated++
2194 	return []UnsignedPoint{*r.prev}
2231 type BooleanReduceStringFunc func(prev *StringPoint, curr *BooleanPoint) (t int64, v string, aux []…
2236 	prev *StringPoint  member
2241 func NewBooleanFuncStringReducer(fn BooleanReduceStringFunc, prev *StringPoint) *BooleanFuncStringR…
2242 	return &BooleanFuncStringReducer{fn: fn, prev: prev}
2248 	t, v, aux := r.fn(r.prev, p)
2249 	if r.prev == nil {
2250 		r.prev = &StringPoint{}
2252 	r.prev.Time = t
2253 	r.prev.Value = v
2254 	r.prev.Aux = aux
2256 		r.prev.Aggregated += p.Aggregated
2258 		r.prev.Aggregated++
2264 	return []StringPoint{*r.prev}
2301 type BooleanReduceFunc func(prev *BooleanPoint, curr *BooleanPoint) (t int64, v bool, aux []interfa…
2306 	prev *BooleanPoint  member
2311 func NewBooleanFuncReducer(fn BooleanReduceFunc, prev *BooleanPoint) *BooleanFuncReducer {
2312 	return &BooleanFuncReducer{fn: fn, prev: prev}
2318 	t, v, aux := r.fn(r.prev, p)
2319 	if r.prev == nil {
2320 		r.prev = &BooleanPoint{}
2322 	r.prev.Time = t
2323 	r.prev.Value = v
2324 	r.prev.Aux = aux
2326 		r.prev.Aggregated += p.Aggregated
2328 		r.prev.Aggregated++
2334 	return []BooleanPoint{*r.prev}
2427 	prev           BooleanPoint  member
2435 		prev:           BooleanPoint{Nil: true},
2442 	r.prev = r.curr
2448 	if !r.prev.Nil {
2449 		elapsed := (r.curr.Time - r.prev.Time) / r.unitConversion