processor

type AggBin[T comparable] struct {
	MID    seq.MID
	Source T
}

type AggLimits struct {
	// MaxFieldTokens max AggQuery.Field uniq values to parse.
	MaxFieldTokens int
	// MaxGroupTokens max AggQuery.GroupBy unique values.
	MaxGroupTokens int
	// MaxTIDsPerFraction max number of tokens per fraction.
	MaxTIDsPerFraction int
}

type AggQuery struct {
	Field     *parser.Literal
	GroupBy   *parser.Literal
	Func      seq.AggFunc
	Quantiles []float64
	Interval  int64
}

type Aggregator interface {
	// Next iterates to count the next lid.
	Next(lid uint32) error
	// Aggregate processes and returns the final aggregation result.
	Aggregate() (seq.AggregatableSamples, error)
}

type ExtractMIDFunc func(seq.LID) seq.MID

type SearchParams struct {
	AST *parser.ASTNode `json:"-"`

	AggQ         []AggQuery
	HistInterval uint64

	From  seq.MID
	To    seq.MID
	Limit int

	WithTotal bool
	Order     seq.DocsOrder
}

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

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

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

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

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