Documentation ¶
Index ¶
- func New(addrs []string, options *store.Config) (store.Store, error)
- func Register()
- type EtcdV3
- func (s *EtcdV3) AtomicDelete(key string, previous *store.KVPair) (bool, error)
- func (s *EtcdV3) AtomicPut(key string, value []byte, previous *store.KVPair, opts *store.WriteOptions) (bool, *store.KVPair, error)
- func (s *EtcdV3) Close()
- func (s *EtcdV3) Delete(key string) error
- func (s *EtcdV3) DeleteTree(directory string) error
- func (s *EtcdV3) Exists(key string, opts *store.ReadOptions) (bool, error)
- func (s *EtcdV3) Get(key string, opts *store.ReadOptions) (pair *store.KVPair, err error)
- func (s *EtcdV3) List(directory string, opts *store.ReadOptions) ([]*store.KVPair, error)
- func (s *EtcdV3) NewLock(key string, options *store.LockOptions) (lock store.Locker, err error)
- func (s *EtcdV3) Put(key string, value []byte, opts *store.WriteOptions) (err error)
- func (s *EtcdV3) Watch(key string, stopCh <-chan struct{}, opts *store.ReadOptions) (<-chan *store.KVPair, error)
- func (s *EtcdV3) WatchTree(directory string, stopCh <-chan struct{}, opts *store.ReadOptions) (<-chan []*store.KVPair, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type EtcdV3 ¶
type EtcdV3 struct {
// contains filtered or unexported fields
}
EtcdV3 is the receiver type for the Store interface
func (*EtcdV3) AtomicDelete ¶
AtomicDelete deletes a value at "key" if the key has not been modified in the meantime, throws an error if this is the case
func (*EtcdV3) AtomicPut ¶
func (s *EtcdV3) AtomicPut(key string, value []byte, previous *store.KVPair, opts *store.WriteOptions) (bool, *store.KVPair, error)
AtomicPut puts a value at "key" if the key has not been modified in the meantime, throws an error if this is the case
func (*EtcdV3) DeleteTree ¶
DeleteTree deletes a range of keys under a given directory
func (*EtcdV3) Get ¶
Get the value at "key", returns the last modified index to use in conjunction to Atomic calls
func (*EtcdV3) NewLock ¶
NewLock returns a handle to a lock struct which can be used to provide mutual exclusion on a key
func (*EtcdV3) Watch ¶
func (s *EtcdV3) Watch(key string, stopCh <-chan struct{}, opts *store.ReadOptions) (<-chan *store.KVPair, error)
Watch for changes on a "key" It returns a channel that will receive changes or pass on errors. Upon creation, the current value will first be sent to the channel. Providing a non-nil stopCh can be used to stop watching.
func (*EtcdV3) WatchTree ¶
func (s *EtcdV3) WatchTree(directory string, stopCh <-chan struct{}, opts *store.ReadOptions) (<-chan []*store.KVPair, error)
WatchTree watches for changes on a "directory" It returns a channel that will receive changes or pass on errors. Upon creating a watch, the current childs values will be sent to the channel. Providing a non-nil stopCh can be used to stop watching.