moscajs / aedes-persistence-mongodb / 24882453311

96%

push

github

fix: add unique index on retained.topic to prevent COLLSCAN stalls (#91)

Without an index on `retained.topic`, every storeRetained upsert and
createRetainedStreamCombi lookup falls back to a collection scan. Under
load, the ordered bulkWrite in storeRetained serializes the whole
publish pipeline behind those scans, stalling broker.publish callbacks
by tens of seconds on deployments with thousands of retained topics
(observed: ~60s uniform lag with 15k retained + 200 msg/s).

The index is declared `unique` to match the {topic}-filtered upsert
semantics. Also extends the index factory to honor the `unique` flag.

Co-authored-by: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

174 of 184 branches covered (94.57%)

Branch coverage included in aggregate %.

16 of 16 new or added lines in 1 file covered. (100.0%)

1383 of 1438 relevant lines covered (96.18%)

147.28 hits per line