fakestoreadapter

Documentation

Index

• type FakeStoreAdapter
  • func New() *FakeStoreAdapter
  • func (adapter *FakeStoreAdapter) CompareAndDelete(nodes ...storeadapter.StoreNode) error
  • func (adapter *FakeStoreAdapter) CompareAndDeleteByIndex(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) DeleteLeaves(keys ...string) error
  • func (adapter *FakeStoreAdapter) Disconnect() error
  • func (adapter *FakeStoreAdapter) Get(key string) (storeadapter.StoreNode, error)
  • func (adapter *FakeStoreAdapter) GetMaintainedNodeName() string
  • 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
  • func NewFakeStoreAdapterErrorInjector(keyRegexp string, err error) *FakeStoreAdapterErrorInjector

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

	MaintainedNodeValue []byte
	MaintainNodeError   error
	MaintainNodeStatus  chan bool

	OnReleaseNodeChannel func(chan chan bool)

	sync.Mutex
	// contains filtered or unexported fields
}

func New

func New() *FakeStoreAdapter

func (*FakeStoreAdapter) CompareAndDelete

func (adapter *FakeStoreAdapter) CompareAndDelete(nodes ...storeadapter.StoreNode) error

func (*FakeStoreAdapter) CompareAndDeleteByIndex

func (adapter *FakeStoreAdapter) CompareAndDeleteByIndex(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) DeleteLeaves

func (adapter *FakeStoreAdapter) DeleteLeaves(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) GetMaintainedNodeName

func (adapter *FakeStoreAdapter) GetMaintainedNodeName() string

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

type FakeStoreAdapterErrorInjector struct {
	KeyRegexp *regexp.Regexp
	Error     error
}

func NewFakeStoreAdapterErrorInjector

func NewFakeStoreAdapterErrorInjector(keyRegexp string, err error) *FakeStoreAdapterErrorInjector