6 Commits

Include renames

Author	SHA1	Message	Date
3 people	b481dae0b6	feat: implement cross-node event broadcasting with NATSEventBus (#151) ... This PR implements cross-node event broadcasting for aether. Changes: - UpdateVersionCache method in JetStreamEventStore - SubscribeToEventStored helper in NATSEventBus - Integration tests for cross-node scenarios - Example code demonstrating NATSEventBus + JetStreamEventStore Tests: All integration tests passing. Co-authored-by: Claude Code <noreply@anthropic.com> Co-authored-by: Hugo Nijhuis <hugo.nijhuis@flowmade.one> Reviewed-on: #151	2026-05-17 15:29:52 +00:00
HugoNijhuisandClaude Opus 4.5	ef73fb6bfd	Add namespace event filtering (SubscribeWithFilter) ... Adds support for filtering events by type or actor pattern within namespace subscriptions. Key changes: - Add SubscriptionFilter type with EventTypes and ActorPattern fields - Add SubscribeWithFilter to EventBroadcaster interface - Implement filtering in EventBus with full wildcard pattern support preserved - Implement filtering in NATSEventBus (server-side namespace, client-side filters) - Add MatchActorPattern function for actor ID pattern matching - Add comprehensive unit tests for all filtering scenarios Filter Processing: - EventTypes: Event must match at least one type in the list (OR within types) - ActorPattern: Event's ActorID must match the pattern (supports * and > wildcards) - Multiple filters are combined with AND logic This implementation works alongside the existing wildcard subscription support: - Namespace wildcards (* and >) work with event filters - Filters are applied after namespace pattern matching - Metrics are properly recorded for filtered subscriptions Closes #21 Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>	2026-01-10 23:45:57 +01:00
HugoNijhuis	e3dbe3d52d	[Issue #22] Add EventBroadcaster metrics (#49)	2026-01-10 18:52:32 +00:00
HugoNijhuisandClaude Opus 4.5	adead7e980	Add wildcard namespace subscriptions ... Support NATS-style wildcard patterns ("*" and ">") for subscribing to events across multiple namespaces. This enables cross-cutting concerns like logging, monitoring, and auditing without requiring separate subscriptions for each namespace. - Add pattern.go with MatchNamespacePattern and IsWildcardPattern - Update EventBus to track wildcard subscribers separately - Update NATSEventBus to use NATS native wildcard support - Add comprehensive tests for pattern matching and EventBus wildcards - Document security implications in all relevant code comments Closes #20 Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>	2026-01-10 19:24:26 +01:00
HugoNijhuisandClaude Opus 4.5	c757bb76f3	Make configuration values injectable rather than hardcoded ... Add config structs with sensible defaults for tunable parameters: - JetStreamConfig for stream retention (1 year) and replica count (1) - HashRingConfig for virtual nodes per physical node (150) - ShardConfig for shard count (1024) and replication factor (1) Each component gets a new WithConfig constructor that accepts custom configuration, while the original constructors continue to work with defaults. Zero values in configs fall back to defaults for backward compatibility. Closes #38 Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>	2026-01-10 15:33:56 +01:00
HugoNijhuisandClaude	e9e50c021f	Initial aether repository structure ... Distributed actor system with event sourcing for Go: - event.go - Event, ActorSnapshot, EventStore interface - eventbus.go - EventBus, EventBroadcaster for pub/sub - nats_eventbus.go - NATS-backed cross-node event broadcasting - store/ - InMemoryEventStore (testing), JetStreamEventStore (production) - cluster/ - Node discovery, leader election, shard distribution - model/ - EventStorming model types Extracted from arcadia as open-source infrastructure component. Co-Authored-By: Claude <noreply@anthropic.com>	2026-01-08 19:30:02 +01:00