Documentation
¶
Index ¶
- type EtcdDiscovery
- func (s *EtcdDiscovery) Close() error
- func (s *EtcdDiscovery) GetServerList() (map[string]string, error)
- func (s *EtcdDiscovery) ListenLeaseRespChan()
- func (s *EtcdDiscovery) Register() error
- func (this *EtcdDiscovery) SetNodeAddr(nodeAddr string)
- func (s *EtcdDiscovery) WatchService(watchChan discovery.WatchChan)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EtcdDiscovery ¶
type EtcdDiscovery struct {
discovery.ServiceDiscovery
// contains filtered or unexported fields
}
EtcdDiscovery
func NewEtcdDiscovery ¶
func NewEtcdDiscovery(conf clientv3.Config) *EtcdDiscovery
NewEtcdDiscovery return a EtcdDiscovery
func (*EtcdDiscovery) GetServerList ¶ added in v1.0.1
func (s *EtcdDiscovery) GetServerList() (map[string]string, error)
func (*EtcdDiscovery) ListenLeaseRespChan ¶
func (s *EtcdDiscovery) ListenLeaseRespChan()
ListenLeaseRespChan Monitor lease renewals
func (*EtcdDiscovery) Register ¶
func (s *EtcdDiscovery) Register() error
Register registers the nodeId and notify other nodes
func (*EtcdDiscovery) SetNodeAddr ¶ added in v1.0.1
func (this *EtcdDiscovery) SetNodeAddr(nodeAddr string)
SetNodeAddr sets a nodeAddr
func (*EtcdDiscovery) WatchService ¶
func (s *EtcdDiscovery) WatchService(watchChan discovery.WatchChan)
WatchService Listens for a new node to start
Source Files
Click to show internal directories.
Click to hide internal directories.