(waitReconnect)
| 396 | } |
| 397 | |
| 398 | async getKeyspaces(waitReconnect) { |
| 399 | const keyspaces = {}; |
| 400 | const result = await this.cc.query(_selectAllKeyspacesV1, waitReconnect); |
| 401 | for (let i = 0; i < result.rows.length; i++) { |
| 402 | const row = result.rows[i]; |
| 403 | const ksInfo = this._createKeyspace(row['keyspace_name'], row['durable_writes'], row['strategy_class'], JSON.parse(row['strategy_options'] || null)); |
| 404 | keyspaces[ksInfo.name] = ksInfo; |
| 405 | } |
| 406 | return keyspaces; |
| 407 | } |
| 408 | |
| 409 | async getKeyspace(name) { |
| 410 | const row = await this._getFirstRow(format(_selectSingleKeyspaceV1, name)); |
nothing calls this directly
no test coverage detected