storage

Jul 6, 2017

Changes in this version

+ const AlreadyExists

May 19, 2017

Changes in this version

+ const NotFound

+ type Error string

+ func (e Error) Error() string

+ type UpdateFunc func(current proto.Message) (updated proto.Message, err error)

Dec 20, 2016

Changes in this version

type Interface

+ Put func(ctx context.Context, key string, val proto.Message, ttl int64) error

Oct 12, 2016

Changes in this version

+ type Event struct

+ Error error

+ IsCreated bool

+ IsDeleted bool

+ IsError bool

+ Key string

+ Revision int64

+ Value []byte

+ type Filter interface

+ Filter func(val proto.Message) bool

+ var Everything Filter = everything{}

+ type Interface interface

+ Close func() error

+ CompareAndSet func(ctx context.Context, key string, expect proto.Message, update proto.Message) error

+ Connect func(timeout time.Duration) error

+ Create func(ctx context.Context, key string, val proto.Message, out proto.Message, ...) error

+ Delete func(ctx context.Context, key string, recurse bool, out proto.Message) error

+ Endpoints func() []string

+ Get func(ctx context.Context, key string, out proto.Message, ignoreNotFound bool) error

+ List func(ctx context.Context, key string, filter Filter, obj proto.Message, ...) error

+ Update func(ctx context.Context, key string, val proto.Message, ttl int64) error

+ Watch func(ctx context.Context, key string, resourceVersion int64, filter Filter) (WatchInterface, error)

+ WatchList func(ctx context.Context, key string, resourceVersion int64, filter Filter) (WatchInterface, error)

+ type WatchInterface interface

+ ResultChan func() <-chan Event

+ Stop func()