index

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

type Condition map[FieldKey][]ConditionValue

type ConditionValue struct {
	Values [][]byte
	Op     modelv1.Condition_BinaryOp
}

type Executor interface {
	Execute() (posting.List, 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
	EncodeTerm  bool
}

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

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

type Searcher interface {
	FieldIterable
	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 Tree interface {
	Executor
	TrimRangeLeaf(key FieldKey) (rangeOpts RangeOpts, found bool)
}

type Writer interface {
	Write(field Field, itemID common.ItemID) error
}