etcdstoreadapter

Documentation

Index

• type ETCDStoreAdapter
  • func NewETCDStoreAdapter(urls []string, workerPool *workerpool.WorkerPool) *ETCDStoreAdapter
  • func (adapter *ETCDStoreAdapter) CompareAndDelete(node storeadapter.StoreNode) error
  • func (adapter *ETCDStoreAdapter) CompareAndSwap(oldNode storeadapter.StoreNode, newNode storeadapter.StoreNode) error
  • func (adapter *ETCDStoreAdapter) CompareAndSwapByIndex(oldNodeIndex uint64, newNode storeadapter.StoreNode) error
  • func (adapter *ETCDStoreAdapter) Connect() error
  • func (adapter *ETCDStoreAdapter) Create(node storeadapter.StoreNode) error
  • func (adapter *ETCDStoreAdapter) Delete(keys ...string) error
  • func (adapter *ETCDStoreAdapter) DeleteLeaves(keys ...string) error
  • func (adapter *ETCDStoreAdapter) Disconnect() error
  • func (adapter *ETCDStoreAdapter) Get(key string) (storeadapter.StoreNode, error)
  • func (adapter *ETCDStoreAdapter) ListRecursively(key string) (storeadapter.StoreNode, error)
  • func (adapter *ETCDStoreAdapter) MaintainNode(storeNode storeadapter.StoreNode) (<-chan bool, chan (chan bool), error)
  • func (adapter *ETCDStoreAdapter) SetMulti(nodes []storeadapter.StoreNode) error
  • func (adapter *ETCDStoreAdapter) Update(node storeadapter.StoreNode) error
  • func (adapter *ETCDStoreAdapter) UpdateDirTTL(key string, ttl uint64) error
  • func (adapter *ETCDStoreAdapter) Watch(key string) (<-chan storeadapter.WatchEvent, chan<- bool, <-chan error)

Types

type ETCDStoreAdapter

type ETCDStoreAdapter struct {
	// contains filtered or unexported fields
}

func NewETCDStoreAdapter

func NewETCDStoreAdapter(urls []string, workerPool *workerpool.WorkerPool) *ETCDStoreAdapter

func (*ETCDStoreAdapter) CompareAndDelete

func (adapter *ETCDStoreAdapter) CompareAndDelete(node storeadapter.StoreNode) error

func (*ETCDStoreAdapter) CompareAndSwap

func (adapter *ETCDStoreAdapter) CompareAndSwap(oldNode storeadapter.StoreNode, newNode storeadapter.StoreNode) error

func (*ETCDStoreAdapter) CompareAndSwapByIndex

func (adapter *ETCDStoreAdapter) CompareAndSwapByIndex(oldNodeIndex uint64, newNode storeadapter.StoreNode) error

func (*ETCDStoreAdapter) Connect

func (adapter *ETCDStoreAdapter) Connect() error

func (*ETCDStoreAdapter) Create

func (adapter *ETCDStoreAdapter) Create(node storeadapter.StoreNode) error

func (*ETCDStoreAdapter) Delete

func (adapter *ETCDStoreAdapter) Delete(keys ...string) error

func (*ETCDStoreAdapter) DeleteLeaves

func (adapter *ETCDStoreAdapter) DeleteLeaves(keys ...string) error

func (*ETCDStoreAdapter) Disconnect

func (adapter *ETCDStoreAdapter) Disconnect() error

func (*ETCDStoreAdapter) Get

func (adapter *ETCDStoreAdapter) Get(key string) (storeadapter.StoreNode, error)

func (*ETCDStoreAdapter) ListRecursively

func (adapter *ETCDStoreAdapter) ListRecursively(key string) (storeadapter.StoreNode, error)

func (*ETCDStoreAdapter) MaintainNode

func (adapter *ETCDStoreAdapter) MaintainNode(storeNode storeadapter.StoreNode) (<-chan bool, chan (chan bool), error)

func (*ETCDStoreAdapter) SetMulti

func (adapter *ETCDStoreAdapter) SetMulti(nodes []storeadapter.StoreNode) error

func (*ETCDStoreAdapter) Update

func (adapter *ETCDStoreAdapter) Update(node storeadapter.StoreNode) error

func (*ETCDStoreAdapter) UpdateDirTTL

func (adapter *ETCDStoreAdapter) UpdateDirTTL(key string, ttl uint64) error

func (*ETCDStoreAdapter) Watch

func (adapter *ETCDStoreAdapter) Watch(key string) (<-chan storeadapter.WatchEvent, chan<- bool, <-chan error)