Documentation
¶
Index ¶
- type EtcdDiscoveryService
- func (service *EtcdDiscoveryService) AddNodeListUpdated(key string, sub chan []taskhandler.ServingService)
- func (service *EtcdDiscoveryService) RegisterService() error
- func (service *EtcdDiscoveryService) RemoveNodeListUpdated(key string)
- func (service *EtcdDiscoveryService) UnregisterService() error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EtcdDiscoveryService ¶
type EtcdDiscoveryService struct {
ListUpdatedChans map[string]chan []taskhandler.ServingService
ServiceName string
ServiceId string
EtcdClient *clientv3.Client
HealthCheckFun func() (bool, error)
// contains filtered or unexported fields
}
func NewDiscoveryService ¶
func NewDiscoveryService(healthCheck func() (bool, error)) (*EtcdDiscoveryService, error)
func (*EtcdDiscoveryService) AddNodeListUpdated ¶
func (service *EtcdDiscoveryService) AddNodeListUpdated(key string, sub chan []taskhandler.ServingService)
func (*EtcdDiscoveryService) RegisterService ¶
func (service *EtcdDiscoveryService) RegisterService() error
func (*EtcdDiscoveryService) RemoveNodeListUpdated ¶
func (service *EtcdDiscoveryService) RemoveNodeListUpdated(key string)
func (*EtcdDiscoveryService) UnregisterService ¶
func (service *EtcdDiscoveryService) UnregisterService() error
Source Files
Click to show internal directories.
Click to hide internal directories.