processing

package

Go to main page

Versions in this module

v0

v0.11.0

May 27, 2026

v0.10.2

May 21, 2026

v0.10.1

May 20, 2026

Changes in this version

type ExtensionRegistry

+ LabelTables map[string]LabelTable

+ type LabelResolver struct

+ func BuildLabelResolver(bindings []*types.LabelBinding, registry *ExtensionRegistry) (*LabelResolver, error)

+ func (r *LabelResolver) Apply(field, raw string) (out string, sibling string, ok bool)

+ func (r *LabelResolver) AugmentField(field string) string

+ func (r *LabelResolver) FieldsWithAugment() []string

+ func (r *LabelResolver) Has(field string) bool

+ func (r *LabelResolver) Mode(field string) types.LabelMode

+ func (r *LabelResolver) Warnings() []ResolverWarning

+ type LabelTable struct

+ Lookup func(key string) (string, bool, error)

+ Rows map[string]string

+ type ResolverWarning struct

+ Code errors.Code

+ Details map[string]any

+ Message string

v0.10.0

May 20, 2026

Changes in this version

+ func AggregationLabel(agg *types.Aggregation) string

+ func CanChainRequest(req *types.Request, schema *encoding.Schema) bool

+ func ChainOutputSchema(req *types.Request) (*encoding.Schema, error)

+ func FormatJoinKindError(kind string) string

+ func JoinedSchema(left, right *encoding.Schema, spec *types.JoinSpec) (*encoding.Schema, error)

+ type HashJoinIterator struct

+ func NewHashJoinIterator(left RecordIterator, right []*Record, leftSchema, rightSchema *encoding.Schema, ...) (*HashJoinIterator, *encoding.Schema, error)

+ func (h *HashJoinIterator) Next() bool

+ func (h *HashJoinIterator) Record() *Record

+ func (h *HashJoinIterator) Reset()

type Record

+ func RecordsFromChainRows(rows []map[string]any, schema *encoding.Schema) ([]*Record, error)

v0.9.0

May 20, 2026

v0.8.4

May 19, 2026

v0.8.3

May 18, 2026

Changes in this version

+ type BitsetSet struct

+ func (b *BitsetSet) Add(id uint32)

+ func (b *BitsetSet) Contains(id uint32) bool

+ func (b *BitsetSet) Kind() string

+ func (b *BitsetSet) Len() int

type FilterFunc

+ func BuildMemberSetPredicate(set MemberSet, schema *encoding.Schema, fieldName string) (FilterFunc, error)

+ type LoadMemberSetResult struct

+ Invalid int

+ Lines int

+ NotInDictionary int

+ Set MemberSet

+ func LoadMemberSetFromReader(r io.Reader, schema *encoding.Schema, fieldName string) (LoadMemberSetResult, error)

+ type MemberSet interface

+ Kind func() string

+ Len func() int

+ type StringSet struct

+ func (s *StringSet) Add(v string)

+ func (s *StringSet) Contains(v string) bool

+ func (s *StringSet) Kind() string

+ func (s *StringSet) Len() int

+ type Uint64Set struct

+ func (s *Uint64Set) Add(v uint64)

+ func (s *Uint64Set) Contains(v uint64) bool

+ func (s *Uint64Set) Kind() string

+ func (s *Uint64Set) Len() int

v0.8.2

May 18, 2026

v0.8.1

May 18, 2026

v0.8.0

May 18, 2026

Changes in this version

+ func CanMergeRequest(req *types.Request, schema *encoding.Schema) bool

type ExtensionRegistry

+ FieldInputs map[string]FieldInputsFunc

+ func (r *ExtensionRegistry) FieldInputsFor(category, name string, raw json.RawMessage) ([]string, bool)

+ type FieldInputsFunc func(raw json.RawMessage) []string

+ type FieldSet map[string]struct

+ func NeededFields(req *types.Request, schema *encoding.Schema, ext *ExtensionRegistry) FieldSet

+ func NewFieldSet(hint int) FieldSet

+ func (s FieldSet) Add(name string)

+ func (s FieldSet) Has(name string) bool

+ func (s FieldSet) IsWide() bool

+ func (s FieldSet) Len() int

+ func (s FieldSet) Widen()

+ type MergeableAggregator interface

+ MergeOnline func(other OnlineAggregator) error

v0.7.2

May 15, 2026

