watcher2

Documentation

Index

• type ClientWatcher
  • func NewClientWatcher(registryDir, serviceName string, cfg etcd3.Config, ...) (watcher *ClientWatcher, err error)
  • func (m *ClientWatcher) WatchClients(cb func(etype, addr string))

Types

type ClientWatcher

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

TODO(@benqi): grpc_util/serviec_discovery集成

func NewClientWatcher

func NewClientWatcher(registryDir, serviceName string, cfg etcd3.Config, client *net2.TcpClientGroupManager) (watcher *ClientWatcher, err error)

func (*ClientWatcher) WatchClients

func (m *ClientWatcher) WatchClients(cb func(etype, addr string))