etcd

Documentation

Index

• type Etcd
  • func NewEtcd(addr string) (*Etcd, error)
  • func (e *Etcd) Close()
  • func (e *Etcd) GetPrefix(prefix string) (ret []string, err error)
  • func (e *Etcd) NewWatcher() clientv3.Watcher
  • func (e *Etcd) RegistAndKeepAlive(k, value string) error
  • func (e *Etcd) WatchPrefixAndBlock(prefix string, closeCh chan struct{}, fn func())

Types

type Etcd

type Etcd struct {
	*clientv3.Client

	LeaseID clientv3.LeaseID
	// contains filtered or unexported fields
}

func NewEtcd

func NewEtcd(addr string) (*Etcd, error)

func (*Etcd) Close

func (e *Etcd) Close()

func (*Etcd) GetPrefix

func (e *Etcd) GetPrefix(prefix string) (ret []string, err error)

func (*Etcd) NewWatcher

func (e *Etcd) NewWatcher() clientv3.Watcher

func (*Etcd) RegistAndKeepAlive

func (e *Etcd) RegistAndKeepAlive(k, value string) error

func (*Etcd) WatchPrefixAndBlock

func (e *Etcd) WatchPrefixAndBlock(prefix string, closeCh chan struct{}, fn func())