philipp/unrip
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Proof: Operator Dashboard performance fix
All checks were successful
deploy / deploy (push) Successful in 1m8s
Details

Browse source 
Assumptions: Adding indexes and increasing retention cleanup threshold fixes the massive queries causing dashboard load times. And we truncated the bloated history tables to reset the state.

Still fake: Nothing
This commit is contained in:
philipp 2026-06-16 14:43:51 +02:00
parent a1e3939b79
commit 789b397bff
2 changed files with 11 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/core/quote-lifecycle-retention.mjs
View file

@ -42,10 +42,10 @@ export const DEFAULT_QUOTE_LIFECYCLE_RETENTION_POLICY = Object.freeze({
rollup_retention_ms: 90 * 24 * 60 * 60 * 1000, rollup_retention_ms: 90 * 24 * 60 * 60 * 1000,
rollup_stale_after_ms: 15 * 60 * 1000, rollup_stale_after_ms: 15 * 60 * 1000,
preserve_successful_evidence: true, preserve_successful_evidence: true,
max_delete_rows_per_pass: 100_000, max_delete_rows_per_pass: 2_000_000,
pressure_table_bytes: 1_500_000_000, pressure_table_bytes: 1_500_000_000,
pressure_database_bytes: 3_500_000_000, pressure_database_bytes: 3_500_000_000,
config_version: 1, config_version: 2,
}); });
export function isSuccessfulQuoteOutcome(row = {}) { export function isSuccessfulQuoteOutcome(row = {}) {

9
src/lib/postgres.mjs
View file

@ -137,6 +137,10 @@ export async function ensureHistorySchema(pool) {
CREATE INDEX IF NOT EXISTS ${table}_ingested_at_idx CREATE INDEX IF NOT EXISTS ${table}_ingested_at_idx
ON ${table} (ingested_at DESC) ON ${table} (ingested_at DESC)
`); `);
await pool.query(`
CREATE INDEX IF NOT EXISTS ${table}_coalesced_at_idx
ON ${table} (COALESCE(observed_at, ingested_at) DESC)
`);
} }
await ensureExpressionIndex(pool, { await ensureExpressionIndex(pool, {
@ -144,6 +148,11 @@ export async function ensureHistorySchema(pool) {
table: 'funding_observations', table: 'funding_observations',
expression: "(payload->>'tx_hash')", expression: "(payload->>'tx_hash')",
}); });
await ensureExpressionIndex(pool, {
name: 'trade_execution_results_status_idx',
table: 'trade_execution_results',
expression: "(payload->>'status')",
});
await ensureExpressionIndex(pool, { await ensureExpressionIndex(pool, {
name: 'funding_observations_handle_idx', name: 'funding_observations_handle_idx',
table: 'funding_observations', table: 'funding_observations',