550 B
550 B
NATS — verae-archive-worm
| Direction | Address | From / to | Body |
|---|---|---|---|
| IN | verae.archive.put |
splitter | { sha256, tenantId, kind, record, traceId } |
| IN | verae.archive.query |
aggregator (broadcast) | { correlationId, sha256, tenantId, kinds[], traceId } |
| OUT | verae.archive.reply.<correlationId> |
aggregator | { archiveId, sha256, records[], traceId } only if bloom.mightHave(sha256) |
Subscribe to query without a shared queue group so every archive sees every query.