Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

series

package

Go to main page

Versions in this module

v0

v0.2.7

Apr 25, 2024

Changes in this version

+ var BitAgg = func() Aggregatable

+ var BitAggAnd = func(src bitmap.Bitmap) Aggregatable

+ var BitAggAndNot = func(src bitmap.Bitmap) Aggregatable

+ var BitAggOr = func(src bitmap.Bitmap) Aggregatable

+ var I128Agg = func(scale int) Aggregatable

+ var I256Agg = func(scale int) Aggregatable

+ var TimeUnitDay = MustParseTimeUnit("d")

+ var TimeUnitHour = MustParseTimeUnit("h")

+ var TimeUnitMinute = MustParseTimeUnit("m")

+ var TimeUnitMonth = MustParseTimeUnit("M")

+ var TimeUnitQuarter = MustParseTimeUnit("q")

+ var TimeUnitWeek = MustParseTimeUnit("w")

+ var TimeUnitYear = MustParseTimeUnit("y")

+ func Fill[T Number](mode FillMode, now, prev, next time.Time, preval, nextval T) (T, bool, bool)

+ func WriteBase64Bytes(b *bytes.Buffer, data []byte, sep byte)

+ func WriteBool(b *bytes.Buffer, i bool, sep byte)

+ func WriteFloat64(b *bytes.Buffer, f float64, prec int, sep byte)

+ func WriteFloat64Slice(b *bytes.Buffer, f []float64, prec int, sep byte)

+ func WriteHexBytes(b *bytes.Buffer, data []byte, sep byte)

+ func WriteInt(b *bytes.Buffer, i int, sep byte)

+ func WriteInt64(b *bytes.Buffer, i int64, sep byte)

+ func WriteInt64Slice(b *bytes.Buffer, i []int64, sep byte)

+ func WriteIntSlice(b *bytes.Buffer, i []int, sep byte)

+ func WriteNullString(b *bytes.Buffer, s string, sep byte)

+ func WriteRawBytes(b *bytes.Buffer, data []byte, sep byte)

+ func WriteRfc3339Slice(b *bytes.Buffer, t []time.Time, sep byte)

+ func WriteString(b *bytes.Buffer, s string, sep byte)

+ func WriteStringSlice(b *bytes.Buffer, s []string, sep byte)

+ func WriteUint64(b *bytes.Buffer, i uint64, sep byte)

+ func WriteUint64Slice(b *bytes.Buffer, i []uint64, sep byte)

+ type Aggregatable interface

+ Add func(Aggregatable) Aggregatable

+ Cmp func(Aggregatable) int

+ Emit func(*bytes.Buffer) error

+ Float64 func() float64

+ Init func(Aggregatable)

+ SetFloat64 func(float64)

+ Zero func() Aggregatable

+ type BitmapAggregator struct

+ func (b *BitmapAggregator) Add(val Aggregatable) Aggregatable

+ func (b *BitmapAggregator) Init(val Aggregatable)

+ func (b *BitmapAggregator) SetFloat64(f64 float64)

+ func (b *BitmapAggregator) UnmarshalBinary(src []byte) error

+ func (b BitmapAggregator) Cmp(val Aggregatable) int

+ func (b BitmapAggregator) Count() int

+ func (b BitmapAggregator) Emit(buf *bytes.Buffer) error

+ func (b BitmapAggregator) Float64() float64

+ func (b BitmapAggregator) IsZero() bool

+ func (b BitmapAggregator) Zero() Aggregatable

+ type BitmapIntersectFunc func(bitmap.Bitmap, bitmap.Bitmap) bitmap.Bitmap

+ type Bucket interface

+ Emit func(*bytes.Buffer) error

+ Len func() int

+ Push func(time.Time, pack.Row, bool) error

+ WithDimensions func(TimeRange, TimeUnit) Bucket

+ WithFill func(FillMode) Bucket

+ WithIndex func(int) Bucket

+ WithInit func(Aggregatable) Bucket

+ WithLimit func(int) Bucket

+ WithName func(string) Bucket

+ WithReducer func(ReducerFunc) Bucket

+ WithType func(reflect.Type) Bucket

+ WithTypeOf func(Aggregatable) Bucket

