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
}