(pgClient: PoolClient)
| 117 | } |
| 118 | |
| 119 | private setupKeepAlive(pgClient: PoolClient) { |
| 120 | const interval = argv['sl-keep-alive-interval'] || 180000; |
| 121 | logger.info(`Setup PG Pool keep alive. interval ${interval} ms`); |
| 122 | setInterval(() => { |
| 123 | void (async () => { |
| 124 | try { |
| 125 | await pgClient.query('SELECT 1'); |
| 126 | } catch (err) { |
| 127 | getLogger('db').error('Schema listener client keep-alive query failed: ', err); |
| 128 | } |
| 129 | })(); |
| 130 | }, interval); |
| 131 | } |
| 132 | |
| 133 | private async createServer() { |
| 134 | const app = this.httpAdapterHost.httpAdapter.getInstance(); |
no test coverage detected