+ func NewBucket(typ pack.FieldType) Bucket

+ type CountBucket struct

+ func NewCountBucket() *CountBucket

+ func (b *CountBucket) Emit(buf *bytes.Buffer) error

+ func (b *CountBucket) Len() int

+ func (b *CountBucket) Push(t time.Time, _ pack.Row, join bool) error

+ func (b *CountBucket) WithDimensions(r TimeRange, w TimeUnit) Bucket

+ func (b *CountBucket) WithFill(mode FillMode) Bucket

+ func (b *CountBucket) WithIndex(index int) Bucket

+ func (b *CountBucket) WithInit(_ Aggregatable) Bucket

+ func (b *CountBucket) WithLimit(limit int) Bucket

+ func (b *CountBucket) WithName(name string) Bucket

+ func (b *CountBucket) WithReducer(_ ReducerFunc) Bucket

+ func (b *CountBucket) WithType(_ reflect.Type) Bucket

+ func (b *CountBucket) WithTypeOf(_ Aggregatable) Bucket

+ type CountReducer struct

+ func (r *CountReducer[T]) Reduce(_ T, t time.Time, _ bool)

+ func (r *CountReducer[T]) Reset()

+ func (r *CountReducer[T]) Time() time.Time

+ func (r *CountReducer[T]) Type() ReducerFunc

+ func (r *CountReducer[T]) Value() (T, bool)

+ type Expr struct

+ Field string

+ Reduce ReducerFunc

+ type ExprList []Expr

+ func (l *ExprList) AddUnique(name string, fn ReducerFunc)

+ func (l *ExprList) AddUniqueFront(name string, fn ReducerFunc)

+ func (l *ExprList) UnmarshalText(src []byte) error

+ func (l ExprList) Cols() (cols util.StringList)

+ func (l ExprList) QueryFields() (cols util.StringList)

+ func (s ExprList) Get(i int) (e Expr)

+ type FillMode string

+ const FillModeInvalid

+ const FillModeLast

+ const FillModeLinear

+ const FillModeNone

+ const FillModeNow

+ const FillModeNull

+ const FillModeZero

+ func ParseFillMode(s string) FillMode

+ func (m *FillMode) UnmarshalText(data []byte) error

+ func (m FillMode) IsValid() bool

+ func (m FillMode) MarshalText() ([]byte, error)

+ func (m FillMode) String() string

+ type FirstJoinReducer struct

+ func (r *FirstJoinReducer[T]) Reduce(v T, t time.Time, join bool)

+ func (r *FirstJoinReducer[T]) Reset()

+ func (r *FirstJoinReducer[T]) Time() time.Time

+ func (r *FirstJoinReducer[T]) Type() ReducerFunc

+ func (r *FirstJoinReducer[T]) Value() (T, bool)

+ type FirstReducer struct

+ func (r *FirstReducer[T]) Reduce(v T, t time.Time, _ bool)

+ func (r *FirstReducer[T]) Reset()

+ func (r *FirstReducer[T]) Time() time.Time

+ func (r *FirstReducer[T]) Type() ReducerFunc

+ func (r *FirstReducer[T]) Value() (T, bool)

+ type Float = constraints.Float

+ type Int128Aggregator struct

+ func (b *Int128Aggregator) Add(val Aggregatable) Aggregatable

+ func (b *Int128Aggregator) Init(val Aggregatable)

+ func (b *Int128Aggregator) SetFloat64(f64 float64)

+ func (b *Int128Aggregator) UnmarshalBinary(_ []byte) error

+ func (b Int128Aggregator) Cmp(val Aggregatable) int

+ func (b Int128Aggregator) Emit(buf *bytes.Buffer) error

+ func (b Int128Aggregator) Float64() float64

+ func (b Int128Aggregator) Zero() Aggregatable

+ type Int256Aggregator struct

+ func (b *Int256Aggregator) Add(val Aggregatable) Aggregatable

+ func (b *Int256Aggregator) Init(val Aggregatable)

+ func (b *Int256Aggregator) SetFloat64(f64 float64)

+ func (b *Int256Aggregator) UnmarshalBinary(_ []byte) error

+ func (b Int256Aggregator) Cmp(val Aggregatable) int

