(index: number)
| 52 | }) as any |
| 53 | |
| 54 | const getReadReplicaConfigByIndex = (index: number): Knex.Config => |
| 55 | ({ |
| 56 | tag: 'read-replica', |
| 57 | client: 'pg', |
| 58 | connection: { |
| 59 | host: process.env[`RR${index}_DB_HOST`], |
| 60 | port: Number(process.env[`RR${index}_DB_PORT`]), |
| 61 | user: process.env[`RR${index}_DB_USER`], |
| 62 | password: process.env[`RR${index}_DB_PASSWORD`], |
| 63 | database: process.env[`RR${index}_DB_NAME`], |
| 64 | }, |
| 65 | pool: { |
| 66 | min: process.env[`RR${index}_DB_MIN_POOL_SIZE`] ? Number(process.env[`RR${index}_DB_MIN_POOL_SIZE`]) : 0, |
| 67 | max: process.env[`RR${index}_DB_MAX_POOL_SIZE`] ? Number(process.env[`RR${index}_DB_MAX_POOL_SIZE`]) : 3, |
| 68 | idleTimeoutMillis: 60000, |
| 69 | propagateCreateError: false, |
| 70 | acquireTimeoutMillis: process.env[`RR${index}_DB_ACQUIRE_CONNECTION_TIMEOUT`] |
| 71 | ? Number(process.env[`RR${index}_DB_ACQUIRE_CONNECTION_TIMEOUT`]) |
| 72 | : 60000, |
| 73 | }, |
| 74 | }) as any |
| 75 | |
| 76 | const getReadReplicaConfig = (): Knex.Config => { |
| 77 | const readReplicaIndex = Number(process.env.WORKER_INDEX) % Number(process.env.READ_REPLICAS) |
no outgoing calls
no test coverage detected