zookeeper

Documentation

Index

• Variables
• func Connect(addr []string, timeout time.Duration) (*zk.Conn, error)
• func Create(conn *zk.Conn, fpath string) error
• func GetNodeData(conn *zk.Conn, path string) ([]byte, error)
• func GetNodesW(conn *zk.Conn, path string) ([]string, <-chan zk.Event, error)
• func RegisterTempNode(conn *zk.Conn, fpath string, data []byte) error
• func SetNodeData(conn *zk.Conn, path string, data []byte) error

Variables

var (
	ErrNoChild      = errors.New("zk: children is nil")
	ErrNodeNotExist = errors.New("zk: node not exist")
)

Functions

func Connect

func Connect(addr []string, timeout time.Duration) (*zk.Conn, error)

连接到zookeeper

func Create

func Create(conn *zk.Conn, fpath string) error

func GetNodeData

func GetNodeData(conn *zk.Conn, path string) ([]byte, error)

func GetNodesW

func GetNodesW(conn *zk.Conn, path string) ([]string, <-chan zk.Event, error)

创建节点,并返回watch

func RegisterTempNode

func RegisterTempNode(conn *zk.Conn, fpath string, data []byte) error

注册一个临时znode

func SetNodeData

func SetNodeData(conn *zk.Conn, path string, data []byte) error