+ func (b Int256Aggregator) Emit(buf *bytes.Buffer) error

+ func (b Int256Aggregator) Float64() float64

+ func (b Int256Aggregator) Zero() Aggregatable

+ type LastJoinReducer struct

+ func (r *LastJoinReducer[T]) Reduce(v T, t time.Time, join bool)

+ func (r *LastJoinReducer[T]) Reset()

+ func (r *LastJoinReducer[T]) Time() time.Time

+ func (r *LastJoinReducer[T]) Type() ReducerFunc

+ func (r *LastJoinReducer[T]) Value() (T, bool)

+ type LastReducer struct

+ func (r *LastReducer[T]) Reduce(v T, t time.Time, _ bool)

+ func (r *LastReducer[T]) Reset()

+ func (r *LastReducer[T]) Time() time.Time

+ func (r *LastReducer[T]) Type() ReducerFunc

+ func (r *LastReducer[T]) Value() (T, bool)

+ type LimitableRequest interface

+ ApplyLimits func(int, int)

+ type MaxJoinReducer struct

+ func (r *MaxJoinReducer[T]) Reduce(v T, t time.Time, join bool)

+ func (r *MaxJoinReducer[T]) Reset()

+ func (r *MaxJoinReducer[T]) Time() time.Time

+ func (r *MaxJoinReducer[T]) Type() ReducerFunc

+ func (r *MaxJoinReducer[T]) Value() (T, bool)

+ type MaxReducer struct

+ func (r *MaxReducer[T]) Reduce(v T, t time.Time, _ bool)

+ func (r *MaxReducer[T]) Reset()

+ func (r *MaxReducer[T]) Time() time.Time

+ func (r *MaxReducer[T]) Type() ReducerFunc

+ func (r *MaxReducer[T]) Value() (T, bool)

+ type MeanJoinReducer struct

+ func (r *MeanJoinReducer[T]) Reduce(v T, t time.Time, join bool)

+ func (r *MeanJoinReducer[T]) Reset()

+ func (r *MeanJoinReducer[T]) Time() time.Time

+ func (r *MeanJoinReducer[T]) Type() ReducerFunc

+ func (r *MeanJoinReducer[T]) Value() (T, bool)

+ type MeanReducer struct

+ func (r *MeanReducer[T]) Reduce(v T, t time.Time, _ bool)

+ func (r *MeanReducer[T]) Reset()

+ func (r *MeanReducer[T]) Time() time.Time

+ func (r *MeanReducer[T]) Type() ReducerFunc

+ func (r *MeanReducer[T]) Value() (T, bool)

+ type MinJoinReducer struct

+ func (r *MinJoinReducer[T]) Reduce(v T, t time.Time, join bool)

+ func (r *MinJoinReducer[T]) Reset()

+ func (r *MinJoinReducer[T]) Time() time.Time

+ func (r *MinJoinReducer[T]) Type() ReducerFunc

+ func (r *MinJoinReducer[T]) Value() (T, bool)

+ type MinReducer struct

+ func (r *MinReducer[T]) Reduce(v T, t time.Time, _ bool)

+ func (r *MinReducer[T]) Reset()

+ func (r *MinReducer[T]) Time() time.Time

+ func (r *MinReducer[T]) Type() ReducerFunc

+ func (r *MinReducer[T]) Value() (T, bool)

+ type NativeBucket struct

+ func NewNativeBucket[T Number]() *NativeBucket[T]

+ func (b *NativeBucket[T]) Emit(buf *bytes.Buffer) error

+ func (b *NativeBucket[T]) Len() int

+ func (b *NativeBucket[T]) Push(t time.Time, r pack.Row, join bool) error

+ func (b *NativeBucket[T]) WithDimensions(r TimeRange, w TimeUnit) Bucket

+ func (b *NativeBucket[T]) WithFill(mode FillMode) Bucket

+ func (b *NativeBucket[T]) WithIndex(index int) Bucket

+ func (b *NativeBucket[T]) WithInit(_ Aggregatable) Bucket

+ func (b *NativeBucket[T]) WithLimit(limit int) Bucket

+ func (b *NativeBucket[T]) WithName(name string) Bucket

