()
| 57 | } |
| 58 | |
| 59 | func (rc *RpcConnectClient) GetAllConnectTypeRpcClient() (rpcClientList []client.XClient) { |
| 60 | for serverId, _ := range rc.ServerInsMap { |
| 61 | c, err := rc.GetRpcClientByServerId(serverId) |
| 62 | if err != nil { |
| 63 | logrus.Infof("GetAllConnectTypeRpcClient err:%s", err.Error()) |
| 64 | continue |
| 65 | } |
| 66 | rpcClientList = append(rpcClientList, c) |
| 67 | } |
| 68 | return |
| 69 | } |
| 70 | |
| 71 | func getParamByKey(s string, key string) string { |
| 72 | params := strings.Split(s, "&") |
no test coverage detected