Documentation ¶
Index ¶
- type Observer
- type ServiceDiscovery
- func (discovery *ServiceDiscovery) AddObserver(observer Observer)
- func (discovery *ServiceDiscovery) Close() error
- func (discovery *ServiceDiscovery) DelServiceList(key string)
- func (discovery *ServiceDiscovery) GetServiceList() []string
- func (discovery *ServiceDiscovery) SetServiceList(key, value string)
- func (discovery *ServiceDiscovery) WatchService(prefix string) ([]string, error)
- type ServiceRegister
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ServiceDiscovery ¶
type ServiceDiscovery struct {
// contains filtered or unexported fields
}
ServiceDiscovery 服务发现
func NewServiceDiscovery ¶
func (*ServiceDiscovery) AddObserver ¶
func (discovery *ServiceDiscovery) AddObserver(observer Observer)
func (*ServiceDiscovery) Close ¶
func (discovery *ServiceDiscovery) Close() error
func (*ServiceDiscovery) DelServiceList ¶
func (discovery *ServiceDiscovery) DelServiceList(key string)
func (*ServiceDiscovery) GetServiceList ¶
func (discovery *ServiceDiscovery) GetServiceList() []string
func (*ServiceDiscovery) SetServiceList ¶
func (discovery *ServiceDiscovery) SetServiceList(key, value string)
func (*ServiceDiscovery) WatchService ¶
func (discovery *ServiceDiscovery) WatchService(prefix string) ([]string, error)
WatchService 首次初始化本地的服务列表+后续监听相同前缀的服务列表
type ServiceRegister ¶
ServiceRegister 服务注册
func NewServiceRegister ¶
func NewServiceRegister(endpoints []string, leaseTTL int64) (*ServiceRegister, error)
func (*ServiceRegister) Close ¶
func (service *ServiceRegister) Close() error
func (*ServiceRegister) RegisterService ¶
func (service *ServiceRegister) RegisterService(key, value string) error
func (*ServiceRegister) RevokeService ¶
func (service *ServiceRegister) RevokeService() error
Click to show internal directories.
Click to hide internal directories.