+4 -1

src/server/admin/page.js

reviewed

··· 81 81 statRow("Upstream crawl", badge) 82 82 + statRow("Repos crawled", formatNumber(status.repos_queued_total)) 83 83 + statRow("Resync queue depth", formatNumber(status.resync_queue_depth)) 84 84 + + statRow("Discovery queue depth", formatNumber(status.discovery_queue_depth)) 84 85 + statRow("Resyncs completed", formatNumber(status.resyncs_completed_total)) 85 86 + statRow("Resync-buffered events", formatNumber(status.resync_buffer_count)); 86 87 ··· 233 234 } 234 235 235 236 // Update tab title with queue depth for at-a-glance monitoring 236 236 - document.title = `lightrail \u00b7 Q:${formatNumber(status.resync_queue_depth)}`; 237 237 + const dq = status.discovery_queue_depth; 238 238 + const rq = status.resync_queue_depth; 239 239 + document.title = `lightrail \u00b7 Q:${formatNumber(rq)}${dq ? ` D:${formatNumber(dq)}` : ''}`; 237 240 238 241 // Build all cards 239 242 let html = renderIndexingCard(status)

+2

src/server/admin/status.rs

reviewed

··· 30 30 collection_deaths_resync: u64, 31 31 resyncs_completed_total: u64, 32 32 resync_queue_depth: i64, 33 33 + discovery_queue_depth: usize, 33 34 resync_buffer_count: i64, 34 35 // ── Cardinality estimates (HLL sketches, ~1.6% error at large N) ────── 35 36 distinct_collections: usize, ··· 114 115 collection_deaths_resync: s.collection_deaths_resync.load(Ordering::Relaxed), 115 116 resyncs_completed_total: s.resyncs_completed_total.load(Ordering::Relaxed), 116 117 resync_queue_depth: s.resync_queue_depth.load(Ordering::Relaxed), 118 118 + discovery_queue_depth: dispatcher.as_ref().map_or(0, |d| d.discovery_queue_depth), 117 119 resync_buffer_count: s.resync_buffer_count.load(Ordering::Relaxed), 118 120 distinct_collections: s.sketch_collections.lock().unwrap().estimate(), 119 121 distinct_accounts_all: s.sketch_accounts_all.lock().unwrap().estimate(),