kvdbproxy

Aug 28, 2018

Changes in this version

+ var DefaultPlugin = *NewPlugin()

+ type Deps struct

+ KVDB kvsyncDelegate

+ type KvdbsyncMock struct

+ func (kv *KvdbsyncMock) AddIgnoreEntry(key string, op datasync.Op)

+ func (kv *KvdbsyncMock) Delete(key string, opts ...datasync.DelOption) (existed bool, err error)

+ func (kv *KvdbsyncMock) Put(key string, data proto.Message, opts ...datasync.PutOption) error

+ func (kv *KvdbsyncMock) Watch(resyncName string, changeChan chan datasync.ChangeEvent, ...) (datasync.WatchRegistration, error)

+ type Option func(*Plugin)

+ func UseDeps(cb func(*Deps)) Option

+ type Plugin struct

+ func NewPlugin(opts ...Option) *Plugin

+ func (plugin *Plugin) AddIgnoreEntry(key string, op datasync.Op)

+ func (plugin *Plugin) Close() error

+ func (plugin *Plugin) DelIgnoreEntry(key string)

+ func (plugin *Plugin) Delete(key string, opts ...datasync.DelOption) (existed bool, err error)

+ func (plugin *Plugin) Init() error

+ func (plugin *Plugin) Put(key string, data proto.Message, opts ...datasync.PutOption) error

+ func (plugin *Plugin) Watch(resyncName string, changeChan chan datasync.ChangeEvent, ...) (datasync.WatchRegistration, error)

+ type Proxy interface

+ AddIgnoreEntry func(key string, op datasync.Op)

+ Delete func(key string, opts ...datasync.DelOption) (existed bool, err error)

+ Put func(key string, data proto.Message, opts ...datasync.PutOption) error

+ Watch func(resyncName string, changeChan chan datasync.ChangeEvent, ...) (datasync.WatchRegistration, error)

+ func NewKvdbsyncMock() Proxy