collection

Mar 27, 2018

Changes in this version

type ReadWriteCollection

+ TTL func(key string) (int64, error)

+ Update func(key string, val proto.Message, f func() error) error

+ Upsert func(key string, val proto.Message, f func() error) error

type ReadonlyCollection

+ ListPaginated func() (Iterator, error)

type STM

+ TTL func(key string) (int64, error)

Jan 11, 2018

Changes in this version

+ const QueryPaginationLimit

type ReadWriteCollection

+ DeleteAllPrefix func(prefix string)

type ReadonlyCollection

+ ListPrefix func(prefix string) (Iterator, error)

Dec 11, 2017

Changes in this version

type ReadonlyCollection

+ GetBlock func(key string, val proto.Unmarshaler) error

Oct 4, 2017

Changes in this version

+ func IsErrExists(e error) bool

+ func IsErrMalformedValue(e error) bool

+ func IsErrNotFound(e error) bool

Aug 2, 2017

Changes in this version

type ReadWriteCollection

+ PutTTL func(key string, val proto.Marshaler, ttl int64) error

type ReadonlyCollection

+ Count func() (int64, error)

Jul 7, 2017

Changes in this version

type Collection

+ Path func(string) string

type ReadWriteIntCollection

+ DecrementBy func(key string, n int) error

+ IncrementBy func(key string, n int) error

type ReadonlyCollection

+ WatchWithPrev func() (watch.Watcher, error)

Mar 29, 2017

Changes in this version

+ func NewSTM(ctx context.Context, c *v3.Client, apply func(STM) error) (*v3.TxnResponse, error)

+ type Collection interface

+ ReadOnly func(ctx context.Context) ReadonlyCollection

+ ReadWrite func(stm STM) ReadWriteCollection

+ ReadWriteInt func(stm STM) ReadWriteIntCollection

+ func NewCollection(etcdClient *etcd.Client, prefix string, indexes []Index, ...) Collection

+ type ErrExists struct

+ Key string

+ Type string

+ func (e ErrExists) Error() string

+ type ErrMalformedValue struct

+ Key string

+ Type string

+ Val string

+ func (e ErrMalformedValue) Error() string

+ type ErrNotFound struct

+ Key string

+ Type string

+ func (e ErrNotFound) Error() string

+ type Index struct

+ Field string

+ Multi bool

+ type Iterator interface

+ Next func(key *string, val proto.Message) (ok bool, retErr error)

+ type ReadWriteCollection interface

+ Create func(key string, val proto.Message) error

+ Delete func(key string) error

+ DeleteAll func()

+ Get func(key string, val proto.Message) error

+ Put func(key string, val proto.Message)

+ type ReadWriteIntCollection interface

+ Create func(key string, val int) error

+ Decrement func(key string) error

+ Delete func(key string) error

+ Get func(key string) (int, error)

+ Increment func(key string) error

+ type ReadonlyCollection interface

+ Get func(key string, val proto.Message) error

+ GetByIndex func(index Index, val interface{}) (Iterator, error)

+ List func() (Iterator, error)

+ Watch func() (watch.Watcher, error)

+ WatchByIndex func(index Index, val interface{}) (watch.Watcher, error)

+ WatchOne func(key string) (watch.Watcher, error)

+ type STM interface

+ Context func() context.Context

+ Del func(key string)

+ DelAll func(key string)

+ Get func(key string) string

+ Put func(key, val string, opts ...v3.OpOption)

+ Rev func(key string) int64