zk

Documentation

Index

• func RegisterResolver(scheme string, zkServers []string, registryDir, srvName, srvVersion string)
• type Config
• type Registrar
  • func NewRegistrar(conf *Config) (*Registrar, error)
  • func (r *Registrar) Close()
  • func (r *Registrar) Register(service *registry.ServiceInfo) error
  • func (r *Registrar) Unregister(service *registry.ServiceInfo)
• type Watcher
  • func (w *Watcher) Close()
  • func (w *Watcher) Watch() chan []resolver.Address

Functions

func RegisterResolver

func RegisterResolver(scheme string, zkServers []string, registryDir, srvName, srvVersion string)

Types

type Config

type Config struct {
	ZkServers      []string
	RegistryDir    string
	SessionTimeout time.Duration
}

type Registrar

type Registrar struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewRegistrar

func NewRegistrar(conf *Config) (*Registrar, error)

func (*Registrar) Close

func (r *Registrar) Close()

func (*Registrar) Register

func (r *Registrar) Register(service *registry.ServiceInfo) error

func (*Registrar) Unregister

func (r *Registrar) Unregister(service *registry.ServiceInfo)

type Watcher

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

Watcher watcher结构体

func (*Watcher) Close

func (w *Watcher) Close()

func (*Watcher) Watch

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