Versions in this module Expand all Collapse all v0 v0.0.3 Dec 16, 2024 Changes in this version + var RegexMatch = Op("matches") v0.0.2 Aug 21, 2021 Changes in this version + const KeysOnlyBufSize + const NormalBufSize + var Equal = Op("==") + var GreaterThan = Op(">") + var GreaterThanOrEqual = Op(">=") + var LessThan = Op("<") + var LessThanOrEqual = Op("<=") + var NotEqual = Op("!=") + func Less(orders []Order, a, b Entry) bool + func Sort(orders []Order, entries []Entry) + type Entry struct + Expiration time.Time + Key string + Size int + Value []byte + func ResultEntriesFrom(keys []string, vals [][]byte) []Entry + type Filter interface + Filter func(e Entry) bool + type FilterKeyCompare struct + Key string + Op Op + func (f FilterKeyCompare) Filter(e Entry) bool + func (f FilterKeyCompare) String() string + type FilterKeyPrefix struct + Prefix string + func (f FilterKeyPrefix) Filter(e Entry) bool + func (f FilterKeyPrefix) String() string + type FilterValueCompare struct + Op Op + Value []byte + func (f FilterValueCompare) Filter(e Entry) bool + func (f FilterValueCompare) String() string + type Iterator struct + Close func() error + Next func() (Result, bool) + type Op string + type Order interface + Compare func(a, b Entry) int + type OrderByFunction func(a, b Entry) int + func (OrderByFunction) String() string + func (o OrderByFunction) Compare(a, b Entry) int + type OrderByKey struct + func (OrderByKey) String() string + func (o OrderByKey) Compare(a, b Entry) int + type OrderByKeyDescending struct + func (OrderByKeyDescending) String() string + func (o OrderByKeyDescending) Compare(a, b Entry) int + type OrderByValue struct + func (OrderByValue) String() string + func (o OrderByValue) Compare(a, b Entry) int + type OrderByValueDescending struct + func (OrderByValueDescending) String() string + func (o OrderByValueDescending) Compare(a, b Entry) int + type Query struct + Filters []Filter + KeysOnly bool + Limit int + Offset int + Orders []Order + Prefix string + ReturnExpirations bool + ReturnsSizes bool + func (q Query) String() string + type Result struct + Error error + type ResultBuilder struct + Output chan Result + Process goprocess.Process + Query Query + func NewResultBuilder(q Query) *ResultBuilder + func (rb *ResultBuilder) Results() Results + type Results interface + Close func() error + Next func() <-chan Result + NextSync func() (Result, bool) + Process func() goprocess.Process + Query func() Query + Rest func() ([]Entry, error) + func NaiveFilter(qr Results, filter Filter) Results + func NaiveLimit(qr Results, limit int) Results + func NaiveOffset(qr Results, offset int) Results + func NaiveOrder(qr Results, orders ...Order) Results + func NaiveQueryApply(q Query, qr Results) Results + func ResultsFromIterator(q Query, iter Iterator) Results + func ResultsReplaceQuery(r Results, q Query) Results + func ResultsWithChan(q Query, res <-chan Result) Results + func ResultsWithEntries(q Query, res []Entry) Results + func ResultsWithProcess(q Query, proc func(goprocess.Process, chan<- Result)) Results
Go to main page