Files
modules/messaging-gossip/hyper-p2p-distributed-event-bus
Raven ScottandCursor f509060710 Add moduleSnapshot() across all modules for uniform state export.
Completes the sixth expansion pass: zero-arg moduleSnapshot aliases snapshot() (or clusterSnapshot/stateSnapshot where specialized), with async variants for temporal, spatial, semantic-vector, and reactive-state indexes.

Co-authored-by: Cursor <[email protected]>
2026-05-21 04:42:45 -04:00
..
2026-05-21 00:07:44 -04:00
2026-05-20 23:36:32 -04:00
2026-05-20 21:02:45 -04:00
2026-05-20 21:02:45 -04:00
2026-05-21 00:07:44 -04:00
2026-05-20 21:02:45 -04:00
2026-05-20 21:02:45 -04:00
2026-05-20 23:36:32 -04:00

hyper-p2p-distributed-event-bus

Distributed append-only event bus: topic pub/sub, vector clocks, signing, Hyperbee replay, Protomux gossip.

Category: Messaging & gossip

Composes with: hyper-p2p-vector-clock, hyper-p2p-gossip-mesh, hyper-p2p-dedup-filter

Protocol: hyper-p2p-distributed-event-bus/v1

When to use

Event-sourced P2P apps that need durable logs and causal metadata across peers.

When not to use

Fire-and-forget messages without persistence (use lighter gossip modules).

Quick start

const HyperP2PDistributedEventBus = require('hyper-p2p-distributed-event-bus')
const bus = new HyperP2PDistributedEventBus({ enableBackgroundTimers: false })
await bus.ready()
bus.subscribe('orders', (e) => console.log(e.payload))
await bus.publish('orders', { sku: 'A1' })
await bus.close()

Docs

Test

npm install && npm test