v0.7.1

May 15, 2026

v0.7.0

May 15, 2026

Changes in this version

+ func StreamabilityKey(category, name string) string

+ type ExprFunction struct

+ Fn any

+ Name string

+ type ExtensionAware interface

+ SetExtensions func(r *ExtensionRegistry)

+ type ExtensionRegistry struct

+ Aggregators map[types.AggregationType]AggregatorFactory

+ Attributes map[types.AttributeType]AttributeFactory

+ ExprFunctions []ExprFunction

+ Features map[types.FeatureType]feature.Factory

+ Filterers map[types.FiltererType]FiltererFactory

+ Groupers map[types.GroupType]GrouperFactory

+ LookupTables map[string]LookupTable

+ PostTests map[types.TestType]PostTestFactory

+ RowTests map[types.TestType]RowTestFactory

+ Streamable map[string]bool

+ Windows map[types.WindowType]window.WindowFactory

+ func (r *ExtensionRegistry) CustomAggregatorNames() []types.AggregationType

+ func (r *ExtensionRegistry) CustomAttributeNames() []types.AttributeType

+ func (r *ExtensionRegistry) CustomFeatureNames() []types.FeatureType

+ func (r *ExtensionRegistry) CustomFiltererNames() []types.FiltererType

+ func (r *ExtensionRegistry) CustomGrouperNames() []types.GroupType

+ func (r *ExtensionRegistry) CustomPostTestNames() []types.TestType

+ func (r *ExtensionRegistry) CustomRowTestNames() []types.TestType

+ func (r *ExtensionRegistry) CustomWindowNames() []types.WindowType

+ func (r *ExtensionRegistry) ExprOptions() []expr.Option

+ func (r *ExtensionRegistry) FeatureFactories() map[types.FeatureType]feature.Factory

+ func (r *ExtensionRegistry) HasAggregator(t types.AggregationType) bool

+ func (r *ExtensionRegistry) HasAttribute(t types.AttributeType) bool

+ func (r *ExtensionRegistry) HasFeature(t types.FeatureType) bool

+ func (r *ExtensionRegistry) HasFilterer(t types.FiltererType) bool

+ func (r *ExtensionRegistry) HasGrouper(t types.GroupType) bool

+ func (r *ExtensionRegistry) HasPostTest(t types.TestType) bool

+ func (r *ExtensionRegistry) HasRowTest(t types.TestType) bool

+ func (r *ExtensionRegistry) HasWindow(t types.WindowType) bool

+ func (r *ExtensionRegistry) IsStreamable(category, name string) bool

+ func (r *ExtensionRegistry) LookupAggregator(t types.AggregationType) (AggregatorFactory, bool)

+ func (r *ExtensionRegistry) LookupAttribute(t types.AttributeType) (AttributeFactory, bool)

+ func (r *ExtensionRegistry) LookupFeature(t types.FeatureType) (feature.Factory, bool)

+ func (r *ExtensionRegistry) LookupFilterer(t types.FiltererType) (FiltererFactory, bool)

+ func (r *ExtensionRegistry) LookupGrouper(t types.GroupType) (GrouperFactory, bool)

+ func (r *ExtensionRegistry) LookupPostTest(t types.TestType) (PostTestFactory, bool)

+ func (r *ExtensionRegistry) LookupRowTest(t types.TestType) (RowTestFactory, bool)

+ func (r *ExtensionRegistry) LookupWindow(t types.WindowType) (window.WindowFactory, bool)

+ func (r *ExtensionRegistry) WindowFactories() map[types.WindowType]window.WindowFactory

type FilterFunc

+ func BuildFilters(filterers []*types.Filterer, schema *encoding.Schema, exts *ExtensionRegistry) ([]FilterFunc, error)

+ type LookupTable struct

+ Lookup func(keys ...string) (float64, bool, error)

+ Rows map[string]float64

type Processor

+ func NewProcessorWithExtensions(schema *encoding.Schema, exts *ExtensionRegistry) *Processor

v0.6.0

May 14, 2026

v0.5.0

May 13, 2026

v0.4.0

May 12, 2026

v0.3.0

May 11, 2026

Changes in this version

+ type PostTest interface

+ Run func(rows []map[string]any) (*types.TestResult, error)

+ type PostTestFactory func(spec *types.Test, schema *encoding.Schema) (PostTest, error)

