Optimize in real-time

1import { Replane } from '@replanejs/sdk'
2import { Pool } from 'pg'
3
4interface Configs {
5  'db-pool-size': number
6  'db-timeout-ms': number
7  'cache-ttl-seconds': number
8  'max-retries': number
9}
10
11const replane = new Replane<Configs>()
12
13await replane.connect({
14  baseUrl: 'https://replane.example.com',
15  sdkKey: process.env.REPLANE_SDK_KEY
16})
17
18// Initialize pool with configurable size
19let pool = new Pool({
20  max: replane.get('db-pool-size'),
21  idleTimeoutMillis: replane.get('db-timeout-ms')
22})
23
24// Resize pool when config changes
25replane.subscribe('db-pool-size', async (config) => {
26  console.log('Resizing pool to:', config.value)
27  await pool.end()
28  pool = new Pool({
29    max: config.value,
30    idleTimeoutMillis: replane.get('db-timeout-ms')
31  })
32})
33
34// Use configurable timeouts and retries
35async function fetchWithRetry(fn: () => Promise<any>) {
36  const maxRetries = replane.get('max-retries')
37  
38  for (let i = 0; i < maxRetries; i++) {
39    try {
40      return await fn()
41    } catch (err) {
42      if (i === maxRetries - 1) throw err
43    }
44  }
45}