gxzookeeper

Documentation

Overview

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

Index

• type Client
  • 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

Types

type Client

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

func NewClient

func NewClient(conn *zk.Conn) *Client

func (*Client) CreateZkPath

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

节点须逐级创建

func (*Client) DeleteZkPath

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

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

func (*Client) ExistW

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

func (*Client) Get

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

func (*Client) GetChildren

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

func (*Client) GetChildrenW

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

func (*Client) RegisterTemp

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

func (*Client) RegisterTempSeq

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

func (*Client) StateToString

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

func (*Client) ZkConn

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