mirror of
https://github.com/vitorpamplona/amethyst.git
synced 2026-08-09 08:04:45 +00:00
Streams 50k events from an upstream KtorRelay to a downstream via the production MirrorWorker (real OkHttp WebSocket + trusted skipVerify ingest) and asserts the downstream receives every one — 50000/50000, 0 missing. This closes the last untested layer: the in-process guards (BatchInsertLossTest, ConcurrentIngestLossTest) call IngestQueue.submit directly, bypassing the wire. With this, geode is proven lossless end-to-end — store, concurrent pipeline, background pool contention, RelaySession, and the real WS mirror path. The ~0.05% shortfall seen in the geode↔geode relayBench sync is therefore an artifact of the harness's hand-rolled fetchByIds+publish delta transfer, not a geode event-loss bug. Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com> Claude-Session: https://claude.ai/code/session_012EZeWww5TJnzBZKPoc6mvU