Documentation
¶
Index ¶
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) 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) SetNodeId ¶
func (this *EtcdDiscovery) SetNodeId(nodeId string)
SetNodeId sets a nodeId
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.