etcd

Documentation

Index

• type Observer
• type ServiceDiscovery
  • func NewServiceDiscovery(endpoints []string, format string, ipWeightList map[string]string) (*ServiceDiscovery, error)
  • 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
  • func NewServiceRegister(endpoints []string, leaseTTL int64) (*ServiceRegister, error)
  • func (service *ServiceRegister) Close() error
  • func (service *ServiceRegister) RegisterService(key, value string) error
  • func (service *ServiceRegister) RevokeService() error

Types

type Observer

type Observer interface {
	Update([]string)
}

type ServiceDiscovery

type ServiceDiscovery struct {
	// contains filtered or unexported fields
}

ServiceDiscovery 服务发现

func NewServiceDiscovery

func NewServiceDiscovery(endpoints []string, format string, ipWeightList map[string]string) (*ServiceDiscovery, error)

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

type ServiceRegister struct {
	Client *clientv3.Client
	// contains filtered or unexported fields
}

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