+ func (b *NativeBucket[T]) WithReducer(fn ReducerFunc) Bucket

+ func (b *NativeBucket[T]) WithType(_ reflect.Type) Bucket

+ func (b *NativeBucket[T]) WithTypeOf(_ Aggregatable) Bucket

+ type Number interface

+ type Reducer interface

+ Reduce func(T, time.Time, bool)

+ Reset func()

+ Time func() time.Time

+ Type func() ReducerFunc

+ Value func() (T, bool)

+ func NewReducer[T Number](fn ReducerFunc) Reducer[T]

+ type ReducerFunc string

+ const ReducerFuncCount

+ const ReducerFuncFirst

+ const ReducerFuncFirstJoin

+ const ReducerFuncInvalid

+ const ReducerFuncLast

+ const ReducerFuncLastJoin

+ const ReducerFuncMax

+ const ReducerFuncMaxJoin

+ const ReducerFuncMean

+ const ReducerFuncMeanJoin

+ const ReducerFuncMin

+ const ReducerFuncMinJoin

+ const ReducerFuncStd

+ const ReducerFuncStdJoin

+ const ReducerFuncSum

+ const ReducerFuncVar

+ const ReducerFuncVarJoin

+ func ParseReducerFunc(s string) ReducerFunc

+ func (f *ReducerFunc) UnmarshalText(data []byte) error

+ func (f ReducerFunc) IsValid() bool

+ func (f ReducerFunc) MarshalText() ([]byte, error)

+ func (f ReducerFunc) String() string

+ type Request struct

+ Fill FillMode

+ GroupBy string

+ Interval TimeUnit

+ Limit int

+ Range TimeRange

+ Select ExprList

+ Table string

+ TypeMap TypeMap

+ func NewRequest() *Request

+ func (r *Request) ApplyLimits(def, max int) *Request

+ func (r *Request) Sanitize() *Request

+ func (r *Request) WithExpr(field string, fn ReducerFunc) *Request

+ func (r *Request) WithFill(m FillMode) *Request

+ func (r *Request) WithGroupBy(g string) *Request

+ func (r *Request) WithInterval(u TimeUnit) *Request

+ func (r *Request) WithLimit(l int) *Request

+ func (r *Request) WithRange(rng TimeRange) *Request

+ func (r *Request) WithTable(t pack.Table) *Request

+ func (r *Request) WithType(name string, agg Aggregatable) *Request

+ func (r Request) MakeBucket(expr Expr, tinfo pack.FieldList) (Bucket, error)

+ func (r Request) Query(key string) pack.Query

+ func (r Request) Run(ctx context.Context, key string) (*Result, error)

+ func (req Request) RunQuery(ctx context.Context, q pack.Query) (*Result, error)

+ type Result struct

+ func (r Result) Columns() []string

+ func (r Result) Groups() []string

+ func (r Result) MarshalJSON() ([]byte, error)

+ type Signed = constraints.Signed

+ type StdJoinReducer struct

+ func (r *StdJoinReducer[T]) Reduce(v T, t time.Time, join bool)

+ func (r *StdJoinReducer[T]) Reset()

+ func (r *StdJoinReducer[T]) Time() time.Time

+ func (r *StdJoinReducer[T]) Type() ReducerFunc

+ func (r *StdJoinReducer[T]) Value() (T, bool)

+ type StdReducer struct

+ func (r *StdReducer[T]) Reduce(v T, t time.Time, _ bool)

+ func (r *StdReducer[T]) Reset()

+ func (r *StdReducer[T]) Time() time.Time

+ func (r *StdReducer[T]) Type() ReducerFunc

+ func (r *StdReducer[T]) Value() (T, bool)

+ type SumReducer struct

+ func (r *SumReducer[T]) Reduce(v T, t time.Time, _ bool)

+ func (r *SumReducer[T]) Reset()

+ func (r *SumReducer[T]) Time() time.Time

+ func (r *SumReducer[T]) Type() ReducerFunc

+ func (r *SumReducer[T]) Value() (T, bool)

+ type TimeBucket struct

+ func NewTimeBucket() *TimeBucket

+ type TimeRange struct

+ From time.Time

+ IsRelative bool

+ Key string

+ To time.Time

