* @param {Boolean} waitReconnect * @returns {Promise >} * @ignore * @internal
(waitReconnect)
| 271 | * @internal |
| 272 | */ |
| 273 | async refreshKeyspacesInternal(waitReconnect) { |
| 274 | this.log('info', 'Retrieving keyspaces metadata'); |
| 275 | try { |
| 276 | this.keyspaces = await this._schemaParser.getKeyspaces(waitReconnect); |
| 277 | return this.keyspaces; |
| 278 | } |
| 279 | catch (err) { |
| 280 | this.log('error', 'There was an error while trying to retrieve keyspaces information', err); |
| 281 | throw err; |
| 282 | } |
| 283 | } |
| 284 | |
| 285 | _getKeyspaceReplicas(keyspace) { |
| 286 | if (!keyspace.replicas) { |
no test coverage detected