flowmade-one/aether
3
0
Fork 0
Code Issues 5 Pull Requests 7 Actions Packages Projects Releases Wiki Activity

feat: implement cross-node event broadcasting with NATSEventBus #151

Merged
HugoNijhuis merged 2 commits from issue-149-cross-node-broadcasting into main 2026-05-17 15:29:53 +00:00
Conversation 2 Commits 2 Files Changed 8
+1090 -361
2 Commits
Author SHA1 Message Date
Hugo Nijhuis 5fb68fed4a feat: add integration tests and examples for cross-node event broadcasting
CI / build (pull_request) Successful in 1m28s
Details 
- Add integration tests for UpdateVersionCache, SubscribeToEventStored
- Add cross-node broadcasting integration tests
- Add example demonstrating NATSEventBus + JetStreamEventStore integration
- Fix unsafe type assertions in example with ok pattern
- Add documentation for EventStored schema
- Add helper methods: GetCachedVersion, SetBroadcaster, Close
- Add constructors: NewNATSEventBusWithBroadcaster, NewNATSEventBusWithStore
 2026-05-17 16:39:25 +02:00
Claude Code f46348ab07 feat: implement cross-node event broadcasting with NATSEventBus 
- Add UpdateVersionCache method to JetStreamEventStore for cache synchronization
- Add SubscribeToEventStored convenience helper to NATSEventBus
- Create integration tests for cross-node broadcasting scenarios
- Add example demonstrating NATSEventBus + JetStreamEventStore integration
- Tests verify:
  - Single-node broadcasting works
  - Multi-node event flow works
  - Version cache consistency across nodes
  - Namespace isolation maintained
  - EventStored subscription works correctly
 2026-05-17 13:46:50 +02:00