gxetcd

Documentation

Overview

Package gxetcd provides an etcd version 3 gxregistry

Package gxetcd provides an etcd version 3 gxregistry ref: https://github.com/micro/go-plugins/blob/master/gxregistry/etcdv3/etcdv3.go

Index

• func NewRegistry(opts ...gxregistry.Option) (gxregistry.Registry, error)
• func NewWatcher(client *gxetcd.Client, opts ...gxregistry.WatchOption) (gxregistry.Watcher, error)
• type Registry
  • 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
  • func (w *Watcher) Close()
  • func (w *Watcher) IsClosed() bool
  • func (w *Watcher) Notify() (*gxregistry.EventResult, error)
  • func (w *Watcher) Valid() bool

Functions

func NewRegistry

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

func NewWatcher

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

Types

type Registry

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

func (*Registry) Client

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

func (*Registry) Close

func (r *Registry) Close() error

func (*Registry) Deregister

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

func (*Registry) GetServices

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

func (*Registry) Options

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

func (*Registry) Register

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

func (*Registry) String

func (r *Registry) String() string

func (*Registry) Watch

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

type Watcher

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

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

func (*Watcher) Close

func (w *Watcher) Close()

func (*Watcher) IsClosed

func (w *Watcher) IsClosed() bool

check whether the session has been closed.

func (*Watcher) Notify

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

func (*Watcher) Valid

func (w *Watcher) Valid() bool