gxzookeeper

package

v0.3.0 Latest Latest Go to latest Published: Jul 29, 2018 License: Apache-2.0 Imports: 4 Imported by: 1

Details

Package gxzookeeper provides a zookeeper driver based on samuel/go-zookeeper/zk

This section is empty.

This section is empty.

This section is empty.

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

func NewClient(conn *zk.Conn) *Client

func (c *Client) CreateZkPath(basePath string) error

节点须逐级创建

func (c *Client) DeleteZkPath(path string) error

像创建一样，删除节点的时候也只能从叶子节点逐级回退删除当节点还有子节点的时候，删除是不会成功的

func (c *Client) ExistW(path string) (<-chan zk.Event, error)

func (c *Client) Get(path string) ([]byte, error)

func (c *Client) GetChildren(path string) ([]string, error)

func (c *Client) GetChildrenW(path string) ([]string, <-chan zk.Event, error)

func (c *Client) RegisterTemp(path string, data []byte) (string, error)

func (c *Client) RegisterTempSeq(path string, data []byte) (string, error)

func (c *Client) StateToString(state zk.State) string

func (c *Client) ZkConn() *zk.Conn