Versions in this module Expand all Collapse all v0 v0.1.0 Jun 30, 2020 Changes in this version + const RowPseudoField + var ErrMeasureNotFound = errors.New("measure not found for field") + type Cardinality struct + Precision int + func (Cardinality) Name() string + func (c Cardinality) ContReader() ContReaderFunc + func (c Cardinality) DiscWriter() DiscWriterFunc + func (c Cardinality) Size() int + type Collator struct + func (c Collator) Keys() [][]byte + func (c Collator) Name() string + func (c Collator) Read(fml []FM, buf []byte) (Result, error) + func (c Collator) Size() int + func (c Collator) Update(r Row, buf []byte, init bool) error + type ContReaderFunc func(buf []byte) (float64, error) + type ContWriterFunc func(buf []byte, init bool, v float64) error + type ContinuousInput interface + ContWriter func() ContWriterFunc + type ContinuousOutput interface + ContReader func() ContReaderFunc + type Count struct + func (Count) ContReader() ContReaderFunc + func (Count) Name() string + func (Count) RowWriter() RowWriterFunc + func (Count) Size() int + type DiscReaderFunc func(buf []byte) ([]byte, error) + type DiscWriterFunc func(buf []byte, init bool, v []byte) error + type DiscreteInput interface + DiscWriter func() DiscWriterFunc + type DiscreteOutput interface + DiscReader func() DiscReaderFunc + type FM struct + F []byte + M [][]byte + type FMV struct + F []byte + M []byte + V interface{} + func (f FMV) String() string + type FV struct + F []byte + V []byte + type FVList []FV + func (fv FVList) KeyValue(keys [][]byte) (uint64, bool) + type FieldSpec struct + Pattern string + type Filter struct + type KeySpec struct + Field FieldSpec + type Max struct + func (Max) ContReader() ContReaderFunc + func (Max) ContWriter() ContWriterFunc + func (Max) Name() string + func (Max) Size() int + type Mean struct + func (Mean) ContReader() ContReaderFunc + func (Mean) ContWriter() ContWriterFunc + func (Mean) Name() string + func (Mean) Size() int + type Measure interface + Name func() string + Size func() int + type MeasureSpec struct + Field FieldSpec + Measures []Measure + type Min struct + func (Min) ContReader() ContReaderFunc + func (Min) ContWriter() ContWriterFunc + func (Min) Name() string + func (Min) Size() int + type Query struct + Criteria FVList + FieldMeasures []FM + func (q *Query) KeyValue(keys [][]byte) (uint64, bool) + func (q *Query) Reset() + type Record struct + type Result struct + FieldMeasureValues []FMV + type Row struct + Data FVList + DataTime time.Time + ReceiveTime time.Time + func (r *Row) KeyValue(keys [][]byte) (uint64, bool) + func (r *Row) Reset() + type RowMeasure interface + RowWriter func() RowWriterFunc + type RowWriterFunc func(buf []byte, init bool) error + type Schema struct + Filter Filter + Keys []KeySpec + Measures []MeasureSpec + Name string + RecordMeasures []RowMeasure + func (s *Schema) Compile() (Collator, error) + type Sum struct + func (Sum) ContReader() ContReaderFunc + func (Sum) ContWriter() ContWriterFunc + func (Sum) Name() string + func (Sum) Size() int + type Variance struct + func (Variance) ContReader() ContReaderFunc + func (Variance) ContWriter() ContWriterFunc + func (Variance) Name() string + func (Variance) Size() int