in clients/zk_client/zk_client.go [165:181]
func (zc *ShenYuZkClient) RegisterServiceInstance(metaData interface{}) (registerResult bool, err error) {
mdr := zc.checkCommonParam(metaData, err)
err = zc.ensureRoot()
if err != nil {
logger.Fatalf("ensureRoot failure, err %v:", err)
}
path := zc.Zcp.ZkRoot + "/" + mdr.AppName
data, err := json.Marshal(metaData)
if err != nil {
return false, err
}
_, err = zc.ZkClient.Create(path, data, 0, zk.WorldACL(zk.PermAll))
if err != nil {
return false, err
}
return true, nil
}