+ type RowTest interface

+ Finalize func() (*types.TestResult, error)

+ UpdateRow func(record *Record) error

+ type RowTestFactory func(spec *types.Test, schema *encoding.Schema) (RowTest, error)

v0.2.0

May 11, 2026

Changes in this version

+ func AggregateDecimalField(agg types.AggregationType, records []*Record, field string, scale uint8) (decimalAggResult, error)

+ func AggregateGeoField(agg types.AggregationType, records []*Record, field string) (any, error)

+ func CanStreamRequest(req *types.Request, schema *encoding.Schema) bool

+ func EnableReuse(iter RecordIterator)

+ func IsDecimalAggregationSupported(agg types.AggregationType) bool

+ func IsGeoAggregation(agg types.AggregationType) bool

+ type BBoxResult struct

+ MaxLat float64

+ MaxLon float64

+ MinLat float64

+ MinLon float64

+ type CentroidResult struct

+ Lat float64

+ Lon float64

+ type OnlineAggregator interface

+ Finalize func() (float64, error)

+ UpdateRow func(record *Record, field string) error

+ type ProcessPath int

+ const PathBuffered

+ const PathStreaming

+ const PathUnknown

+ func (p ProcessPath) String() string

type Processor

+ func (p *Processor) LastPath() ProcessPath

type Record

+ func NewRecordWithWide(schema *encoding.Schema, values map[string]float64, nulls map[string]bool, ...) *Record

+ func NewReusableRecord(schema *encoding.Schema) *Record

+ func (r *Record) ClearForRow()

+ func (r *Record) Set(name string, value float64)

+ func (r *Record) SetNull(name string)

+ func (r *Record) SetNullField(name string)

+ func (r *Record) SetNumeric(name string, value float64)

+ func (r *Record) SetWide(name string, v any)

+ func (r *Record) SetWideField(name string, v any)

+ func (r *Record) WideValue(name string) (any, bool)

+ type ReusableIterator interface

+ SetReuse func(bool)

+ type RowLocalAttribute interface

+ Row func(record *Record, field string) (float64, error)

+ type StreamingGrouper interface

+ KeyForRow func(record *Record, field string) (key string, ok bool, err error)

+ type TwoPassAttribute interface

+ Finalize func() error

+ PrePass func(record *Record, field string) error

v0.1.0

Apr 27, 2026

Changes in this version

+ type Aggregator interface

+ Aggregate func(records []*Record, field string) (float64, error)

+ type AggregatorFactory func(agg *types.Aggregation, schema *encoding.Schema) (Aggregator, error)

+ type AttributeComputer interface

+ Compute func(records []*Record, field string) ([]float64, error)

+ type AttributeFactory func(attr *types.Attribute, schema *encoding.Schema) (AttributeComputer, error)

+ type FilterFunc func(record *Record) (bool, error)

+ type FiltererBuilder interface

+ Build func(filter *types.Filterer, schema *encoding.Schema) (FilterFunc, error)

+ type FiltererFactory func() FiltererBuilder

+ type Grouper interface

+ Group func(records []*Record, field string) (map[string][]*Record, error)

+ type GrouperFactory func(grp *types.Group, schema *encoding.Schema) (Grouper, error)

+ type Processor struct

+ func NewProcessor(schema *encoding.Schema) *Processor

+ func (p *Processor) Process(ctx context.Context, req *types.Request, iter RecordIterator) (*types.Response, error)

+ func (p *Processor) ProcessComposed(ctx context.Context, composed *types.ComposedRequest, records []*Record) ([]*types.Response, error)

+ type Record struct

+ func NewRecord(schema *encoding.Schema, values map[string]float64) *Record

+ func NewRecordWithNulls(schema *encoding.Schema, values map[string]float64, nulls map[string]bool) *Record

+ func (r *Record) AllValues() map[string]any

+ func (r *Record) NumericValue(name string) (float64, bool)

+ func (r *Record) Schema() *encoding.Schema

+ func (r *Record) StringValue(name string) (string, bool)

+ type RecordIterator interface

+ Next func() bool

+ Record func() *Record

+ Reset func()

+ type SliceIterator struct

+ func NewSliceIterator(records []*Record) *SliceIterator

+ func (it *SliceIterator) Next() bool

+ func (it *SliceIterator) Record() *Record

+ func (it *SliceIterator) Reset()

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL