etcd

Jun 25, 2021

Changes in this version

+ func NewEtcd(timeout time.Duration, leaseTLL int64, config *clientv3.Config) error

+ type Action struct

+ Act namespace.WatcherAction

+ B map[string][]byte

+ type Etcd struct

+ var DefaultEtcd *Etcd

+ func (s *Etcd) Client() *clientv3.Client

+ func (s *Etcd) Close()

+ func (s *Etcd) Delete(key string) error

+ func (s *Etcd) GetWithKey(key string) ([]byte, error)

+ func (s *Etcd) GetWithLastKey(key string) ([]byte, error)

+ func (s *Etcd) GetWithList(key string, opts ...clientv3.OpOption) (map[string][]byte, error)

+ func (s *Etcd) Put(key, value string) error

+ func (s *Etcd) PutTimeout(key, value string, leaseTLL int64) error

+ func (s *Etcd) PutWithLease(key, value string) error

+ type Watch struct

+ func NewEtcdWatch(prefix string, client *clientv3.Client) *Watch

+ func (w *Watch) Close()

+ func (w *Watch) Watch(prefix string) chan *Action