query

Dec 2, 2019

Changes in this version

type Entry

+ Size int

type Query

+ ReturnsSizes bool

Oct 1, 2019

Changes in this version

type FilterKeyCompare

+ func (f FilterKeyCompare) String() string

type FilterKeyPrefix

+ func (f FilterKeyPrefix) String() string

type FilterValueCompare

+ func (f FilterValueCompare) String() string

type OrderByFunction

+ func (OrderByFunction) String() string

type OrderByKey

+ func (OrderByKey) String() string

type OrderByKeyDescending

+ func (OrderByKeyDescending) String() string

type OrderByValue

+ func (OrderByValue) String() string

type OrderByValueDescending

+ func (OrderByValueDescending) String() string

type Query

+ func (q Query) String() string

Apr 19, 2019

Changes in this version

+ func Sort(orders []Order, entries []Entry)

Apr 9, 2019

Changes in this version

type Results

+ func ResultsWithProcess(q Query, proc func(goprocess.Process, chan<- Result)) Results

Mar 23, 2019

Changes in this version

+ func Less(orders []Order, a, b Entry) bool

Feb 28, 2019

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("!=")

+ type Entry struct

+ Expiration time.Time

+ Key string

+ 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

+ 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

+ Compare func(a, b Entry) int

+ type OrderByFunction func(a, b Entry) int

+ func (o OrderByFunction) Compare(a, b Entry) int

+ type OrderByKey struct

+ func (o OrderByKey) Compare(a, b Entry) int

+ type OrderByKeyDescending struct

+ func (o OrderByKeyDescending) Compare(a, b Entry) int

+ type OrderByValue struct

+ func (o OrderByValue) Compare(a, b Entry) int

+ type OrderByValueDescending struct

+ 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

+ 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, 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