+ func MustParseTimeRange(s string) TimeRange

+ func NewTimeRangeSince(u TimeUnit) TimeRange

+ func ParseTimeRange(s string) (TimeRange, error)

+ func (r *TimeRange) Set(s string) (err error)

+ func (r *TimeRange) UnmarshalText(data []byte) error

+ func (r TimeRange) Duration() time.Duration

+ func (r TimeRange) Epochs(interval TimeUnit, limit int) (epochs [][2]time.Time)

+ func (r TimeRange) MarshalText() ([]byte, error)

+ func (r TimeRange) NumSteps(u TimeUnit) (steps int)

+ func (r TimeRange) Sanitize(now time.Time) TimeRange

+ func (r TimeRange) String() string

+ func (r TimeRange) Truncate(d time.Duration) TimeRange

+ type TimeUnit struct

+ Unit rune

+ Value int

+ func MustParseTimeUnit(s string) TimeUnit

+ func ParseTimeUnit(s string) (TimeUnit, error)

+ func (c *TimeUnit) UnmarshalText(data []byte) error

+ func (c TimeUnit) Add(t time.Time) time.Time

+ func (c TimeUnit) Base() time.Duration

+ func (c TimeUnit) Between(from, to time.Time, limit int) []time.Time

+ func (c TimeUnit) Duration() time.Duration

+ func (c TimeUnit) Format(t time.Time) string

+ func (c TimeUnit) MarshalText() ([]byte, error)

+ func (c TimeUnit) Next(t time.Time, n int) time.Time

+ func (c TimeUnit) Steps(from, to time.Time, limit int) []time.Time

+ func (c TimeUnit) String() string

+ func (c TimeUnit) Sub(t time.Time) time.Time

+ func (c TimeUnit) Title() string

+ func (c TimeUnit) Truncate(t time.Time) time.Time

+ func (c TimeUnit) TruncateRelative(t time.Time, base time.Time) time.Time

+ func (u *TimeUnit) Set(s string) (err error)

+ type TypeMap map[string]Aggregatable

+ type TypedBucket struct

+ func NewTypedBucket() *TypedBucket

+ func (b *TypedBucket) Emit(buf *bytes.Buffer) error

+ func (b *TypedBucket) Len() int

+ func (b *TypedBucket) Push(t time.Time, r pack.Row, join bool) error

+ func (b *TypedBucket) WithDimensions(r TimeRange, w TimeUnit) Bucket

+ func (b *TypedBucket) WithFill(mode FillMode) Bucket

+ func (b *TypedBucket) WithIndex(index int) Bucket

+ func (b *TypedBucket) WithInit(val Aggregatable) Bucket

+ func (b *TypedBucket) WithLimit(limit int) Bucket

+ func (b *TypedBucket) WithName(name string) Bucket

+ func (b *TypedBucket) WithReducer(fn ReducerFunc) Bucket

+ func (b *TypedBucket) WithType(typ reflect.Type) Bucket

+ func (b *TypedBucket) WithTypeOf(val Aggregatable) Bucket

+ type TypedFirstJoinReducer struct

+ func (r *TypedFirstJoinReducer) Config() Aggregatable

+ func (r *TypedFirstJoinReducer) Init(v Aggregatable)

+ func (r *TypedFirstJoinReducer) Reduce(v Aggregatable, t time.Time, join bool)

+ func (r *TypedFirstJoinReducer) Reset()

+ func (r *TypedFirstJoinReducer) Time() time.Time

+ func (r *TypedFirstJoinReducer) Type() ReducerFunc

+ func (r *TypedFirstJoinReducer) Value() (Aggregatable, bool)

+ type TypedFirstReducer struct

+ func (r *TypedFirstReducer) Config() Aggregatable

+ func (r *TypedFirstReducer) Init(v Aggregatable)

+ func (r *TypedFirstReducer) Reduce(v Aggregatable, t time.Time, _ bool)

+ func (r *TypedFirstReducer) Reset()

+ func (r *TypedFirstReducer) Time() time.Time

+ func (r *TypedFirstReducer) Type() ReducerFunc

+ func (r *TypedFirstReducer) Value() (Aggregatable, bool)

+ type TypedLastJoinReducer struct

