fn

type AggrAggregateFunc func(aggr *aggrImpl, accumulatedValue float64, inputValue float64) (float64, error)

type AggrFinalizeFunc func(aggr *aggrImpl, accumulatedValue float64, accumulatedCount int) (any, error)

type AggrResetFunc func(aggr *aggrImpl) (float64, error)

type Aggregator interface {
	// Name returns the name of the aggregator.
	Name() string
	// Type returns the type of the aggregator.
	Type() FunctionType
	// Argmuents returns the arguments of the aggregator.
	Arguments() []string
	// GroupBy returns the group by column name and whether it is a group by column.
	GroupBy() (string, bool)
	// Reset resets the aggregator to its initial state.
	Reset(opts ...any) error
	// Aggregate aggregates a map or an array. The map represents a row of data, and the array is a
	// list of rows. If grouping is enabled, the array row must have a group value as the first element.
	Aggregate(v any) error
	// Finalize finalizes the aggregation and returns the result.
	Finalize() (ResultSet, error)
}

type AggregatorOption = aggrOption

type AggregatorSet []Aggregator

type Argument string

type Arguments []Argument

type ArithFunc func(float64, float64) (float64, error)

type Avg struct {
	// contains filtered or unexported fields
}

type AvgOption = aggrOption

type CastFunc = func(any) (any, error)

type Count struct {
	// contains filtered or unexported fields
}

type CountOption = aggrOption

type Executor interface {
	// Name returns the name of the function.
	Name() string
	// Type returns the type of the function.
	Type() FunctionType
	// Arguments returns the arguments of the executor.
	Arguments() []string
	// Execute returns the executed value with the specified arguments.
	Execute(any) (any, error)
}

type ExecutorOption = execOption

type Function interface {
	// Name returns the function name.
	Name() string
	// IsName returns true whether the function name is the specified one.
	IsName(string) bool
	// Type returns the function type.
	Type() FunctionType
	// IsType returns true whether the function type is the specified one.
	IsType(FunctionType) bool
	// IsFunction returns true whether the function is a function.
	IsFunction() bool
	// Function returns the function if the function is a function.
	Function() (Function, bool)
	// Arguments returns the argument list.
	Arguments() Arguments
	// Executor returns the executor of the function.
	Executor(opts ...ExecutorOption) (Executor, error)
	// IsAggregator returns true if the function is an aggregator function.
	IsAggregator() bool
	// Aggregator returns the aggregator of the function.
	Aggregator(opts ...AggregatorOption) (Aggregator, error)
	// String returns a string representation of the function.
	String() string
	// SelectorHelper provides additional methods for selectors.
	SelectorHelper
}

type FunctionOption = func(*function)

type FunctionType int

type GroupBy string

type Map map[string]any

type MathFunc func([]float64) (any, error)

type MathResultSet map[any]float64

type Max struct {
	// contains filtered or unexported fields
}

type MaxOption = aggrOption

type Min struct {
	// contains filtered or unexported fields
}

type MinOption = aggrOption

type ResultSet interface {
	// Columns returns the column names.
	Columns() []string
	// Next returns the next row.
	Next() bool
	// Row returns the current row.
	Row() (Row, error)
	// Map returns the current row as a Map.
	Map() (Map, error)
}

type Row []any

type SelectorHelper interface {
	// IsAsterisk returns true wheher the selector is an asterisk.
	IsAsterisk() bool
	// IsFunction returns true whether the selector is a function.
	IsFunction() bool
}

type StringFunc func([]string) (any, error)

type Sum struct {
	// contains filtered or unexported fields
}

type SumOption = aggrOption

type TimeFunc func([]string) (any, error)