etcd

Documentation

Index

• func Discovery(client *clientv3.Client, registryDir, srvName string) ([]resolver.Address, error)
• func RegisterResolver(scheme string, cli *clientv3.Client, registryDir, srvName string)
• type Option
• type Registry
  • func NewRegistry(client *clientv3.Client, option Option) *Registry
  • func (e *Registry) Register(stopCh <-chan struct{}) (err error)
  • func (e *Registry) UnRegister()
• type Watcher
  • func (w *Watcher) Close()
  • func (w *Watcher) GetAllAddresses() []resolver.Address
  • func (w *Watcher) Watch() chan []resolver.Address

Functions

func Discovery

func Discovery(client *clientv3.Client, registryDir, srvName string) ([]resolver.Address, error)

func RegisterResolver

func RegisterResolver(scheme string, cli *clientv3.Client, registryDir, srvName string)

Types

type Option

type Option struct {
	RegistryDir string
	ServiceName string
	ServiceAddr string
	ServiceData map[string]interface{}
	Ttl         time.Duration
}

type Registry

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

func NewRegistry

func NewRegistry(client *clientv3.Client, option Option) *Registry

func (*Registry) Register

func (e *Registry) Register(stopCh <-chan struct{}) (err error)

func (*Registry) UnRegister

func (e *Registry) UnRegister()

type Watcher

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

func (*Watcher) Close

func (w *Watcher) Close()

func (*Watcher) GetAllAddresses

func (w *Watcher) GetAllAddresses() []resolver.Address

func (*Watcher) Watch

func (w *Watcher) Watch() chan []resolver.Address