etcd

Documentation

Index

• type Driver
  • func NewDriver(cli *clientv3.Client) (*Driver, error)
  • func NewEtcdDriver(config *clientv3.Config) (*Driver, error)
  • func (d *Driver) GetServiceNodeList(serviceName string) ([]string, error)
  • func (d *Driver) Ping() error
  • func (d *Driver) RegisterServiceNode(serviceName string) (string, error)
  • func (d *Driver) SetHeartBeat(nodeID string)
  • func (d *Driver) SetTimeout(timeout time.Duration)

Types

type Driver

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

func NewDriver

func NewDriver(cli *clientv3.Client) (*Driver, error)

NewDriver 新建etcd的驱动

func NewEtcdDriver

func NewEtcdDriver(config *clientv3.Config) (*Driver, error)

NewEtcdDriver ...

func (*Driver) GetServiceNodeList

func (d *Driver) GetServiceNodeList(serviceName string) ([]string, error)

GetServiceNodeList get service notes

func (*Driver) Ping

func (d *Driver) Ping() error

func (*Driver) RegisterServiceNode

func (d *Driver) RegisterServiceNode(serviceName string) (string, error)

RegisterServiceNode register a node to service

func (*Driver) SetHeartBeat

func (d *Driver) SetHeartBeat(nodeID string)

func (*Driver) SetTimeout

func (d *Driver) SetTimeout(timeout time.Duration)

SetTimeout set etcd lease timeout