Versions in this module Expand all Collapse all v1 v1.7.1 Jan 29, 2021 v1.7.0 Dec 8, 2020 v1.6.4 Sep 30, 2020 v1.6.3 Jun 9, 2020 v1.6.2 Jun 9, 2020 v1.6.1 Jun 8, 2020 v1.6.0 Jun 4, 2020 v1.5.1 Mar 17, 2020 v1.5.0 Mar 17, 2020 Changes in this version + const KeysOnlyBufSize + const NormalBufSize + const NotFetched + var Equal = Op("==") + var GreaterThan = Op(">") + var GreaterThanOrEqual = Op(">=") + var LessThan = Op("<") + var LessThanOrEqual = Op("<=") + var NotEqual = Op("!=") + type Entry struct + Key string + Value interface{} + func ResultEntriesFrom(keys []string, vals []interface{}) []Entry + type Filter interface + Filter func(e Entry) bool + type FilterKeyCompare struct + Key string + Op Op + func (f FilterKeyCompare) Filter(e Entry) bool + type FilterKeyPrefix struct + Prefix string + func (f FilterKeyPrefix) Filter(e Entry) bool + type FilterValueCompare struct + Op Op + TypedFilter Filter + Value interface{} + func (f FilterValueCompare) Filter(e Entry) bool + type Iterator struct + Close func() error + Next func() (Result, bool) + type Op string + type Order interface + Sort func([]Entry) + type OrderByKey struct + func (o OrderByKey) Sort(res []Entry) + type OrderByKeyDescending struct + func (o OrderByKeyDescending) Sort(res []Entry) + type OrderByValue struct + TypedOrder Order + func (o OrderByValue) Sort(res []Entry) + type OrderByValueDescending struct + TypedOrder Order + func (o OrderByValueDescending) Sort(res []Entry) + type Query struct + Filters []Filter + KeysOnly bool + Limit int + Offset int + Orders []Order + Prefix 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 DerivedResults(qr Results, ch <-chan Result) Results + 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, o 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