zookeeper

Documentation

Index

• type ZkManager
  • func NewZkManager(hosts []string) *ZkManager
  • func (z *ZkManager) Close()
  • func (z *ZkManager) GetConnect() error
  • func (z *ZkManager) GetPathData(nodePath string) ([]byte, *zk.Stat, error)
  • func (z *ZkManager) GetServerListByPath(path string) (list []string, err error)
  • func (z *ZkManager) RegistServerPath(nodePath, host string) (err error)
  • func (z *ZkManager) SetPathData(nodePath string, config []byte, version int32) (err error)
  • func (z *ZkManager) WatchPathData(nodePath string) (chan []byte, chan error)
  • func (z *ZkManager) WatchServerListByPath(path string) (chan []string, chan error)

Types

type ZkManager

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

func NewZkManager

func NewZkManager(hosts []string) *ZkManager

func (*ZkManager) Close

func (z *ZkManager) Close()

关闭服务

func (*ZkManager) GetConnect

func (z *ZkManager) GetConnect() error

连接zk服务器

func (*ZkManager) GetPathData

func (z *ZkManager) GetPathData(nodePath string) ([]byte, *zk.Stat, error)

获取配置

func (*ZkManager) GetServerListByPath

func (z *ZkManager) GetServerListByPath(path string) (list []string, err error)

获取服务列表

func (*ZkManager) RegistServerPath

func (z *ZkManager) RegistServerPath(nodePath, host string) (err error)

创建临时节点

func (*ZkManager) SetPathData

func (z *ZkManager) SetPathData(nodePath string, config []byte, version int32) (err error)

更新配置

func (*ZkManager) WatchPathData

func (z *ZkManager) WatchPathData(nodePath string) (chan []byte, chan error)

watch机制，监听节点值变化

func (*ZkManager) WatchServerListByPath

func (z *ZkManager) WatchServerListByPath(path string) (chan []string, chan error)

watch机制，服务器有断开或者重连，收到消息