Documentation ¶
Index ¶
- type ZookeeperStoreAdapter
- func (adapter *ZookeeperStoreAdapter) Connect() error
- func (adapter *ZookeeperStoreAdapter) Create(node storeadapter.StoreNode) error
- func (adapter *ZookeeperStoreAdapter) Delete(keys ...string) error
- func (adapter *ZookeeperStoreAdapter) Disconnect() error
- func (adapter *ZookeeperStoreAdapter) Get(key string) (node storeadapter.StoreNode, err error)
- func (adapter *ZookeeperStoreAdapter) ListRecursively(key string) (storeadapter.StoreNode, error)
- func (adapter *ZookeeperStoreAdapter) MaintainNode(storeadapter.StoreNode) (lostNode <-chan bool, releaseNode chan chan bool, err error)
- func (adapter *ZookeeperStoreAdapter) SetMulti(nodes []storeadapter.StoreNode) error
- func (adapter *ZookeeperStoreAdapter) Update(node storeadapter.StoreNode) error
- func (adapter *ZookeeperStoreAdapter) UpdateDirTTL(key string, ttl uint64) error
- func (adapter *ZookeeperStoreAdapter) Watch(key string) (<-chan storeadapter.WatchEvent, chan<- bool, <-chan error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ZookeeperStoreAdapter ¶
type ZookeeperStoreAdapter struct {
// contains filtered or unexported fields
}
func NewZookeeperStoreAdapter ¶
func NewZookeeperStoreAdapter(urls []string, workerPool *workerpool.WorkerPool, timeProvider timeprovider.TimeProvider, connectionTimeout time.Duration) *ZookeeperStoreAdapter
func (*ZookeeperStoreAdapter) Connect ¶
func (adapter *ZookeeperStoreAdapter) Connect() error
func (*ZookeeperStoreAdapter) Create ¶
func (adapter *ZookeeperStoreAdapter) Create(node storeadapter.StoreNode) error
func (*ZookeeperStoreAdapter) Delete ¶
func (adapter *ZookeeperStoreAdapter) Delete(keys ...string) error
func (*ZookeeperStoreAdapter) Disconnect ¶
func (adapter *ZookeeperStoreAdapter) Disconnect() error
func (*ZookeeperStoreAdapter) Get ¶
func (adapter *ZookeeperStoreAdapter) Get(key string) (node storeadapter.StoreNode, err error)
func (*ZookeeperStoreAdapter) ListRecursively ¶
func (adapter *ZookeeperStoreAdapter) ListRecursively(key string) (storeadapter.StoreNode, error)
func (*ZookeeperStoreAdapter) MaintainNode ¶
func (adapter *ZookeeperStoreAdapter) MaintainNode(storeadapter.StoreNode) (lostNode <-chan bool, releaseNode chan chan bool, err error)
func (*ZookeeperStoreAdapter) SetMulti ¶
func (adapter *ZookeeperStoreAdapter) SetMulti(nodes []storeadapter.StoreNode) error
func (*ZookeeperStoreAdapter) Update ¶
func (adapter *ZookeeperStoreAdapter) Update(node storeadapter.StoreNode) error
func (*ZookeeperStoreAdapter) UpdateDirTTL ¶
func (adapter *ZookeeperStoreAdapter) UpdateDirTTL(key string, ttl uint64) error
func (*ZookeeperStoreAdapter) Watch ¶
func (adapter *ZookeeperStoreAdapter) Watch(key string) (<-chan storeadapter.WatchEvent, chan<- bool, <-chan error)
Click to show internal directories.
Click to hide internal directories.