aether

flowmade-one/aether

Fork 0

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

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

1 changed files with 1 additions and 1 deletions

									
										go.mod
									
		+1
		-1
	
												View File
												
				@@ -5,7 +5,7 @@ go 1.23.0

				require (

					github.com/google/uuid v1.6.0

					github.com/nats-io/nats.go v1.37.0

					github.com/prometheus/client_golang v1.24.1

					github.com/prometheus/client_golang v1.23.2

				)

				require (

Compare commits