Method create

pkg/models/zk/zkclient.go:235–250

(conn *zk.Conn, path string, data []byte, flag int32)

}

func (c *Client) create(conn *zk.Conn, path string, data []byte, flag int32) (string, error) {
	if err := c.mkdir(conn, filepath.Dir(path)); err != nil {
		return "", err
	}
	p, err := conn.Create(path, data, flag, func() []zk.ACL {
		const perm = zk.PermAdmin | zk.PermRead | zk.PermWrite
		if c.username != "" {
			return zk.DigestACL(perm, c.username, c.password)
		}
		return zk.WorldACL(perm)
	}())
	if err != nil {
		return "", errors.Trace(err)
	}
	return p, nil
}

func (c *Client) watch(conn *zk.Conn, path string) (<-chan struct{}, error) {
	_, _, w, err := conn.GetW(path)