Documentation ¶
Index ¶
- type FakeStoreAdapter
- func (adapter *FakeStoreAdapter) CompareAndDelete(node storeadapter.StoreNode) error
- func (adapter *FakeStoreAdapter) CompareAndSwap(oldNode storeadapter.StoreNode, newNode storeadapter.StoreNode) error
- func (adapter *FakeStoreAdapter) CompareAndSwapByIndex(oldNodeIndex uint64, newNode storeadapter.StoreNode) error
- func (adapter *FakeStoreAdapter) Connect() error
- func (adapter *FakeStoreAdapter) Create(node storeadapter.StoreNode) error
- func (adapter *FakeStoreAdapter) Delete(keys ...string) error
- func (adapter *FakeStoreAdapter) Disconnect() error
- func (adapter *FakeStoreAdapter) Get(key string) (storeadapter.StoreNode, error)
- func (adapter *FakeStoreAdapter) ListRecursively(key string) (storeadapter.StoreNode, error)
- func (adapter *FakeStoreAdapter) MaintainNode(storeNode storeadapter.StoreNode) (status <-chan bool, releaseNode chan chan bool, err error)
- func (adapter *FakeStoreAdapter) Reset()
- func (adapter *FakeStoreAdapter) SetMulti(nodes []storeadapter.StoreNode) error
- func (adapter *FakeStoreAdapter) Update(node storeadapter.StoreNode) error
- func (adapter *FakeStoreAdapter) UpdateDirTTL(key string, ttl uint64) error
- func (adapter *FakeStoreAdapter) Watch(key string) (events <-chan storeadapter.WatchEvent, stop chan<- bool, errors <-chan error)
- type FakeStoreAdapterErrorInjector
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FakeStoreAdapter ¶
type FakeStoreAdapter struct { DidConnect bool DidDisconnect bool ConnectErr error DisconnectErr error SetErrInjector *FakeStoreAdapterErrorInjector GetErrInjector *FakeStoreAdapterErrorInjector ListErrInjector *FakeStoreAdapterErrorInjector DeleteErrInjector *FakeStoreAdapterErrorInjector CreateErrInjector *FakeStoreAdapterErrorInjector WatchErrChannel chan error MaintainedNodeName string MaintainedNodeValue []byte MaintainNodeError error MaintainNodeStatus chan bool ReleaseNodeChannel chan chan bool *sync.Mutex // contains filtered or unexported fields }
func New ¶
func New() *FakeStoreAdapter
func (*FakeStoreAdapter) CompareAndDelete ¶
func (adapter *FakeStoreAdapter) CompareAndDelete(node storeadapter.StoreNode) error
func (*FakeStoreAdapter) CompareAndSwap ¶
func (adapter *FakeStoreAdapter) CompareAndSwap(oldNode storeadapter.StoreNode, newNode storeadapter.StoreNode) error
func (*FakeStoreAdapter) CompareAndSwapByIndex ¶
func (adapter *FakeStoreAdapter) CompareAndSwapByIndex(oldNodeIndex uint64, newNode storeadapter.StoreNode) error
func (*FakeStoreAdapter) Connect ¶
func (adapter *FakeStoreAdapter) Connect() error
func (*FakeStoreAdapter) Create ¶
func (adapter *FakeStoreAdapter) Create(node storeadapter.StoreNode) error
func (*FakeStoreAdapter) Delete ¶
func (adapter *FakeStoreAdapter) Delete(keys ...string) error
func (*FakeStoreAdapter) Disconnect ¶
func (adapter *FakeStoreAdapter) Disconnect() error
func (*FakeStoreAdapter) Get ¶
func (adapter *FakeStoreAdapter) Get(key string) (storeadapter.StoreNode, error)
func (*FakeStoreAdapter) ListRecursively ¶
func (adapter *FakeStoreAdapter) ListRecursively(key string) (storeadapter.StoreNode, error)
func (*FakeStoreAdapter) MaintainNode ¶
func (adapter *FakeStoreAdapter) MaintainNode(storeNode storeadapter.StoreNode) (status <-chan bool, releaseNode chan chan bool, err error)
func (*FakeStoreAdapter) Reset ¶
func (adapter *FakeStoreAdapter) Reset()
func (*FakeStoreAdapter) SetMulti ¶
func (adapter *FakeStoreAdapter) SetMulti(nodes []storeadapter.StoreNode) error
func (*FakeStoreAdapter) Update ¶
func (adapter *FakeStoreAdapter) Update(node storeadapter.StoreNode) error
func (*FakeStoreAdapter) UpdateDirTTL ¶
func (adapter *FakeStoreAdapter) UpdateDirTTL(key string, ttl uint64) error
func (*FakeStoreAdapter) Watch ¶
func (adapter *FakeStoreAdapter) Watch(key string) (events <-chan storeadapter.WatchEvent, stop chan<- bool, errors <-chan error)
type FakeStoreAdapterErrorInjector ¶
func NewFakeStoreAdapterErrorInjector ¶
func NewFakeStoreAdapterErrorInjector(keyRegexp string, err error) *FakeStoreAdapterErrorInjector
Click to show internal directories.
Click to hide internal directories.