etcd

Documentation

Index

• type EtcdDiscoveryService
  • func NewDiscoveryService(healthCheck func() (bool, error)) (*EtcdDiscoveryService, error)
  • 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

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