func()

in clients/zk_client/zk_client.go [204:216]


func (zc *ShenYuZkClient) ensureRoot() error {
	exists, _, err := zc.ZkClient.Exists(zc.Zcp.ZkRoot)
	if err != nil {
		return err
	}
	if !exists {
		_, err := zc.ZkClient.Create(zc.Zcp.ZkRoot, []byte(""), 0, zk.WorldACL(zk.PermAll))
		if err != nil && err != zk.ErrNodeExists {
			return err
		}
	}
	return nil
}