+ func (r *TypedLastJoinReducer) Config() Aggregatable

+ func (r *TypedLastJoinReducer) Init(v Aggregatable)

+ func (r *TypedLastJoinReducer) Reduce(v Aggregatable, t time.Time, join bool)

+ func (r *TypedLastJoinReducer) Reset()

+ func (r *TypedLastJoinReducer) Time() time.Time

+ func (r *TypedLastJoinReducer) Type() ReducerFunc

+ func (r *TypedLastJoinReducer) Value() (Aggregatable, bool)

+ type TypedLastReducer struct

+ func (r *TypedLastReducer) Config() Aggregatable

+ func (r *TypedLastReducer) Init(v Aggregatable)

+ func (r *TypedLastReducer) Reduce(v Aggregatable, t time.Time, _ bool)

+ func (r *TypedLastReducer) Reset()

+ func (r *TypedLastReducer) Time() time.Time

+ func (r *TypedLastReducer) Type() ReducerFunc

+ func (r *TypedLastReducer) Value() (Aggregatable, bool)

+ type TypedMaxJoinReducer struct

+ func (r *TypedMaxJoinReducer) Config() Aggregatable

+ func (r *TypedMaxJoinReducer) Init(v Aggregatable)

+ func (r *TypedMaxJoinReducer) Reduce(v Aggregatable, t time.Time, join bool)

+ func (r *TypedMaxJoinReducer) Reset()

+ func (r *TypedMaxJoinReducer) Time() time.Time

+ func (r *TypedMaxJoinReducer) Type() ReducerFunc

+ func (r *TypedMaxJoinReducer) Value() (Aggregatable, bool)

+ type TypedMaxReducer struct

+ func (r *TypedMaxReducer) Config() Aggregatable

+ func (r *TypedMaxReducer) Init(v Aggregatable)

+ func (r *TypedMaxReducer) Reduce(v Aggregatable, t time.Time, _ bool)

+ func (r *TypedMaxReducer) Reset()

+ func (r *TypedMaxReducer) Time() time.Time

+ func (r *TypedMaxReducer) Type() ReducerFunc

+ func (r *TypedMaxReducer) Value() (Aggregatable, bool)

+ type TypedMeanJoinReducer struct

+ func (r *TypedMeanJoinReducer) Config() Aggregatable

+ func (r *TypedMeanJoinReducer) Init(v Aggregatable)

+ func (r *TypedMeanJoinReducer) Reduce(v Aggregatable, t time.Time, join bool)

+ func (r *TypedMeanJoinReducer) Reset()

+ func (r *TypedMeanJoinReducer) Time() time.Time

+ func (r *TypedMeanJoinReducer) Type() ReducerFunc

+ func (r *TypedMeanJoinReducer) Value() (Aggregatable, bool)

+ type TypedMeanReducer struct

+ func (r *TypedMeanReducer) Config() Aggregatable

+ func (r *TypedMeanReducer) Init(v Aggregatable)

+ func (r *TypedMeanReducer) Reduce(v Aggregatable, t time.Time, _ bool)

+ func (r *TypedMeanReducer) Reset()

+ func (r *TypedMeanReducer) Time() time.Time

+ func (r *TypedMeanReducer) Type() ReducerFunc

+ func (r *TypedMeanReducer) Value() (Aggregatable, bool)

+ type TypedMinJoinReducer struct

+ func (r *TypedMinJoinReducer) Config() Aggregatable

+ func (r *TypedMinJoinReducer) Init(v Aggregatable)

+ func (r *TypedMinJoinReducer) Reduce(v Aggregatable, t time.Time, join bool)

+ func (r *TypedMinJoinReducer) Reset()

+ func (r *TypedMinJoinReducer) Time() time.Time

+ func (r *TypedMinJoinReducer) Type() ReducerFunc

+ func (r *TypedMinJoinReducer) Value() (Aggregatable, bool)

+ type TypedMinReducer struct

+ func (r *TypedMinReducer) Config() Aggregatable

+ func (r *TypedMinReducer) Init(v Aggregatable)

+ func (r *TypedMinReducer) Reduce(v Aggregatable, t time.Time, _ bool)

