zookeeper

Documentation

Index

• Variables
• type Config
• type Info
• type NodeEvent
• type NodeInfo
• type StatInfo
  • func StatToInfo(stat *zk.Stat) (info *StatInfo)
• type WatchChildrenListenData
• type ZKService
  • func New(config Config) (service *ZKService, err error)
  • func (this_ *ZKService) Create(path string, data []byte, mode int32) (err error)
  • func (this_ *ZKService) CreateIfNotExists(path string, data []byte) (err error)
  • func (this_ *ZKService) Delete(path string) (err error)
  • func (this_ *ZKService) Exists(path string) (isExist bool, err error)
  • func (this_ *ZKService) Get(path string) (info *NodeInfo, err error)
  • func (this_ *ZKService) GetChildren(path string) (children []string, err error)
  • func (this_ *ZKService) GetConn() *zk.Conn
  • func (this_ *ZKService) GetServers() []string
  • func (this_ *ZKService) Info() (info *Info, err error)
  • func (this_ *ZKService) Set(path string, data []byte) (err error)
  • func (this_ *ZKService) Stat(path string) (info *StatInfo, err error)
  • func (this_ *ZKService) Stop()
  • func (this_ *ZKService) WatchChildren(path string, listen func(data *WatchChildrenListenData) (finish bool)) (err error)

Variables

var NodeEventAdded = newNodeEvent("node event node added")

var NodeEventDeleted = newNodeEvent("node event node deleted")

var NodeEventError = newNodeEvent("node event node listen error")

var NodeEventNodeNotFound = newNodeEvent("node event node not found")

var NodeEventStopped = newNodeEvent("node event zk is stopped")

var ZKLogger zk.Logger = &defaultLogger{}

Types

type Config

type Config struct {
	Address  string `json:"address"`
	Username string `json:"username,omitempty"`
	Password string `json:"password,omitempty"`
}

type Info

type Info struct {
	Server    string   `json:"server"`
	SessionID int64    `json:"sessionID"`
	State     zk.State `json:"state"`
}

type NodeEvent

type NodeEvent string

type NodeInfo

type NodeInfo struct {
	Path string    `json:"path"`
	Data string    `json:"data"`
	Stat *StatInfo `json:"stat"`
}

type StatInfo

type StatInfo struct {
	Czxid          int64 `json:"czxid,omitempty"`
	Mzxid          int64 `json:"mzxid,omitempty"`
	Ctime          int64 `json:"ctime,omitempty"`
	Mtime          int64 `json:"mtime,omitempty"`
	Version        int32 `json:"version,omitempty"`
	Cversion       int32 `json:"cversion,omitempty"`
	Aversion       int32 `json:"aversion,omitempty"`
	EphemeralOwner int64 `json:"ephemeralOwner,omitempty"`
	DataLength     int32 `json:"dataLength,omitempty"`
	NumChildren    int32 `json:"numChildren,omitempty"`
	Pzxid          int64 `json:"pzxid,omitempty"`
}

func StatToInfo

func StatToInfo(stat *zk.Stat) (info *StatInfo)

type WatchChildrenListenData

type WatchChildrenListenData struct {
	Path  string
	Event *NodeEvent
	Child string
	Err   error
}

type ZKService

type ZKService struct {
	Config
	// contains filtered or unexported fields
}

ZKService 注册处理器在线信息等

func New

func New(config Config) (service *ZKService, err error)

New 创建zookeeper客户端

func (*ZKService) Create

func (this_ *ZKService) Create(path string, data []byte, mode int32) (err error)

Create 创建节点

func (*ZKService) CreateIfNotExists

func (this_ *ZKService) CreateIfNotExists(path string, data []byte) (err error)

CreateIfNotExists 一层层检查，如果不存在则创建

func (*ZKService) Delete

func (this_ *ZKService) Delete(path string) (err error)

Delete 删除节点 如果有子节点，则子节点一同删除

func (*ZKService) Exists

func (this_ *ZKService) Exists(path string) (isExist bool, err error)

Exists 判断节点是否存在

func (*ZKService) Get

func (this_ *ZKService) Get(path string) (info *NodeInfo, err error)

Get 获取节点信息

func (*ZKService) GetChildren

func (this_ *ZKService) GetChildren(path string) (children []string, err error)

GetChildren 查询子节点

func (*ZKService) GetConn

func (this_ *ZKService) GetConn() *zk.Conn

func (*ZKService) GetServers

func (this_ *ZKService) GetServers() []string

func (*ZKService) Info

func (this_ *ZKService) Info() (info *Info, err error)

Info ZK信息

func (*ZKService) Set

func (this_ *ZKService) Set(path string, data []byte) (err error)

Set 修改节点数据

func (*ZKService) Stat

func (this_ *ZKService) Stat(path string) (info *StatInfo, err error)

Stat 获取节点状态

func (*ZKService) Stop

func (this_ *ZKService) Stop()

func (*ZKService) WatchChildren

func (this_ *ZKService) WatchChildren(path string, listen func(data *WatchChildrenListenData) (finish bool)) (err error)

WatchChildren 监听子节点 子节点 新增 删除