gxzookeeper

Documentation

Overview

Package gxzookeeper provides a zookeeper registry

Package gxzookeeper provides a zookeeper watcher

Index

• Constants
• func NewRegistry(opts ...gxregistry.Option) (gxregistry.Registry, error)
• func NewWatcher(r gxregistry.Registry, opts ...gxregistry.WatchOption) (gxregistry.Watcher, error)
• type Registry
  • func (r *Registry) Client() *gxzookeeper.Client
  • func (r *Registry) Close() error
  • func (r *Registry) Deregister(s gxregistry.Service) error
  • func (r *Registry) Done() <-chan struct{}
  • 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

Constants

const (
	MAX_TIMES                   = 15 // 设置(wathcer)watchDir()等待时长
	Wactch_Event_Channel_Size   = 32 // 用于设置通知selector的event channel的size
	ZKCLIENT_EVENT_CHANNEL_SIZE = 4  // 设置用于zk client与watcher&consumer&provider之间沟通的channel的size
)

Functions

func NewRegistry

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

func NewWatcher

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

Types

type Registry

type Registry struct {
	sync.Mutex // lock for client + register
	// contains filtered or unexported fields
}

func (*Registry) Client

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

func (*Registry) Close

func (r *Registry) Close() error

func (*Registry) Deregister

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

func (*Registry) Done

func (r *Registry) Done() <-chan struct{}

check whether the session has been closed.

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.Mutex // lock path set

	sync.Once // for Close
	// contains filtered or unexported fields
}

watcher的watch系列函数暴露给zk 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