+ func (r *TypedMinReducer) Reset()

+ func (r *TypedMinReducer) Time() time.Time

+ func (r *TypedMinReducer) Type() ReducerFunc

+ func (r *TypedMinReducer) Value() (Aggregatable, bool)

+ type TypedReducer interface

+ Config func() Aggregatable

+ Init func(Aggregatable)

+ Reduce func(Aggregatable, time.Time, bool)

+ Reset func()

+ Time func() time.Time

+ Type func() ReducerFunc

+ Value func() (Aggregatable, bool)

+ func NewTypedReducer(typ reflect.Type, fn ReducerFunc) TypedReducer

+ type TypedStdJoinReducer struct

+ func (r *TypedStdJoinReducer) Config() Aggregatable

+ func (r *TypedStdJoinReducer) Init(v Aggregatable)

+ func (r *TypedStdJoinReducer) Reduce(v Aggregatable, t time.Time, join bool)

+ func (r *TypedStdJoinReducer) Reset()

+ func (r *TypedStdJoinReducer) Time() time.Time

+ func (r *TypedStdJoinReducer) Type() ReducerFunc

+ func (r *TypedStdJoinReducer) Value() (Aggregatable, bool)

+ type TypedStdReducer struct

+ func (r *TypedStdReducer) Config() Aggregatable

+ func (r *TypedStdReducer) Init(v Aggregatable)

+ func (r *TypedStdReducer) Reduce(v Aggregatable, t time.Time, _ bool)

+ func (r *TypedStdReducer) Reset()

+ func (r *TypedStdReducer) Time() time.Time

+ func (r *TypedStdReducer) Type() ReducerFunc

+ func (r *TypedStdReducer) Value() (Aggregatable, bool)

+ type TypedSumReducer struct

+ func (r *TypedSumReducer) Config() Aggregatable

+ func (r *TypedSumReducer) Init(v Aggregatable)

+ func (r *TypedSumReducer) Reduce(v Aggregatable, t time.Time, _ bool)

+ func (r *TypedSumReducer) Reset()

+ func (r *TypedSumReducer) Time() time.Time

+ func (r *TypedSumReducer) Type() ReducerFunc

+ func (r *TypedSumReducer) Value() (Aggregatable, bool)

+ type TypedVarJoinReducer struct

+ func (r *TypedVarJoinReducer) Config() Aggregatable

+ func (r *TypedVarJoinReducer) Init(v Aggregatable)

+ func (r *TypedVarJoinReducer) Reduce(v Aggregatable, t time.Time, join bool)

+ func (r *TypedVarJoinReducer) Reset()

+ func (r *TypedVarJoinReducer) Time() time.Time

+ func (r *TypedVarJoinReducer) Type() ReducerFunc

+ func (r *TypedVarJoinReducer) Value() (Aggregatable, bool)

+ type TypedVarReducer struct

+ func (r *TypedVarReducer) Config() Aggregatable

+ func (r *TypedVarReducer) Init(v Aggregatable)

+ func (r *TypedVarReducer) Reduce(v Aggregatable, t time.Time, _ bool)

+ func (r *TypedVarReducer) Reset()

+ func (r *TypedVarReducer) Time() time.Time

+ func (r *TypedVarReducer) Type() ReducerFunc

+ func (r *TypedVarReducer) Value() (Aggregatable, bool)

+ type Unsigned = constraints.Unsigned

+ type VarJoinReducer struct

+ func (r *VarJoinReducer[T]) Reduce(v T, t time.Time, join bool)

+ func (r *VarJoinReducer[T]) Reset()

+ func (r *VarJoinReducer[T]) Time() time.Time

+ func (r *VarJoinReducer[T]) Type() ReducerFunc

+ func (r *VarJoinReducer[T]) Value() (T, bool)

+ type VarReducer struct

+ func (r *VarReducer[T]) Reduce(v T, t time.Time, _ bool)

+ func (r *VarReducer[T]) Reset()

+ func (r *VarReducer[T]) Time() time.Time

+ func (r *VarReducer[T]) Type() ReducerFunc

+ func (r *VarReducer[T]) Value() (T, bool)

v0.2.6

Mar 26, 2024

v0.2.5

Feb 24, 2024