gxetcd

package

v0.3.3 Latest Latest Go to latest Published: Dec 9, 2020 License: Apache-2.0 Imports: 10 Imported by: 1

Details

Package gxetcd provides an etcd version 3 gxregistry

This section is empty.

This section is empty.

func NewRegistry(opts ...gxregistry.Option) (gxregistry.Registry, error)

func NewWatcher(client *gxetcd.Client, opts ...gxregistry.WatchOption) (gxregistry.Watcher, error)

type Registry struct {
	sync.Mutex
	sync.Once
	// contains filtered or unexported fields
}

func (r *Registry) Client() *gxetcd.Client

func (r *Registry) Close() error

func (r *Registry) Deregister(s gxregistry.Service) error

func (r *Registry) GetServices(attr gxregistry.ServiceAttr) ([]gxregistry.Service, error)

func (r *Registry) Options() gxregistry.Options

func (r *Registry) Register(s gxregistry.Service) error

func (r *Registry) String() string

func (r *Registry) Watch(opts ...gxregistry.WatchOption) (gxregistry.Watcher, error)

type Watcher struct {
	sync.Once // for Close
	// contains filtered or unexported fields
}

watcher的watch系列函数暴露给registry，而Next函数则暴露给selector

func (w *Watcher) Close()

func (w *Watcher) IsClosed() bool

check whether the session has been closed.

func (w *Watcher) Notify() (*gxregistry.EventResult, error)

func (w *Watcher) Valid() bool