index

type CompositePostingValueFn = func(term, value []byte, delegated kv.Iterator) (*PostingValue, error)

type Field struct {
	Key  FieldKey
	Term []byte
}

type FieldIterable interface {
	Iterator(fieldKey FieldKey, termRange RangeOpts, order modelv1.Sort) (iter FieldIterator, err error)
}

type FieldIterator interface {
	Next() bool
	Val() *PostingValue
	Close() error
}

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

type FieldKey struct {
	SeriesID    common.SeriesID
	IndexRuleID uint32
	Analyzer    databasev1.IndexRule_Analyzer
}

type Filter interface {
	fmt.Stringer
	Execute(getSearcher GetSearcher, seriesID common.SeriesID) (posting.List, error)
}

type GetSearcher func(location databasev1.IndexRule_Type) (Searcher, error)

type PostingValue struct {
	Term  []byte
	Value posting.List
}

type RangeOpts struct {
	Upper         []byte
	Lower         []byte
	IncludesUpper bool
	IncludesLower bool
}

type Searcher interface {
	FieldIterable
	Match(fieldKey FieldKey, match []string) (list posting.List, err error)
	MatchField(fieldKey FieldKey) (list posting.List, err error)
	MatchTerms(field Field) (list posting.List, err error)
	Range(fieldKey FieldKey, opts RangeOpts) (list posting.List, err error)
}

type Store interface {
	observability.Observable
	io.Closer
	Writer
	Searcher
	// Flush flushed memory data to disk
	Flush() error
}

type SwitchFn = func(a, b []byte) bool

type Writer interface {
	Write(fields []Field, itemID common.ItemID) error
}