etcd

Documentation

Index

• type EtcdDriver
  • func NewEtcdDriver(config *clientv3.Config) (*EtcdDriver, error)
  • func (e *EtcdDriver) GetServiceNodeList(serviceName string) ([]*node.Node, error)
  • func (e *EtcdDriver) Ping() error
  • func (e *EtcdDriver) RegisterServiceNode(node *node.Node) (string, error)
  • func (e *EtcdDriver) SetHeartBeat(node *node.Node)
  • func (e *EtcdDriver) SetLogger(log dlog.Logger)
  • func (e *EtcdDriver) SetTimeout(timeout time.Duration)

Types

type EtcdDriver

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

func NewEtcdDriver

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

NewEtcdDriver ...

func (*EtcdDriver) GetServiceNodeList

func (e *EtcdDriver) GetServiceNodeList(serviceName string) ([]*node.Node, error)

GetServiceNodeList get service notes

func (*EtcdDriver) Ping

func (e *EtcdDriver) Ping() error

func (*EtcdDriver) RegisterServiceNode

func (e *EtcdDriver) RegisterServiceNode(node *node.Node) (string, error)

RegisterServiceNode register a node to service

func (*EtcdDriver) SetHeartBeat

func (e *EtcdDriver) SetHeartBeat(node *node.Node)

func (*EtcdDriver) SetLogger

func (e *EtcdDriver) SetLogger(log dlog.Logger)

func (*EtcdDriver) SetTimeout

func (e *EtcdDriver) SetTimeout(timeout time.Duration)

SetTimeout set etcd lease timeout