etcd

Documentation

Index

• func SetEtcdAddrs(li ...string) option
• func SetEtcdDialTimeout(t time.Duration) option
• func SetEtcdLeaseTTL(ttl int64) option
• func SetEtcdTimeoutFunc(f func()) option
• type EtcdAccess
  • func NewEtcdAccess(opts ...option) (result *EtcdAccess, err error)
  • func (this *EtcdAccess) Close()
  • func (this *EtcdAccess) Delete(key string) error
  • func (this *EtcdAccess) Get(key string) (result *mvccpb.KeyValue, err error)
  • func (this *EtcdAccess) GetPathAll(pathname string) (*clientv3.GetResponse, error)
  • func (this *EtcdAccess) Put(key, val string) error
  • func (this *EtcdAccess) PutForever(key, val string) error
  • func (this *EtcdAccess) PutNX(key, val string) error
  • func (this *EtcdAccess) RevokeLease(leaseid clientv3.LeaseID)
  • func (this *EtcdAccess) SetReFunc(fs ...reFunc)
  • func (this *EtcdAccess) Start()
  • func (this *EtcdAccess) WatchPrefix(pathname string, f func(md *clientv3.Event), loadall func(key string))

Functions

func SetEtcdAddrs

func SetEtcdAddrs(li ...string) option

设置ETCD地址

func SetEtcdDialTimeout

func SetEtcdDialTimeout(t time.Duration) option

设置超时时间

func SetEtcdLeaseTTL

func SetEtcdLeaseTTL(ttl int64) option

租约时间（秒）

func SetEtcdTimeoutFunc

func SetEtcdTimeoutFunc(f func()) option

设置，当发生自己注册信息丢失的回调

Types

type EtcdAccess

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

etcd的连接器

func NewEtcdAccess

func NewEtcdAccess(opts ...option) (result *EtcdAccess, err error)

func (*EtcdAccess) Close

func (this *EtcdAccess) Close()

func (*EtcdAccess) Delete

func (this *EtcdAccess) Delete(key string) error

删除数据

func (*EtcdAccess) Get

func (this *EtcdAccess) Get(key string) (result *mvccpb.KeyValue, err error)

获取一个KEY的数据

func (*EtcdAccess) GetPathAll

func (this *EtcdAccess) GetPathAll(pathname string) (*clientv3.GetResponse, error)

获取指定路径下的所有数据

func (*EtcdAccess) Put

func (this *EtcdAccess) Put(key, val string) error

写入数据

func (*EtcdAccess) PutForever

func (this *EtcdAccess) PutForever(key, val string) error

写入数据，永远

func (*EtcdAccess) PutNX

func (this *EtcdAccess) PutNX(key, val string) error

添加一个key，如果key不存在，则写入，如果key存在，则不写入，返回错误

func (*EtcdAccess) RevokeLease

func (this *EtcdAccess) RevokeLease(leaseid clientv3.LeaseID)

撤回指定Lease的Keep

func (*EtcdAccess) SetReFunc

func (this *EtcdAccess) SetReFunc(fs ...reFunc)

设置注册方法

func (*EtcdAccess) Start

func (this *EtcdAccess) Start()

func (*EtcdAccess) WatchPrefix

func (this *EtcdAccess) WatchPrefix(pathname string, f func(md *clientv3.Event), loadall func(key string))

监听某个目录，f方法为收到信息后的回调逻辑,回调新协程上